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

>>阅读原文<<