kafkaProp都可以设置哪些参数
KafkaProp可以设置以下参数:
- bootstrap.servers:指定Kafka集群中的Broker地址列表
- group.id:指定消费者组的唯一标识符
- enable.auto.commit:指定是否启用自动提交偏移量
- auto.commit.interval.ms:指定自动提交偏移量的时间间隔
- session.timeout.ms:指定消费者与服务器之间的会话超时时间
- key.deserializer:指定键的反序列化器
- value.deserializer:指定值的反序列化器
- key.serializer:指定键的序列化器
- value.serializer:指定值的序列化器
- max.poll.records:指定每次拉取的最大记录数
- max.poll.interval.ms:指定消费者在单次轮询中处理消息的最大时间
- fetch.max.bytes:指定每次拉取消息的最大字节数
- fetch.min.bytes:指定每次拉取的最小字节数
- fetch.max.wait.ms:指定拉取消息的最长等待时间
- auto.offset.reset:指定当消费者组中没有初始偏移量或偏移量超出范围时的重置行为
- security.protocol:指定Kafka集群的安全协议
- ssl.truststore.location:指定SSL证书的路径
- ssl.truststore.password:指定SSL证书的密码
- ssl.keystore.location:指定SSL密钥的路径
- ssl.keystore.password:指定SSL密钥的密码
- ssl.key.password:指定SSL密钥的密
原文地址: https://www.cveoy.top/t/topic/hiyl 著作权归作者所有。请勿转载和采集!