kafka-consumer:卡夫卡消费者

【文件属性】：

文件名称：kafka-consumer:卡夫卡消费者

文件大小：14KB

文件格式：ZIP

更新时间：2024-05-29 13:46:09

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)