在Apache Kafka中,有许多关于如何命名主题和如何结构化主题消息的最佳实践。以下是几个常见的实践:
以下是一个例子,展示了如何在Kafka中创建一个名为“orders”的主题:
public class KafkaTopicCreator {
private static final String BOOTSTRAP_SERVERS = "localhost:9092";
public static void createTopic(String topicName) throws Exception {
AdminClient adminClient = AdminClient.create(createConfig());
NewTopic newTopic = new NewTopic(topicName, 1, (short) 1);
adminClient.createTopics(Collections.singleton(newTopic)).all().get();
adminClient.close();
}
private static Properties createConfig() {
Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS);
return props;
}
}
在这个例子中,我们使用了Apache Kafka 2.5版本的API。在这个例子中,我们创建了一个