嗨,我想知道是否有一个类似的api在.net库中创建一个主题,同样的方式 AdminUtils.createTopic(zkClient, myTopic, 10, 1, new Properties()); 是否可用于java客户端?否则,我将如何以编程方式创建主题?谢谢您。
AdminUtils.createTopic(zkClient, myTopic, 10, 1, new Properties());
wlsrxk511#
客户端库中当前没有允许您执行此操作的管理api。请参见.net客户端github上的第48期。取决于如何配置代理( auto.create.topics.enable ),则可以在将生产者或使用者附加到主题后自动创建主题。这种方法的缺点是,您无法轻松设置具有不同设置的主题,因为它们将使用代理中配置的默认设置进行设置。创建主题的一种不太好但目前唯一功能齐全的方法是调用命令行管理工具(例如。 kafka-topics )并将设置作为参数传递。
auto.create.topics.enable
kafka-topics
1条答案
按热度按时间wlsrxk511#
客户端库中当前没有允许您执行此操作的管理api。请参见.net客户端github上的第48期。
取决于如何配置代理(
auto.create.topics.enable
),则可以在将生产者或使用者附加到主题后自动创建主题。这种方法的缺点是,您无法轻松设置具有不同设置的主题,因为它们将使用代理中配置的默认设置进行设置。创建主题的一种不太好但目前唯一功能齐全的方法是调用命令行管理工具(例如。
kafka-topics
)并将设置作为参数传递。