2022-11-25 18:11:40.461 INFO [139755764534272] ClientConnection:189 | [ -> pulsar://localhost:6650] Create ClientConnection, timeout=10000 2022-11-25 18:11:40.462 INFO [139755764534272] ConnectionPool:97 | Created connection for pulsar://localhost:6650 2022-11-25 18:11:40.464 INFO [139755764487936] ClientConnection:379 | [127.0.0.1:37788 -> 127.0.0.1:6650] Connected to broker 2022-11-25 18:11:40.466 INFO [139755764487936] HandlerBase:72 | [persistent://public/default/test-partition-0, ] Getting connection from pool 2022-11-25 18:11:40.466 INFO [139755764487936] HandlerBase:72 | [persistent://public/default/test-partition-1, ] Getting connection from pool 2022-11-25 18:11:40.471 WARN [139755764487936] ClientConnection:1096 | [127.0.0.1:37788 -> 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:40.471 ERROR [139755764487936] ProducerImpl:266 | [persistent://public/default/test-partition-0, ] Failed to create producer: ProducerBusy 2022-11-25 18:11:40.471 ERROR [139755764487936] PartitionedProducerImpl:160 | Unable to create Producer for partition - 0 Error - ProducerBusy 2022-11-25 18:11:40.471 INFO [139755764487936] ProducerImpl:190 | [persistent://public/default/test-partition-1, ] Created producer on broker [127.0.0.1:37788 -> 127.0.0.1:6650] 2022-11-25 18:11:40.471 INFO [139755764487936] 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_ = 1] [averageBatchSize_ = 0] }] 2022-11-25 18:11:40.471 INFO [139755764487936] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-1, standalone-0-393] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-1] [numberOfBatchesSent_ = 0] [averageBatchSize_ = 0] }] 2022-11-25 18:11:41.474 INFO [139755764487936] HandlerBase:72 | [persistent://public/default/test-partition-0, ] Getting connection from pool 2022-11-25 18:11:41.475 INFO [139755764487936] HandlerBase:72 | [persistent://public/default/test-partition-1, ] Getting connection from pool 2022-11-25 18:11:41.479 WARN [139755764487936] ClientConnection:1096 | [127.0.0.1:37788 -> 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: 2 2022-11-25 18:11:41.480 ERROR [139755764487936] ProducerImpl:266 | [persistent://public/default/test-partition-0, ] Failed to create producer: ProducerBusy 2022-11-25 18:11:41.480 ERROR [139755764487936] PartitionedProducerImpl:160 | Unable to create Producer for partition - 0 Error - ProducerBusy 2022-11-25 18:11:41.480 INFO [139755764487936] ProducerImpl:190 | [persistent://public/default/test-partition-1, ] Created producer on broker [127.0.0.1:37788 -> 127.0.0.1:6650] 2022-11-25 18:11:41.480 INFO [139755764487936] 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_ = 1] [averageBatchSize_ = 0] }] 2022-11-25 18:11:41.480 INFO [139755764487936] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-1, standalone-0-395] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-1] [numberOfBatchesSent_ = 0] [averageBatchSize_ = 0] }] 2022-11-25 18:11:42.490 INFO [139755764487936] HandlerBase:72 | [persistent://public/default/test-partition-0, ] Getting connection from pool 2022-11-25 18:11:42.490 INFO [139755764487936] HandlerBase:72 | [persistent://public/default/test-partition-1, ] Getting connection from pool 2022-11-25 18:11:42.493 WARN [139755764487936] ClientConnection:1096 | [127.0.0.1:37788 -> 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: 4 2022-11-25 18:11:42.493 ERROR [139755764487936] ProducerImpl:266 | [persistent://public/default/test-partition-0, ] Failed to create producer: ProducerBusy 2022-11-25 18:11:42.493 ERROR [139755764487936] PartitionedProducerImpl:160 | Unable to create Producer for partition - 0 Error - ProducerBusy 2022-11-25 18:11:42.493 INFO [139755764487936] ProducerImpl:190 | [persistent://public/default/test-partition-1, ] Created producer on broker [127.0.0.1:37788 -> 127.0.0.1:6650] 2022-11-25 18:11:42.494 INFO [139755764487936] 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_ = 1] [averageBatchSize_ = 0] }] 2022-11-25 18:11:42.494 INFO [139755764487936] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-1, standalone-0-397] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-1] [numberOfBatchesSent_ = 0] [averageBatchSize_ = 0] }] 2022-11-25 18:11:43.495 INFO [139755764487936] HandlerBase:72 | [persistent://public/default/test-partition-0, ] Getting connection from pool 2022-11-25 18:11:43.495 INFO [139755764487936] HandlerBase:72 | [persistent://public/default/test-partition-1, ] Getting connection from pool 2022-11-25 18:11:43.498 WARN [139755764487936] ClientConnection:1096 | [127.0.0.1:37788 -> 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:43.498 ERROR [139755764487936] ProducerImpl:266 | [persistent://public/default/test-partition-0, ] Failed to create producer: ProducerBusy 2022-11-25 18:11:43.498 ERROR [139755764487936] PartitionedProducerImpl:160 | Unable to create Producer for partition - 0 Error - ProducerBusy 2022-11-25 18:11:43.499 INFO [139755764487936] ProducerImpl:190 | [persistent://public/default/test-partition-1, ] Created producer on broker [127.0.0.1:37788 -> 127.0.0.1:6650] 2022-11-25 18:11:43.500 INFO [139755764487936] 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_ = 1] [averageBatchSize_ = 0] }] 2022-11-25 18:11:43.500 INFO [139755764487936] ProducerImpl:677 | Producer - [persistent://public/default/test-partition-1, standalone-0-399] , [batchMessageContainer = { BatchMessageContainer [size = 0] [bytes = 0] [maxSize = 1000] [maxBytes = 131072] [topicName = persistent://public/default/test-partition-1] [numberOfBatchesSent_ = 0] [averageBatchSize_ = 0] }]