kafka adminclient api在等待节点分配时超时

mzsu5hc0 于 2021-06-08 发布在 Kafka

关注(0)|答案(2)|浏览(1334)

我是Kafka的新手，我正在尝试使用 AdminClient api来管理在我的本地机器上运行的kafka服务器。我的设置与Kafka文档的快速入门部分完全相同。唯一的区别是我没有创建任何主题。
在此设置中运行任何shell脚本都没有问题，但是当我尝试运行以下java代码时：

public class ProducerMain{

    public static void main(String[] args) {
        Properties props = new Properties();
        props.setProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, 
            "localhost:9092");

        try(final AdminClient adminClient = 
              KafkaAdminClient.create(props)){

            try {
                final NewTopic newTopic = new NewTopic("test", 1, 
                    (short)1);

                final CreateTopicsResult createTopicsResult = 
                    adminClient.createTopics( 
                         Collections.singleton(newTopic));

                createTopicsResult.all().get();

            }catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }
    }
}

错误： TimeoutException: Timed out waiting for a node assignment ```
Exception in thread "main" java.lang.RuntimeException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
at ProducerMain.main(ProducerMain.java:41)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:258)
at ProducerMain.main(ProducerMain.java:38)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

我在网上搜索了一个关于问题可能是什么的指示，但到目前为止没有找到任何东西。任何建议都欢迎，因为我已经穷途末路了。

Java apache-kafka RuntimeException

来源：https://stackoverflow.com/questions/51325076/kafka-adminclient-api-timed-out-waiting-for-node-assignment

2条答案

按热度按时间

q35jwt9p1#

听起来你的经纪人不健康。。。
这个代码很好用

public class Main {

    static final Logger logger = LoggerFactory.getLogger(Main.class);

    public static void main(String[] args) {
        Properties properties = new Properties();
        properties.setProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        properties.setProperty(AdminClientConfig.CLIENT_ID_CONFIG, "local-test");
        properties.setProperty(AdminClientConfig.RETRIES_CONFIG, "3");

        try (AdminClient client = AdminClient.create(properties)) {
            final CreateTopicsResult res = client.createTopics(
                    Collections.singletonList(
                            new NewTopic("foo", 1, (short) 1)
                    )
            );
            res.all().get(5, TimeUnit.SECONDS);
        } catch (InterruptedException | ExecutionException | TimeoutException e) {
            logger.error("unable to create topic", e);
        }
    }
}

我可以在代理日志中看到这个主题是创建的

赞(0）回复(0）举报 2021-06-08

pzfprimi2#

我用bitnami/kafka启动了kafka服务，得到了完全相同的错误。试着用这个版本来开始Kafka，它起作用了：https://hub.docker.com/r/wurstmeister/kafka

$ docker run -d --name zookeeper-server --network app-tier \
  -e ALLOW_ANONYMOUS_LOGIN=yes  -p 2181:2181 zookeeper:3.6.2

$ docker run -d --name kafka-server --network app-tier --publish 9092:9092 \
  --env KAFKA_ZOOKEEPER_CONNECT=zookeeper-server:2181 \
  --env KAFKA_ADVERTISED_HOST_NAME=30.225.51.235 \
  --env KAFKA_ADVERTISED_PORT=9092  \
  wurstmeister/kafka

30.225.51.235是主机的ip地址。

赞(0）回复(0）举报 2021-06-08

我来回答

kafka adminclient api在等待节点分配时超时

2条答案

相关问题

热门标签

最新问答