KafkaDemo:kafka Java API

【文件属性】：

文件名称：KafkaDemo:kafka Java API

文件大小：23KB

文件格式：ZIP

更新时间：2024-06-07 12:08:04

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)