java - 使用java api创建Kafka主题,无需zookeeper

标签 java apache-kafka

如何使用java为kafka 0.10.1.x创建没有zookeeper依赖的kafka主题? 我见过创建主题的线程,但它使用了zookeeper、zk客户端等。我只想使用java来完成它,没有scala依赖,因为kafka 0.10已经不使用zookeeper。

最佳答案

是的,可以在不连接到 ZooKeeper 的情况下创建 Kafka 主题。

虽然此功能在 Kafka 0.10.1 的代理中可用,但 AdminClient(使用代理功能的客户端代码)仅在 Kafka 0.11 中添加。

参见KafkaAdminClient.createTopics():http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/admin/KafkaAdminClient.html#createTopics-java.util.Collection-org.apache.kafka.clients.admin.CreateTopicsOptions-

关于java - 使用java api创建Kafka主题,无需zookeeper,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47750306/

相关文章:

仅使用实用程序包的 Java 获取日期

java - Hive UDF - Java 字符串转换异常

java - Spring Redis Cache中如何序列化多种类型?

java - 用于显示错误消息的基于拉取的队列

apache-kafka - SQS 和 Kafka 是一样的吗?

java - Hibernate - 避免 LazyInitializationException - 从代理和 session 中分离对象

java - 避免 Spring ApplicationContext 实例化

apache-kafka - Kafka Consumer:找不到连接条目

spring - 微服务同步通信——服务到服务或消息代理

java - 简单的 Kafka 消费者示例无法通过 java api 工作