Kafka 消息的消费原理

Posted 2021-03-16 newlangwen

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"