junrao commented on PR #19964:
URL: https://github.com/apache/kafka/pull/19964#issuecomment-3032800027
@OmniaGM : Thanks for the updated PR. I ran the new test until failure.
After 10 minutes, I still saw the timeout.
```
java.util.concurrent.TimeoutException: testSendWhileTopicGetRecreated()
timed out after 120 seconds
at java.base/java.util.Optional.ifPresent(Optional.java:178)
at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1708)
at
java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:762)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-6089077873146292020/broker_0_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-6089077873146292020/broker_1_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-6089077873146292020/controller_3000
with metadata.version 4.2-IV1.
[2025-07-03 08:32:04,927] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:05,103] WARN [Producer clientId=producer-2] The metadata
response from the cluster reported a recoverable issue with correlation id 1 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:05,214] WARN [Producer clientId=producer-2] The metadata
response from the cluster reported a recoverable issue with correlation id 7 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:05,438] WARN [Producer clientId=producer-2] The metadata
response from the cluster reported a recoverable issue with correlation id 9 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:06,165] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-6608140775505501629/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-6608140775505501629/broker_1_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-6608140775505501629/broker_0_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:06,290] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:06,450] WARN [Producer clientId=producer-3] The metadata
response from the cluster reported a recoverable issue with correlation id 1 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:06,558] WARN [Producer clientId=producer-3] The metadata
response from the cluster reported a recoverable issue with correlation id 7 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:07,360] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-1689995402898229137/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-1689995402898229137/broker_1_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-1689995402898229137/broker_0_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:07,468] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:07,628] WARN [Producer clientId=producer-4] The metadata
response from the cluster reported a recoverable issue with correlation id 1 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:07,733] WARN [Producer clientId=producer-4] The metadata
response from the cluster reported a recoverable issue with correlation id 7 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:07,956] WARN [Producer clientId=producer-4] The metadata
response from the cluster reported a recoverable issue with correlation id 8 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:08,770] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-17048505300526058547/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-17048505300526058547/broker_1_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-17048505300526058547/broker_0_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:08,880] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:09,145] WARN [Producer clientId=producer-5] The metadata
response from the cluster reported a recoverable issue with correlation id 2 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:09,272] WARN [Producer clientId=producer-5] Got error
produce response with correlation id 8 on topic-partition topic-0, retrying
(2147483646 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION
(org.apache.kafka.clients.producer.internals.Sender:680)
[2025-07-03 08:32:09,273] WARN [Producer clientId=producer-5] Received
unknown topic or partition error in produce request on partition topic-0. The
topic-partition may not exist or the user may not have Describe access to it
(org.apache.kafka.clients.producer.internals.Sender:702)
[2025-07-03 08:32:09,365] WARN [Producer clientId=producer-5] The metadata
response from the cluster reported a recoverable issue with correlation id 9 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:09,484] WARN [Producer clientId=producer-5] The metadata
response from the cluster reported a recoverable issue with correlation id 10 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:10,164] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-12586289379138957056/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-12586289379138957056/broker_0_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-12586289379138957056/broker_1_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:10,281] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:10,440] WARN [Producer clientId=producer-6] The metadata
response from the cluster reported a recoverable issue with correlation id 2 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:10,545] WARN [Producer clientId=producer-6] The metadata
response from the cluster reported a recoverable issue with correlation id 8 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:10,782] WARN [Producer clientId=producer-6] The metadata
response from the cluster reported a recoverable issue with correlation id 9 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:11,569] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-2477307315647262884/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-2477307315647262884/broker_0_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-2477307315647262884/broker_1_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:11,712] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:11,857] WARN [Producer clientId=producer-7] The metadata
response from the cluster reported a recoverable issue with correlation id 2 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:12,066] WARN [Producer clientId=producer-7] The metadata
response from the cluster reported a recoverable issue with correlation id 7 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:12,760] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-14757478012604431632/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-14757478012604431632/broker_0_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-14757478012604431632/broker_1_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:12,860] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:13,007] WARN [Producer clientId=producer-8] The metadata
response from the cluster reported a recoverable issue with correlation id 1 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:13,217] WARN [Producer clientId=producer-8] Got error
produce response with correlation id 9 on topic-partition topic-1, retrying
(2147483646 attempts left). Error: UNKNOWN_TOPIC_ID
(org.apache.kafka.clients.producer.internals.Sender:680)
[2025-07-03 08:32:13,217] WARN [Producer clientId=producer-8] Received
invalid metadata error in produce request on partition topic-1 due to
org.apache.kafka.common.errors.UnknownTopicIdException: This server does not
host this topic ID. Going to request metadata update now
(org.apache.kafka.clients.producer.internals.Sender:706)
[2025-07-03 08:32:13,331] WARN [Producer clientId=producer-8] Got error
produce response with correlation id 12 on topic-partition topic-1, retrying
(2147483645 attempts left). Error: UNKNOWN_TOPIC_ID
(org.apache.kafka.clients.producer.internals.Sender:680)
[2025-07-03 08:32:13,331] WARN [Producer clientId=producer-8] Received
invalid metadata error in produce request on partition topic-1 due to
org.apache.kafka.common.errors.UnknownTopicIdException: This server does not
host this topic ID. Going to request metadata update now
(org.apache.kafka.clients.producer.internals.Sender:706)
[2025-07-03 08:32:13,332] WARN [Producer clientId=producer-8] The metadata
response from the cluster reported a recoverable issue with correlation id 13 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:13,551] WARN [Producer clientId=producer-8] Got error
produce response with correlation id 15 on topic-partition topic-1, retrying
(2147483644 attempts left). Error: UNKNOWN_TOPIC_ID
(org.apache.kafka.clients.producer.internals.Sender:680)
[2025-07-03 08:32:13,551] WARN [Producer clientId=producer-8] Received
invalid metadata error in produce request on partition topic-1 due to
org.apache.kafka.common.errors.UnknownTopicIdException: This server does not
host this topic ID. Going to request metadata update now
(org.apache.kafka.clients.producer.internals.Sender:706)
[2025-07-03 08:32:14,376] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-321361512033974143/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-321361512033974143/broker_0_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-321361512033974143/broker_1_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:14,462] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:14,620] WARN [Producer clientId=producer-9] The metadata
response from the cluster reported a recoverable issue with correlation id 1 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:14,726] WARN [Producer clientId=producer-9] The metadata
response from the cluster reported a recoverable issue with correlation id 7 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:14,965] WARN [Producer clientId=producer-9] The metadata
response from the cluster reported a recoverable issue with correlation id 9 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:15,774] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-543793708133122389/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-543793708133122389/broker_0_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-543793708133122389/broker_1_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:15,883] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:16,033] WARN [Producer clientId=producer-10] The metadata
response from the cluster reported a recoverable issue with correlation id 1 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:16,241] WARN [Producer clientId=producer-10] The metadata
response from the cluster reported a recoverable issue with correlation id 7 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:16,472] WARN [Producer clientId=producer-10] The metadata
response from the cluster reported a recoverable issue with correlation id 9 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:17,360] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-18238593010590373133/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-18238593010590373133/broker_1_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-18238593010590373133/broker_0_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:17,454] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:17,634] WARN [Producer clientId=producer-11] The metadata
response from the cluster reported a recoverable issue with correlation id 2 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:17,739] WARN [Producer clientId=producer-11] The metadata
response from the cluster reported a recoverable issue with correlation id 7 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:18,369] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-1007440053127284728/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-1007440053127284728/broker_0_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-1007440053127284728/broker_1_data0
with metadata.version 4.2-IV1.
[2025-07-03 08:32:18,459] WARN [QuorumController id=3000] Performing
controller activation. The metadata log appears to be empty. Appending 6
bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
[2025-07-03 08:32:18,636] WARN [Producer clientId=producer-12] The metadata
response from the cluster reported a recoverable issue with correlation id 1 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:18,845] WARN [Producer clientId=producer-12] The metadata
response from the cluster reported a recoverable issue with correlation id 8 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:19,035] WARN [Producer clientId=producer-12] The metadata
response from the cluster reported a recoverable issue with correlation id 10 :
{topic=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient:1295)
[2025-07-03 08:32:19,997] WARN [NodeToControllerChannelManager id=3000
name=registration] Attempting to close NetworkClient that has already been
closed. (org.apache.kafka.clients.NetworkClient:744)
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-11984181535268137544/broker_0_data0
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-11984181535268137544/controller_3000
with metadata.version 4.2-IV1.
Formatting metadata directory
/var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-11984181535268137544/broker_1_data0
with metadata.version 4.2-IV1.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
