Kafka–Producer参数

admin • 2022-02-12 22:20 • 好物分享

三个必选项
key.serializer 数据写入key的序列化器
默认值没有
参数为 org.apache.kafka.common.serialization.Serializer 接口的实现类
String类型可以用org.apache.kafka.common.serialization.StringSerializer
value.serializer 数据写入value的序列化器
默认值没有
参数可以为 org.apache.kafka.common.serialization.Serializer接口的实现类
String类型可以用 org.apache.kafka.common.serialization.StringSerializer
bootstrap.servers broker机器的地址
其他为可选项
buffer.memory 生产者客户端可以使用的内存总大小,不仅限于消息大小,比如压缩算法占用的内存也计算在其中
默认值 33554432 (32M)
com