Kafka主题作为聊天室标识符

Question

我对一个可能有可能的聊天室的消息传递聊天应用程序感兴趣。 我试图了解Kafka主题是否可以用作Kafka概念观点的聊天室标识符？

由于聊天室通常是在运行时创建的，因此意味着

• 应该在运行时创建Kafka主题。是否可以？
• 用户应该能够在创建新主题（聊天室）。是否可以？
• 会有很多聊天室。 Kafka有大量主题是不好的还是可以的？

Answer 1

Kafka主题应在运行时创建。可能吗？

是的。 kafka adminclient 用于管理功能，包括列表，创建和删除主题。

我们可以使用肌肉图创建新主题：

Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
AdminClient admin = AdminClient.create(props);


CreateTopicsResult newTopic = admin.createTopics(Collection.singletonList(new NewTopic(TOPIC_NAME, NUM_PARTITIONS, REP_FACTOR)));

admin.close(Duration.ofSeconds(30));

上述代码来自Kafka：“权威指南”第二版，第5章以编程方式管理Apache Kafka，它讨论了很多有关adminclient的讨论。

对于Spring-Kafka，提供 createModifyTopics（）方法。

用户应该在创建新主题（聊天室）时订阅。可能吗？

是的。我们可以在.subscribe（）中使用正则表达式：

表达式可以匹配多个主题名称，如果某人创建一个具有匹配名称的新主题，那么重新平衡将几乎立即发生，消费者将开始从新主题中消费。

例如，要订阅所有测试主题，我们可以致电

consumer.subscribe(Pattern.compile("test.*"));

会有很多聊天室。 Kafka有大量主题是不好的还是可以的？

没关系：我可以在kafka群集中有100万个主题吗？