beenryuu/kafkademo

Kafka Demo

概要

Kafka API(Java)を利用した簡単な KafkaProducer と KafkaConsumer。

参考した資料はこちら。

使い方

1. mavenでパッケージング

   $ mvn package
   
   // fat jar が作成される
   $ ls -ahl target/KafkaDemo-1.1-SNAPSHOT-jar-with-dependencies.jar 
   -rw-r--r--  1 bliu2  staff    17M Oct  2 18:08 target/KafkaDemo-1.1-SNAPSHOT-jar-with-dependencies.jar 
   

2. producer起動

   $ java -classpath ./KafkaDemo-1.1-SNAPSHOT-jar-with-dependencies.jar [-DmessageCount=送信するメッセージ数] [-DclientId=producer識別子] [-DtopicName=topic名] [-DkafkaBrokers=brokerリスト] ind.bliu.demo.kafka.AppProducer
   

   • messageCount　送信するメッセージ数。指定なしの場合は1000
   • clientId　producerの識別子。指定なしの場合はclient1
   • topicName　送信先トピック名。指定なしの場合はmytopic
   • kafkaBrokers　kafka brokerリスト。指定なしの場合は10.0.0.62:9092,10.0.0.200:9092,10.0.0.16:9092

3. consumer起動

   $ java -classpath ./KafkaDemo-1.1-SNAPSHOT-jar-with-dependencies.jar [-DtopicName=topic名] [-DclientId=consumer識別子] [-DgroupId=consumer group名] [-DoffsetReset=latest|earliest] [-DkafkaBrokers=brokerリスト] [-DmaxNoMessageFoundCount=consumer待機時間] ind.bliu.demo.kafka.AppConsumer
   

   • groupId　consumer group名。指定なしの場合はgroup1
   • clientId consumerの識別子。指定なしの場合はclient1
   • offsetReset　consumerの受信開始offset（latestまたはearliest）。指定なしの場合はearliest
   • maxNoMessageFoundCount　consumerが終了するまでに、メッセージ受信しない状態が続く最大時間（秒）。指定なしの場合は100
   • topicName　受信先トピック名。指定なしの場合はmytopic
   • kafkaBrokers　kafka brokerリスト。指定なしの場合は10.0.0.62:9092,10.0.0.200:9092,10.0.0.16:9092