Timeout on executing kafka-topics

Ops
1

Sorry for spamming threads, but those are all different topics (maybe with a similar root cause) and I thought it better to split those up so they can get tracked easier

Basically this thread is about getting a timeout when trying to run kafka-topics list (as a first test to see if connectivity is working).

 ./kafka-topics  --bootstrap-server localhost:9094 --list
Error while executing topic command : Timed out waiting for a node assignment. Call: listTopics
[2025-02-07 08:48:39,707] ERROR org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: listTopics
 (org.apache.kafka.tools.TopicCommand)
[appuser@kafka-3 bin]$ ./kafka-topics  --bootstrap-server localhost:9094 --version
7.8.0-ccs

Connectivity seems to be ok since the version command is fine, there is nothing in the logs (at loglevel Warn), but we do have issues with the cluster where we get a lot of timeouts for reasons we’re trying to identify…

2

the version command does not connect to the cluster at all

you could try with:
kafka-topics --version

probably the same as in your other one

correct broker port chosen?

best,
michael

3

Hi,
yes these attempts connect to broker, I use the same Plaintext port 9094 here…

./kafka-topics --bootstrap-server server1:9094,server2:9094,server3:9094 --list
Error while executing topic command : Timed out waiting for a node assignment. Call: listTopics
[2025-02-07 14:47:21,504] ERROR org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: listTopics
(org.apache.kafka.tools.TopicCommand)

podman run -d  --restart always \
    --name $KAFKA_INSTANCE \
    -h=server1 \
    -p 2281:2281 \
    -p 9093:9093 \
    -p 9094:9094 \
    -p 9095:9095 \
    -e KAFKA_NODE_ID=4 \
    -e KAFKA_PROCESS_ROLES='broker' \
    -e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP='SSL:SSL,CONTROLLER:SSL,SSLINTERNAL:SSL, PLAIN:PLAINTEXT' \
    -e KAFKA_LISTENERS='SSLINTERNAL://:9093,SSL://:9095,PLAIN://:9094' \
    -e KAFKA_CONTROLLER_QUORUM_VOTERS='1@server1:9092,2@server2:9092,3@server3:9092' \
    -e KAFKA_INTER_BROKER_LISTENER_NAME='SSLINTERNAL' \
    -e KAFKA_SECURITY_PROTOCOL='SSL' \
    -e KAFKA_ADVERTISED_LISTENERS='SSLINTERNAL://server1:9093,SSL://:9095' \
    -e KAFKA_CONTROLLER_LISTENER_NAMES='CONTROLLER' \
4

One issue is that port 9094 isn’t in KAFKA_ADVERTISED_LISTENERS – try adding PLAIN://server1:9094.

5

Man, I feel stupid now.
That is so basic that even I could have seen that :disappointed_relieved:

6

This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.