Kafka 消息的消费原理

标签：simple   att   hashcode   imp   消费   www   man   htm   com   

https://www.cnblogs.com/huxi2b/p/6061110.html

1.老版本的kafka的offset是维护在zk上的，新版本的kafka把consumer的offset维护保存在kafka的内部topic上

Math.abs(groupID.hashCode()) % numPartitions

int abs = Math.abs("group-a".hashCode() % 50);

  bin/kafka-simple-consumer-shell.sh --topic __consumer_offsets --partition 47 --broker-list localhost:9092 --formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter"

Kafka 消息的消费原理

标签：simple   att   hashcode   imp   消费   www   man   htm   com   

原文地址：https://www.cnblogs.com/newlangwen/p/12183488.html