当设置 value.serializer =org.apache.kafka.common.serialization.StringSerializer
发送的消息是按照明文格式,获取的时候也直接String。
在此想要了解的问题是value.serializer 是否具有压缩功能?还是仅仅将消息序列化了?
循环10000次发送2.5kb的消息,使用
org.apache.kafka.common.serialization.StringSerializer
和
org.apache.kafka.common.serialization.ByteArraySerializer
消耗的时间并没有什么差别。
我是该在序列化之前,先把内容压缩压缩?(例如gzip压缩)
max.request.size=3376156
batch.size=16384
buffer.memory=671088640
send.buffer.bytes=1310720
另外这些参数设置并没有起作用