You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Gert van Dijk (JIRA)" <ji...@apache.org> on 2019/02/12 20:21:00 UTC
[jira] [Created] (KAFKA-7924) Kafka broker does not list nodes
first ~ 30s after startup
Gert van Dijk created KAFKA-7924:
------------------------------------
Summary: Kafka broker does not list nodes first ~ 30s after startup
Key: KAFKA-7924
URL: https://issues.apache.org/jira/browse/KAFKA-7924
Project: Kafka
Issue Type: Bug
Affects Versions: 2.1.0
Environment: Clean Docker environment, very simple everything single node.
Reporter: Gert van Dijk
Steps to reproduce:
# Start single Zookeeper instance.
# Start single Kafka instance.
# Validate that the line {noformat}INFO [KafkaServer id=0] started (kafka.server.KafkaServer){noformat} is printed.
# Connect using a Kafka client +with debug logging enabled+, right after seeing that line, _do not wait_.
# Observe that it is connected to the Kafka broker just fine, but that the broker lists an empty lists of nodes: {noformat}Updating cluster metadata to Cluster(id = xxx, nodes = [], [...]{noformat}
# Keep watching for about 30 seconds, seeing that log entry popping up hundreds of times. Nothing happens in Kafka/Zookeeper logs in the meantime, but then suddenly the Kafka server start reporting nodes to the connected client: {noformat}[...] nodes = [kafka:9092 (id: 0 rack: null)], [...]
o.apache.kafka.clients.NetworkClient - [AdminClient clientId=adminclient-1] Initiating connection to node [...]{noformat} and it connects all fine.
My expectation is that it should list itself rightaway after listening on the network as a broker. It should not take ~ 30 seconds for a Kafka client to be blocked waiting and timing out first.
Use case: I'm trying to create topics in a CI/CD pipeline and spinning up a clean Kafka for that. Right after it's started, it should be possible to create topics using an AdminClient, but currently experiencing {{TimeoutException: Timed out waiting for a node assignment}} errors unless I put a {{sleep 30}} between observing a Kafka reportedly ready and starting the topic creation process. Not very ideal.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)