【发布时间】:2018-06-07 16:57:42
【问题描述】:
我无法在 kafka 低级消费者中传递任何与身份验证相关的参数(用于 ssl/sasl)。只是想知道Kafka低级消费者是否支持身份验证功能。
- Kafka 服务器版本:0.10.1.0
- Kafka 客户端版本:0.10.2.1/older_versions
【问题讨论】:
标签: authentication apache-kafka kafka-consumer-api
我无法在 kafka 低级消费者中传递任何与身份验证相关的参数(用于 ssl/sasl)。只是想知道Kafka低级消费者是否支持身份验证功能。
【问题讨论】:
标签: authentication apache-kafka kafka-consumer-api
SSL 和 SASL 仅在 Java 客户端 (org.apache.kafka.clients) 中可用。
我猜你所说的“低级”客户端是旧的 Scala 客户端,它们现在已被弃用,并将在下一个版本中删除。见https://kafka.apache.org/documentation/#legacyapis
您现在应该只使用正确支持的 Java 客户端,请参阅 https://kafka.apache.org/documentation/#api
【讨论】: