2022-11-25 18:11:18.378 INFO [140416141425664] ClientConnection:189 | [ -> pulsar://localhost:6650] Create ClientConnection, timeout=10000 2022-11-25 18:11:18.378 INFO [140416141425664] ConnectionPool:97 | Created connection for pulsar://localhost:6650 2022-11-25 18:11:18.380 INFO [140416141379328] ClientConnection:379 | [127.0.0.1:37786 -> 127.0.0.1:6650] Connected to broker 2022-11-25 18:11:18.384 INFO [140416141379328] HandlerBase:72 | [persistent://public/default/test-partition-0, ] Getting connection from pool 2022-11-25 18:11:18.384 INFO [140416141379328] HandlerBase:72 | [persistent://public/default/test-partition-1, ] Getting connection from pool 2022-11-25 18:11:18.395 WARN [140416141379328] ClientConnection:1096 | [127.0.0.1:37786 -> 127.0.0.1:6650] Received error response from server: ProducerBusy (org.apache.pulsar.broker.service.BrokerServiceException$ProducerBusyException: Topic reached max producers limit) -- req_id: 0 2022-11-25 18:11:18.395 ERROR [140416141379328] ProducerImpl:266 | [persistent://public/default/test-partition-0, ] Failed to create producer: ProducerBusy 2022-11-25 18:11:18.395 ERROR [140416141379328] PartitionedProducerImpl:160 | Unable to create Producer for partition - 0 Error - ProducerBusy 2022-11-25 18:11:18.396 INFO [140416141379328] ProducerImpl:190 | [persistent://public/default/test-partition-1, ] Created producer on broker [127.0.0.1:37786 -> 127.0.0.1:6650] 2022-11-25 18:11:18.396 ERROR [140416141379328] ProducerImpl:690 | [persistent://public/default/test-partition-0, ] Failed to close producer: AlreadyClosed 2022-11-25 18:11:18.396 ERROR [140416141379328] PartitionedProducerImpl:317 | Closing the producer failed for partition - 0 2022-11-25 18:11:18.396 INFO [140416141379328] ProducerImpl:721 | [persistent://public/default/test-partition-1, standalone-0-385] Closing producer for topic persistent://public/default/test-partition-1 2022-11-25 18:11:18.397 INFO [140416141379328] ProducerImpl:687 | [persistent://public/default/test-partition-1, standalone-0-385] Closed producer 1 2022-11-25 18:11:18.397 INFO [140416141379328] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-0, ] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-0] [numberOfBatchesSent_ = 2] [averageBatchSize_ = 0] }] 2022-11-25 18:11:18.397 INFO [140416141379328] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-1, standalone-0-385] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-1] [numberOfBatchesSent_ = 1] [averageBatchSize_ = 0] }] 2022-11-25 18:11:19.398 INFO [140416141379328] HandlerBase:72 | [persistent://public/default/test-partition-0, ] Getting connection from pool 2022-11-25 18:11:19.398 INFO [140416141379328] HandlerBase:72 | [persistent://public/default/test-partition-1, ] Getting connection from pool 2022-11-25 18:11:19.402 INFO [140416141379328] ProducerImpl:190 | [persistent://public/default/test-partition-1, ] Created producer on broker [127.0.0.1:37786 -> 127.0.0.1:6650] 2022-11-25 18:11:19.409 WARN [140416141379328] ClientConnection:1096 | [127.0.0.1:37786 -> 127.0.0.1:6650] Received error response from server: ProducerBusy (org.apache.pulsar.broker.service.BrokerServiceException$ProducerBusyException: Topic reached max producers limit) -- req_id: 3 2022-11-25 18:11:19.409 ERROR [140416141379328] ProducerImpl:266 | [persistent://public/default/test-partition-0, ] Failed to create producer: ProducerBusy 2022-11-25 18:11:19.409 ERROR [140416141379328] PartitionedProducerImpl:160 | Unable to create Producer for partition - 0 Error - ProducerBusy 2022-11-25 18:11:19.410 INFO [140416141379328] ProducerImpl:721 | [persistent://public/default/test-partition-0, ] Closing producer for topic persistent://public/default/test-partition-0 2022-11-25 18:11:19.410 INFO [140416141379328] ProducerImpl:687 | [persistent://public/default/test-partition-0, ] Closed producer 2 2022-11-25 18:11:19.410 INFO [140416141379328] ProducerImpl:721 | [persistent://public/default/test-partition-1, standalone-0-387] Closing producer for topic persistent://public/default/test-partition-1 2022-11-25 18:11:19.410 INFO [140416141379328] ProducerImpl:687 | [persistent://public/default/test-partition-1, standalone-0-387] Closed producer 3 2022-11-25 18:11:19.410 INFO [140416141379328] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-0, ] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-0] [numberOfBatchesSent_ = 2] [averageBatchSize_ = 0] }] 2022-11-25 18:11:19.410 INFO [140416141379328] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-1, standalone-0-387] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-1] [numberOfBatchesSent_ = 1] [averageBatchSize_ = 0] }] 2022-11-25 18:11:20.412 INFO [140416141379328] HandlerBase:72 | [persistent://public/default/test-partition-0, ] Getting connection from pool 2022-11-25 18:11:20.412 INFO [140416141379328] HandlerBase:72 | [persistent://public/default/test-partition-1, ] Getting connection from pool 2022-11-25 18:11:20.416 INFO [140416141379328] ProducerImpl:190 | [persistent://public/default/test-partition-1, ] Created producer on broker [127.0.0.1:37786 -> 127.0.0.1:6650] 2022-11-25 18:11:20.424 WARN [140416141379328] ClientConnection:1096 | [127.0.0.1:37786 -> 127.0.0.1:6650] Received error response from server: ProducerBusy (org.apache.pulsar.broker.service.BrokerServiceException$ProducerBusyException: Topic reached max producers limit) -- req_id: 6 2022-11-25 18:11:20.424 ERROR [140416141379328] ProducerImpl:266 | [persistent://public/default/test-partition-0, ] Failed to create producer: ProducerBusy 2022-11-25 18:11:20.424 ERROR [140416141379328] PartitionedProducerImpl:160 | Unable to create Producer for partition - 0 Error - ProducerBusy 2022-11-25 18:11:20.424 INFO [140416141379328] ProducerImpl:721 | [persistent://public/default/test-partition-0, ] Closing producer for topic persistent://public/default/test-partition-0 2022-11-25 18:11:20.424 INFO [140416141379328] ProducerImpl:687 | [persistent://public/default/test-partition-0, ] Closed producer 4 2022-11-25 18:11:20.424 INFO [140416141379328] ProducerImpl:721 | [persistent://public/default/test-partition-1, standalone-0-389] Closing producer for topic persistent://public/default/test-partition-1 2022-11-25 18:11:20.425 INFO [140416141379328] ProducerImpl:687 | [persistent://public/default/test-partition-1, standalone-0-389] Closed producer 5 2022-11-25 18:11:20.426 INFO [140416141379328] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-0, ] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-0] [numberOfBatchesSent_ = 2] [averageBatchSize_ = 0] }] 2022-11-25 18:11:20.426 INFO [140416141379328] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-1, standalone-0-389] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-1] [numberOfBatchesSent_ = 1] [averageBatchSize_ = 0] }] 2022-11-25 18:11:21.427 INFO [140416141379328] HandlerBase:72 | [persistent://public/default/test-partition-0, ] Getting connection from pool 2022-11-25 18:11:21.427 INFO [140416141379328] HandlerBase:72 | [persistent://public/default/test-partition-1, ] Getting connection from pool 2022-11-25 18:11:21.432 INFO [140416141379328] ProducerImpl:190 | [persistent://public/default/test-partition-1, ] Created producer on broker [127.0.0.1:37786 -> 127.0.0.1:6650] 2022-11-25 18:11:21.439 WARN [140416141379328] ClientConnection:1096 | [127.0.0.1:37786 -> 127.0.0.1:6650] Received error response from server: ProducerBusy (org.apache.pulsar.broker.service.BrokerServiceException$ProducerBusyException: Topic reached max producers limit) -- req_id: 9 2022-11-25 18:11:21.439 ERROR [140416141379328] ProducerImpl:266 | [persistent://public/default/test-partition-0, ] Failed to create producer: ProducerBusy 2022-11-25 18:11:21.439 ERROR [140416141379328] PartitionedProducerImpl:160 | Unable to create Producer for partition - 0 Error - ProducerBusy 2022-11-25 18:11:21.439 INFO [140416141379328] ProducerImpl:721 | [persistent://public/default/test-partition-0, ] Closing producer for topic persistent://public/default/test-partition-0 2022-11-25 18:11:21.439 INFO [140416141379328] ProducerImpl:687 | [persistent://public/default/test-partition-0, ] Closed producer 6 2022-11-25 18:11:21.439 INFO [140416141379328] ProducerImpl:721 | [persistent://public/default/test-partition-1, standalone-0-391] Closing producer for topic persistent://public/default/test-partition-1 2022-11-25 18:11:21.440 INFO [140416141379328] ProducerImpl:687 | [persistent://public/default/test-partition-1, standalone-0-391] Closed producer 7 2022-11-25 18:11:21.440 INFO [140416141379328] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-0, ] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-0] [numberOfBatchesSent_ = 2] [averageBatchSize_ = 0] }] 2022-11-25 18:11:21.440 INFO [140416141379328] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-1, standalone-0-391] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-1] [numberOfBatchesSent_ = 1] [averageBatchSize_ = 0] }]