【文件属性】：
文件名称：kafka-examples:带有 java 和 gzip 编码的 kafka 示例
文件大小：21KB
文件格式：ZIP
更新时间：2021-06-19 23:08:39
Java
kafka-例子
此应用程序包含一个用 Java 编写的 Apache Kafka 消费者/生产者控制器的简短示例
Gzip压缩
生产者能够使用 gzip 压缩发送数据，从而显着减少发送到代理的数据量。 集群中不需要进一步的配置，只需指定您将在项目中找到的serializer.class属性并像这样启用 gzip：
如果您希望 gzip 压缩集
serializer.class=es.cancamusa.kafka.codecs.GzipEncoder
kafka.gzip=true
如果不
serializer.class=kafka.serializer.StringEncoder
kafka.gzip=false
使用 Gzip 压缩时，消费者将能够使用GzipDecoder类对消息流进行解码。
【文件预览】：
kafka-examples-master
----.project(545B)
----README.md(754B)
----pom.xml(1KB)
----target()
--------test-classes()
--------classes()
----.settings()
--------org.eclipse.core.resources.prefs(115B)
--------org.eclipse.jdt.core.prefs(238B)
--------org.eclipse.m2e.core.prefs(86B)
----src()
--------test()
--------main()
----.classpath(929B)