【文件属性】：
文件名称：kafka-consumer:卡夫卡消费者
文件大小：14KB
文件格式：ZIP
更新时间：2021-05-09 19:59:29
Java
kafka-consumer
kafka-consumer是基于Kafka-0.8.20封装的consumer。kafka-consumer的目的在于让业务开发人员不必了解kafka就能开发。并且提供消息过滤功能。
Example
关于kafka-consumer的使用，可以参考如下代码。
public class Example {
private static final Logger LOG = Logger.getLogger(Example.class);
private static String topic = "test";
private static int partitionNum = 1;
private static String zkConnectUrl = "127.0.0.1:2181";
private static String zkSessionT
【文件预览】：
kafka-consumer-master
----src()
--------test()
--------main()
----README.md(2KB)
----pom.xml(5KB)
----.gitignore(41B)