生产数据
生产数据
bin/kafka-console-producer.sh --topic topicname --broker-list 192.168.0.1:9092
消费数据
bin/kafka-console-consumer.sh --topic topicname --zookeeper 192.168.0.1:2182
指定消费位置消费
bin/kafka-console-consumer.sh --topic topicname --zookeeper 192.168.0.1:2181 --from-beginning
使用bootstrap-server命令消费
bin/kafka-console-consumer.sh --topic topicname --bootstrap-server 192.168.0.1:9092
broker端口号:9092
zookeeper端口号:2181
0.9版本以上kafka的offset存储在broker的 __consumer_offsets topic 中,默认分区为50
保存格式为:groupid-topic-partition -> offset
日志数据分离
log.dirs=/opt/module/kafka/data(/opt/module/kafka/logs 数据存储位置)
网友评论