我们已经在集群级别上禁用了自动主题创建。那时我们不需要Kafka流。现在我们想使用Kafka流。我们意识到我们需要启用自动主题创建以使Kafka流正常工作。在不启用自动主题创建的情况下,Kafka流有什么工作方法
2ledvvac1#
Kafka Streams Package 了AdminClient,因此它将自动+编程地创建它所需要的主题,而无需您做任何其他事情。
aor9mmx12#
使用平台团队使用的工具或kafka-acls命令(命令参考),为您在流应用程序中用于主题创建/删除等的用户/服务帐户添加所需的权限
bin/kafka-acls.sh --add --cluster --operation Create --authorizer-properties zookeeper.connect=localhost:2181 --allow-principal User:service-account
2条答案
按热度按时间2ledvvac1#
Kafka Streams Package 了AdminClient,因此它将自动+编程地创建它所需要的主题,而无需您做任何其他事情。
aor9mmx12#
使用平台团队使用的工具或kafka-acls命令(命令参考),为您在流应用程序中用于主题创建/删除等的用户/服务帐户添加所需的权限