Kafka トピックをすばやく作成する手順
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.1.0</version> </dependency>
import org.apache.kafka.clients.admin.AdminClient; import org.apache.kafka.clients.admin.NewTopic; import java.util.Collections; import java.util.Properties; public class CreateTopic { public static void main(String[] args) { // 创建Properties对象,并设置Kafka集群的地址 Properties properties = new Properties(); properties.put("bootstrap.servers", "localhost:9092"); // 创建AdminClient对象 AdminClient adminClient = AdminClient.create(properties); // 创建NewTopic对象,并设置主题名称和分区数 NewTopic newTopic = new NewTopic("my-topic", 3); // 创建主题 adminClient.createTopics(Collections.singletonList(newTopic)); // 关闭AdminClient对象 adminClient.close(); } }
mvn exec:java
kafka-topics --list --zookeeper localhost:2181
my-topic
topic は、トピックが正常に作成されたことを意味します。
注
以上がKafka トピックを簡単に作成する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。