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密钥的密
kafkaProp都可以设置哪些参数

原文地址: https://www.cveoy.top/t/topic/hiyl 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录