我无法在kafka低级使用者中传递任何与身份验证相关的参数（对于ssl/sasl）。我只是想知道kafka低层消费者是否支持身份验证功能。kafka服务器版本：0.10.1.0Kafka客户端版本：0.10.2.1/旧版本
yuvru6vn1#
ssl和sasl仅在java客户机中可用( org.apache.kafka.clients ).我猜你所说的“低级别”客户机是旧的scala客户机，现在已经被弃用，在下一个版本中将被删除。看到了吗https://kafka.apache.org/documentation/#legacyapis您现在应该只使用正确支持的java客户机，请参阅https://kafka.apache.org/documentation/#api
org.apache.kafka.clients
1条答案
按热度按时间yuvru6vn1#
ssl和sasl仅在java客户机中可用(
org.apache.kafka.clients).我猜你所说的“低级别”客户机是旧的scala客户机，现在已经被弃用，在下一个版本中将被删除。看到了吗https://kafka.apache.org/documentation/#legacyapis
您现在应该只使用正确支持的java客户机，请参阅https://kafka.apache.org/documentation/#api