I have read many documentation about Kafka but am still confused about the Java development . If I want to integrate kafka into our system, I need to write my own producer and consumer in Java. It is not very clear to me what Java APIs are available to client developers and there is no detailed documentation for those APIs. The other thing is about compiling. How to find all the required jars to compile a customized producer and consumer? Do I need to learn Scala? I will appreciate if anyone can give me some details.
[info] Loading project definition from /opt/kafka/project [info] Set current project to Kafka (in build file:/opt/kafka/) [error] Not a valid command: release-zip [error] Expected '/' [error] Expected ':' [error] Not a valid key: release-zip [error] release-zip [error]
It works for me. I am on 0.8: $ git --no-pager log --max-count=5 --pretty=oneline --decorate e37a4644209de00f265a5361b31ca63cafc895e9 (HEAD) Trivial commit - warn on consumer fetch request errors. 6e640e355632d97e322e462c2bbc379c05d407a4 kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede 2d7403174f8fd6d35fce05585a7ee6edb8af7dd4 kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; reviewed by Jun Rao ede85875a3aea5723baf82736cc71bb1a04a6102 KAFKA-872; Socket server should set send/recv socket buffer sizes; reviewed by Jun Rao. 1976ce8069818c2c6d093b5b75e8f7b6653120bc KAFKA-870 hadoop-producer KafkaRecordWriter writes entire input buffer capacity, even when intended payload is smaller; reviewed by Neha Narkhede
Here is my output: $ ./sbt release-zip [info] Loading project definition from /home/foo-user/kafka/project [info] Set current project to Kafka (in build file:/home/foo-user/kafka/) [success] Total time: 9 s, completed May 7, 2013 6:41:13 PM
Thanks for the example. My version is not the latest 0.8.
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext