文件名称：kafka-examples:带有 java 和 gzip 编码的 kafka 示例
文件大小：21KB
文件格式：ZIP
更新时间：2024-07-09 16:55:19
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)