apache-kafka

1열

2답변

나는 maven에 초보자이며 strom kafka TestTopology spout를 실행하려고 시도하지만 pom 파일은 storm-kafka spout에서 storm-kafka contrib에 제공되지 않습니다. 나는 Lein을 사용했고 그것은 작동하지 않았다. 나는 또한 pom을 lein pom (그리고 그것을 수정하는 것)을 사용하여 스스로 만들려고

21열

5답변

Avro 바이너리 인코더를 사용하여 카프카 메시지를 인코딩/디코딩하는 방법은 무엇입니까?

카프 카에서 읽고 쓰는 메시지에 Avro를 사용하려고합니다. 누구든지 Avro 바이너리 인코더를 사용하여 메시지 대기열에 넣을 데이터를 인코딩/디코딩하는 예가 있습니까? 카프카 부품보다 Avro 부품이 필요합니다. 아니면 다른 해결책을 찾아야할까요? 기본적으로, 나는 공간에 관해서 JSON에보다 효율적인 솔루션을 찾으려고 노력하고있다. Avro는 JSON보