快速创建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
主题,则表示主题创建成功。
注意事项
以上是创建Kafka主题的快速方法的详细内容。更多信息请关注PHP中文网其他相关文章!