我们正在进行有状态的行动。我们的集群是被管理的。每次创建内部主题，我们必须要求管理员家伙解锁，以便内部主题可以创建Kafka流应用程序。我们可以控制目标集群而不是源集群。那么，想了解哪些集群源/目标是内部主题创建的吗？
ubby3x7f1#
到目前为止，kafka流应用程序只能支持到中定义的一个集群的连接 BOOTSTRAP_SERVERS_CONFIG 流内配置。如上所述，所有源主题都驻留在这些代理中，所有内部主题（changelog/重新分区主题）都创建在同一集群中。kstream应用程序也将在同一集群中创建目标主题。有必要查看服务器日志以了解和分析实际的根本原因。
BOOTSTRAP_SERVERS_CONFIG
p8h8hvxi2#
其他答案表明，kafka流应用程序应该只连接一个集群。内部主题由kafka流应用程序创建，并且仅由创建它的应用程序使用。但是，在代理端可能存在一些与安全设置相关的配置，这些配置可能会阻止流应用程序创建以下主题：如果在kafka代理上启用了安全性，则必须授予基础客户端管理权限，以便它们可以创建内部主题集。有关更多信息，请参阅streams security。从这里引述要记住的另一点是，内部主题是由流应用程序自动创建的，并且没有用于自动创建内部主题的显式配置。
dgtucam13#
好吧，kafka streams应用程序只连接到一个集群，所有的源/目标/内部主题都在那里创建。
3条答案
按热度按时间ubby3x7f1#
到目前为止，kafka流应用程序只能支持到中定义的一个集群的连接
BOOTSTRAP_SERVERS_CONFIG流内配置。如上所述，所有源主题都驻留在这些代理中，所有内部主题（changelog/重新分区主题）都创建在同一集群中。kstream应用程序也将在同一集群中创建目标主题。
有必要查看服务器日志以了解和分析实际的根本原因。
p8h8hvxi2#
其他答案表明，kafka流应用程序应该只连接一个集群。内部主题由kafka流应用程序创建，并且仅由创建它的应用程序使用。但是，在代理端可能存在一些与安全设置相关的配置，这些配置可能会阻止流应用程序创建以下主题：
如果在kafka代理上启用了安全性，则必须授予基础客户端管理权限，以便它们可以创建内部主题集。有关更多信息，请参阅streams security。
从这里引述
要记住的另一点是，内部主题是由流应用程序自动创建的，并且没有用于自动创建内部主题的显式配置。
dgtucam13#
好吧，kafka streams应用程序只连接到一个集群，所有的源/目标/内部主题都在那里创建。