【文件属性】：
文件名称：KafkaDemo:kafka Java API
文件大小：23KB
文件格式：ZIP
更新时间：2021-05-18 18:21:24
Java
#Kafka Java API案例
Producer
可选配置，如果不配置，则使用默认的partitioner根据key值value映射到指定的Parition
props.put("partitioner.class", "kafka.demo.PartitionerDemo");
Consumer
String key=(String)obj;
int offset = key.lastIndexOf('.');
if(offset>0){
partition = Integer.parseInt(key.substring(offset + 1)) % numPartitions;
}
【文件预览】：
KafkaDemo-master
----bin()
--------kafka()
----src()
--------kafka()
----README.md(383B)