Last active
June 8, 2023 13:47
-
-
Save arnaudgeiser/3731ce2f771d356de14dfa798bde9a1a to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ❯ python3 consume.py | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updating subscribed topics to: ('demo-topic2',) | |
| Start consuming | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.cluster:Group coordinator for 2bd555a3-f511-4272-bdb5-259088b46f90 is BrokerMetadata(nodeId='coordinator-3', host='194.182.170.126', port=21701, rack=None) | |
| INFO:kafka.coordinator:Discovered coordinator coordinator-3 for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Starting new heartbeat thread | |
| INFO:kafka.coordinator.consumer:Revoking previously assigned partitions set() for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=coordinator-3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=test-exoscale-08c3c08f-8fb6-4b9c-b7d9-104509cfeb05.aivencloud.com:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. | |
| INFO:kafka.coordinator:(Re-)joining group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Elected group leader -- performing partition assignments using range | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=3)] | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=3)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=5)] | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=5)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=18)] | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=18)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=17)] | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=15)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=12)] | |
| INFO:kafka.coordinator:Successfully joined group 2bd555a3-f511-4272-bdb5-259088b46f90 with generation 1 | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=14)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=8)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=10)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=16)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=2)] | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=17)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=7)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=11)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=4)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=13)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=1)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=0)] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=19)] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=9)] | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=15)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=12)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.consumer.subscription_state:Updated partition assignment: [TopicPartition(topic='demo-topic2', partition=6)] | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=14)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=8)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=10)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=16)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=2)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=7)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=11)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=4)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=13)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=1)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=0)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=19)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=9)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.coordinator.consumer:Setting newly assigned partitions {TopicPartition(topic='demo-topic2', partition=6)} for group 2bd555a3-f511-4272-bdb5-259088b46f90 | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connecting> [IPv4 ('91.92.117.22', 21701)]>: connecting to 91.92.117.22:21701 [('91.92.117.22', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 2 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 3 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <handshake> [IPv4 ('91.92.117.22', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 2 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 2 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| Exception in thread Thread-25: | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| Traceback (most recent call last): | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| WARNING:kafka.client:Node 3 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=1 host=91.92.117.22:21701 <connected> [IPv4 ('91.92.117.22', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| Exception in thread Thread-35: | |
| self.run() | |
| Traceback (most recent call last): | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| WARNING:kafka.client:Node 1 connection failed -- refreshing metadata | |
| self._target(*self._args, **self._kwargs) | |
| self.run() | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| WARNING:kafka.client:Node 2 connection failed -- refreshing metadata | |
| Exception in thread Thread-7: | |
| self._target(*self._args, **self._kwargs) | |
| Traceback (most recent call last): | |
| for consume in consumer: | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| WARNING:kafka.client:Node 1 connection failed -- refreshing metadata | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| Exception in thread Thread-23: | |
| self.run() | |
| Traceback (most recent call last): | |
| for consume in consumer: | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| return self.next_v2() | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| self.run() | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| return self.next_v2() | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| return next(self._iterator) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| Exception in thread Thread-19: | |
| self._target(*self._args, **self._kwargs) | |
| self._target(*self._args, **self._kwargs) | |
| Traceback (most recent call last): | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| WARNING:kafka.client:Node 1 connection failed -- refreshing metadata | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| return next(self._iterator) | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| WARNING:kafka.client:Node 1 connection failed -- refreshing metadata | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| for consume in consumer: | |
| Exception in thread Thread-13: | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| Traceback (most recent call last): | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| for consume in consumer: | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| self.run() | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| self.run() | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| Exception in thread Thread-27: | |
| return self.next_v2() | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| Traceback (most recent call last): | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| self._target(*self._args, **self._kwargs) | |
| return self.next_v2() | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| self._fetcher.update_fetch_positions(partitions) | |
| WARNING:kafka.client:Node 1 connection failed -- refreshing metadata | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| return next(self._iterator) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| self._target(*self._args, **self._kwargs) | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| self.run() | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| self._reset_offset(tp) | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| Exception in thread Thread-11: | |
| return next(self._iterator) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| self._target(*self._args, **self._kwargs) | |
| Traceback (most recent call last): | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| for consume in consumer: | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| for consume in consumer: | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| for consume in consumer: | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| self.run() | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| self._fetcher.update_fetch_positions(partitions) | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| return self.next_v2() | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| return self.next_v2() | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| return self.next_v2() | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| self._reset_offset(tp) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| return next(self._iterator) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| self._target(*self._args, **self._kwargs) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| return next(self._iterator) | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| self._fetcher.update_fetch_positions(partitions) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| return next(self._iterator) | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| self._poll(timeout / 1000) | |
| self._reset_offset(tp) | |
| for consume in consumer: | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| self._register_send_sockets() | |
| self._poll(timeout / 1000) | |
| return self.next_v2() | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| return next(self._iterator) | |
| key = self._selector.get_key(conn._sock) | |
| self._register_send_sockets() | |
| self._fetcher.update_fetch_positions(partitions) | |
| self._fetcher.update_fetch_positions(partitions) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| return mapping[fileobj] | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| self._reset_offset(tp) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| self._poll(timeout / 1000) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| key = self._selector.get_key(conn._sock) | |
| self._fetcher.update_fetch_positions(partitions) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| self._reset_offset(tp) | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| return mapping[fileobj] | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| self._reset_offset(tp) | |
| self._register_send_sockets() | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| self._fetcher.update_fetch_positions(partitions) | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| return _fileobj_to_fd(fileobj) | |
| key = self._selector.get_key(conn._sock) | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| self._reset_offset(tp) | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| return mapping[fileobj] | |
| return _fileobj_to_fd(fileobj) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| self._poll(timeout / 1000) | |
| self._poll(timeout / 1000) | |
| raise ValueError("Invalid file object: " | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| raise ValueError("Invalid file object: " | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| ValueError: Invalid file object: None | |
| ValueError: Invalid file object: None | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| self._register_send_sockets() | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| return _fileobj_to_fd(fileobj) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| key = self._selector.get_key(conn._sock) | |
| self._register_send_sockets() | |
| self._fetcher.update_fetch_positions(partitions) | |
| raise ValueError("Invalid file object: " | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| ValueError: Invalid file object: None | |
| self._poll(timeout / 1000) | |
| return mapping[fileobj] | |
| self._reset_offset(tp) | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| self._poll(timeout / 1000) | |
| key = self._selector.get_key(conn._sock) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| self._register_send_sockets() | |
| self._register_send_sockets() | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| return _fileobj_to_fd(fileobj) | |
| return mapping[fileobj] | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| key = self._selector.get_key(conn._sock) | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| key = self._selector.get_key(conn._sock) | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| return mapping[fileobj] | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| raise ValueError("Invalid file object: " | |
| return mapping[fileobj] | |
| return _fileobj_to_fd(fileobj) | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| self._poll(timeout / 1000) | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| ValueError: Invalid file object: None | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| return _fileobj_to_fd(fileobj) | |
| raise ValueError("Invalid file object: " | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| ValueError: Invalid file object: None | |
| self._register_send_sockets() | |
| raise ValueError("Invalid file object: " | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| key = self._selector.get_key(conn._sock) | |
| return _fileobj_to_fd(fileobj) | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| ValueError: Invalid file object: None | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| return mapping[fileobj] | |
| raise ValueError("Invalid file object: " | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| ValueError: Invalid file object: None | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| return _fileobj_to_fd(fileobj) | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| raise ValueError("Invalid file object: " | |
| ValueError: Invalid file object: None | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 3 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL CA from /home/arnaudgeiser/ca.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Cert from /home/arnaudgeiser/test-kafka_cert.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Loading SSL Key from /home/arnaudgeiser/test-kafka_key.pem | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 2 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 3 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 3 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 2 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connecting> [IPv4 ('91.92.117.222', 21701)]>: connecting to 91.92.117.222:21701 [('91.92.117.222', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connected> [IPv4 ('194.182.170.126', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 3 connection failed -- refreshing metadata | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <connecting> [IPv4 ('194.182.170.126', 21701)]>: connecting to 194.182.170.126:21701 [('194.182.170.126', 21701) IPv4] | |
| INFO:kafka.conn:<BrokerConnection node_id=3 host=194.182.170.126:21701 <handshake> [IPv4 ('194.182.170.126', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <handshake> [IPv4 ('91.92.117.222', 21701)]>: Connection complete. | |
| INFO:kafka.conn:<BrokerConnection node_id=2 host=91.92.117.222:21701 <connected> [IPv4 ('91.92.117.222', 21701)]>: Closing connection. KafkaConnectionError: Socket EVENT_READ without in-flight-requests | |
| WARNING:kafka.client:Node 2 connection failed -- refreshing metadata | |
| Exception in thread Thread-9: | |
| Traceback (most recent call last): | |
| File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner | |
| self.run() | |
| File "/usr/lib/python3.9/threading.py", line 910, in run | |
| self._target(*self._args, **self._kwargs) | |
| File "/home/arnaudgeiser/Downloads/kafka-problem/kafka-problem/consume.py", line 38, in consume | |
| for consume in consumer: | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1192, in __next__ | |
| return self.next_v2() | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1200, in next_v2 | |
| return next(self._iterator) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1115, in _message_generator_v2 | |
| record_map = self.poll(timeout_ms=timeout_ms, update_offsets=False) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 654, in poll | |
| records = self._poll_once(remaining, max_records, update_offsets=update_offsets) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 679, in _poll_once | |
| self._update_fetch_positions(self._subscription.missing_fetch_positions()) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/group.py", line 1111, in _update_fetch_positions | |
| self._fetcher.update_fetch_positions(partitions) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 186, in update_fetch_positions | |
| self._reset_offset(tp) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 237, in _reset_offset | |
| offsets = self._retrieve_offsets({partition: timestamp}) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 277, in _retrieve_offsets | |
| self._client.poll(future=future, timeout_ms=remaining_ms) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 600, in poll | |
| self._poll(timeout / 1000) | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 629, in _poll | |
| self._register_send_sockets() | |
| File "/home/arnaudgeiser/.local/lib/python3.9/site-packages/kafka/client_async.py", line 617, in _register_send_sockets | |
| key = self._selector.get_key(conn._sock) | |
| File "/usr/lib/python3.9/selectors.py", line 191, in get_key | |
| return mapping[fileobj] | |
| File "/usr/lib/python3.9/selectors.py", line 72, in __getitem__ | |
| fd = self._selector._fileobj_lookup(fileobj) | |
| File "/usr/lib/python3.9/selectors.py", line 226, in _fileobj_lookup | |
| return _fileobj_to_fd(fileobj) | |
| File "/usr/lib/python3.9/selectors.py", line 39, in _fileobj_to_fd | |
| raise ValueError("Invalid file object: " | |
| ValueError: Invalid file object: None | |
| INFO:kafka.coordinator:Stopping heartbeat thread | |
| Thread-31 ConsumerRecord(topic='demo-topic2', partition=18, offset=879, timestamp=1686232031110, timestamp_type=0, key=None, value=b'test 1143', headers=[], checksum=None, serialized_key_size=-1, serialized_value_size=9, serialized_header_size=-1) | |
| Thread-33 ConsumerRecord(topic='demo-topic2', partition=5, offset=933, timestamp=1686232033113, timestamp_type=0, key=None, value=b'test 1145', headers=[], checksum=None, serialized_key_size=-1, serialized_value_size=9, serialized_header_size=-1) | |
| Thread-33 ConsumerRecord(topic='demo-topic2', partition=5, offset=934, timestamp=1686232034114, timestamp_type=0, key=None, value=b'test 1146', headers=[], checksum=None, serialized_key_size=-1, serialized_value_size=9, serialized_header_size=-1) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment