第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問題,去搜搜看,總會(huì)有你想問的

kafka AdminClient API超時(shí),等待節(jié)點(diǎn)分配

kafka AdminClient API超時(shí),等待節(jié)點(diǎn)分配

BIG陽(yáng) 2021-05-13 18:19:27
我是Kafka的新手,正在嘗試使用AdminClientAPI管理在我的本地計(jì)算機(jī)上運(yùn)行的Kafka服務(wù)器。我將其設(shè)置與Kafka文檔的“快速入門”部分完全相同。唯一的區(qū)別是我還沒有創(chuàng)建任何主題。在此設(shè)置上運(yùn)行任何外殼程序腳本都沒有問題,但是當(dāng)我嘗試運(yùn)行以下Java代碼時(shí):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();            }        }    }}錯(cuò)誤: TimeoutException: Timed out waiting for a node assignmentException 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)    <br>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)<br>Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.我已經(jīng)在網(wǎng)上搜索了有關(guān)可能是什么問題的指示,但到目前為止沒有發(fā)現(xiàn)任何問題。任何建議都值得歡迎,因?yàn)槲乙呀?jīng)走到盡頭了。
查看完整描述

2 回答

?
函數(shù)式編程

TA貢獻(xiàn)1807條經(jīng)驗(yàn) 獲得超9個(gè)贊

聽起來您的經(jīng)紀(jì)人不健康...


該代碼可以正常工作


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);

        }

    }

}

而且我可以在代理日志中看到該主題已創(chuàng)建


查看完整回答
反對(duì) 回復(fù) 2021-05-26
?
桃花長(zhǎng)相依

TA貢獻(xiàn)1860條經(jīng)驗(yàn) 獲得超8個(gè)贊

我用bitnami / kafka啟動(dòng)了kafka服務(wù),并得到了完全相同的錯(cuò)誤。嘗試通過此版本啟動(dòng)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是主機(jī)的IP地址。


查看完整回答
反對(duì) 回復(fù) 2021-05-26
  • 2 回答
  • 0 關(guān)注
  • 355 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)