kafka 自定义分区实例

第一步：使用./kafka-topics.sh 命令建立topic及partitions 分区数java bin/kafka-topics.sh --create --zookeeper 192.168.31.130:2181 --replication-factor 2 --partitions 3 --topic Topic-test 第二步：实现org.apache.kafka.client

>>阅读原文<<