文件名称：kafka自定义partition分发策略实例代码.zip
文件大小：13KB
文件格式：ZIP
更新时间：2022-10-16 10:20:22
java实例代码 kafka分发策略 kafka partition策略 Partitioner
kafka版本:kafka_2.11-0.9.0.1 kafka jar包版本:0.9.0.1 kafka集群:192.168.1.101,192.168.1.102,192.168.1.103 partition分发策略主要是自定义Partitioner的实现类,通过根据key和分区数量来实现
【文件预览】：
.project
pom.xml
target
----test-classes()
----classes()
--------demo()
.settings
----org.eclipse.core.resources.prefs(121B)
----org.eclipse.jdt.core.prefs(243B)
----org.eclipse.m2e.core.prefs(90B)
src
----test()
--------resources()
--------java()
----main()
--------resources()
--------java()
.classpath