[sarama] 2022/02/12 05:06:47 producer/leader/realtime/37 state change to [retrying-1]
[sarama] 2022/02/12 05:06:47 producer/leader/realtime/37 abandoning broker 2
[sarama] 2022/02/12 05:06:47 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:06:47 producer/leader/realtime/37 selected broker 2
[sarama] 2022/02/12 05:06:47 producer/broker/2 state change to [open] on realtime/37
[sarama] 2022/02/12 05:06:47 producer/leader/realtime/37 state change to [flushing-1]
[sarama] 2022/02/12 05:06:47 producer/leader/realtime/37 state change to [normal]
[sarama] 2022/02/12 05:06:47 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:06:47 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 05:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 05:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 05:07:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:07:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:07:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:07:06 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:07:06 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
license:[sarama] 2022/02/12 05:07:29 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:10:19 producer/leader/realtime/24 state change to [retrying-1]
[sarama] 2022/02/12 05:10:19 producer/leader/realtime/24 abandoning broker 1
[sarama] 2022/02/12 05:10:19 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:10:19 producer/leader/realtime/24 selected broker 1
[sarama] 2022/02/12 05:10:19 producer/broker/1 state change to [open] on realtime/24
[sarama] 2022/02/12 05:10:19 producer/leader/realtime/24 state change to [flushing-1]
[sarama] 2022/02/12 05:10:19 producer/leader/realtime/24 state change to [normal]
[sarama] 2022/02/12 05:11:02 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:11:05 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:11:05 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:11:29 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:12:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:12:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:12:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:12:03 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:12:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:12:03 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:12:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:12:04 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:12:04 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:12:24 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:12:24 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:12:24 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:14:35 producer/leader/realtime/47 state change to [retrying-1]
[sarama] 2022/02/12 05:14:35 producer/leader/realtime/47 abandoning broker 3
[sarama] 2022/02/12 05:14:35 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:14:35 producer/leader/realtime/47 selected broker 3
[sarama] 2022/02/12 05:14:35 producer/broker/3 state change to [open] on realtime/47
[sarama] 2022/02/12 05:14:35 producer/leader/realtime/47 state change to [flushing-1]
[sarama] 2022/02/12 05:14:35 producer/leader/realtime/47 state change to [normal]
[sarama] 2022/02/12 05:16:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:16:03 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:16:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:16:27 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 05:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 05:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 05:17:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:17:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:17:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:17:08 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:17:08 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:17:25 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:21:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:21:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:21:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:21:06 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:21:06 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:21:24 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:22:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:22:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:22:02 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:22:05 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:22:05 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:22:22 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:26:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:26:03 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:26:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:26:17 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:26:17 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:26:22 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 05:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 05:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
license:[sarama] 2022/02/12 05:27:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:27:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:27:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:27:04 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:27:04 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:27:17 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:31:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:31:15 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:31:15 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:31:16 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:36:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:36:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:36:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:36:06 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:36:06 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:36:11 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 05:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 05:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 05:37:02 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:37:07 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:37:07 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:37:09 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:41:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:41:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:41:02 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:41:03 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:41:03 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:41:04 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:42:00 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/12 05:42:00 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 state change to [retrying-1]
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 abandoning broker 3
[sarama] 2022/02/12 05:46:29 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 selected broker 3
[sarama] 2022/02/12 05:46:29 producer/broker/3 state change to [open] on realtime/41
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 state change to [flushing-1]
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 state change to [normal]
[sarama] 2022/02/12 05:46:29 producer/broker/3 state change to [closing] because write tcp 10.7.12.20:43544->10.7.12.103:9092: write: broken pipe
[sarama] 2022/02/12 05:46:29 Closed connection to broker 10.7.12.103:9092
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 state change to [retrying-2]
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 abandoning broker 3
[sarama] 2022/02/12 05:46:29 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:46:29 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/12 05:46:29 producer/broker/3 starting up
[sarama] 2022/02/12 05:46:29 producer/broker/3 state change to [open] on realtime/41
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 selected broker 3
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 state change to [flushing-2]
[sarama] 2022/02/12 05:46:29 producer/leader/realtime/41 state change to [normal]
[sarama] 2022/02/12 05:46:29 Connected to broker at 10.7.12.103:9092 (registered as #3)
[sarama] 2022/02/12 05:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 05:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 05:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 state change to [retrying-1]
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 abandoning broker 1
[sarama] 2022/02/12 05:53:34 producer/broker/1 input chan closed
[sarama] 2022/02/12 05:53:34 producer/broker/1 shut down
[sarama] 2022/02/12 05:53:34 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 selected broker 1
[sarama] 2022/02/12 05:53:34 producer/broker/1 state change to [open] on realtime/42
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 state change to [flushing-1]
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 state change to [normal]
[sarama] 2022/02/12 05:53:34 producer/broker/1 state change to [closing] because EOF
[sarama] 2022/02/12 05:53:34 Closed connection to broker 10.7.12.101:9092
[sarama] 2022/02/12 05:53:34 producer/broker/1 state change to [closing] because EOF
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 state change to [retrying-2]
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 abandoning broker 1
[sarama] 2022/02/12 05:53:34 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:53:34 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/12 05:53:34 producer/broker/1 starting up
[sarama] 2022/02/12 05:53:34 producer/broker/1 state change to [open] on realtime/42
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 selected broker 1
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 state change to [flushing-2]
[sarama] 2022/02/12 05:53:34 producer/leader/realtime/42 state change to [normal]
[sarama] 2022/02/12 05:53:34 Connected to broker at 10.7.12.101:9092 (registered as #1)
[sarama] 2022/02/12 05:55:49 producer/leader/realtime/6 state change to [retrying-1]
[sarama] 2022/02/12 05:55:49 producer/leader/realtime/6 abandoning broker 1
[sarama] 2022/02/12 05:55:49 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:55:49 producer/leader/realtime/6 selected broker 1
[sarama] 2022/02/12 05:55:49 producer/broker/1 state change to [open] on realtime/6
[sarama] 2022/02/12 05:55:49 producer/leader/realtime/6 state change to [flushing-1]
[sarama] 2022/02/12 05:55:49 producer/leader/realtime/6 state change to [normal]
[sarama] 2022/02/12 05:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 05:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 05:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 05:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 06:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 06:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 06:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 state change to [retrying-1]
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 abandoning broker 3
[sarama] 2022/02/12 06:09:23 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 selected broker 3
[sarama] 2022/02/12 06:09:23 producer/broker/3 state change to [open] on realtime/2
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 state change to [flushing-1]
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 state change to [normal]
[sarama] 2022/02/12 06:09:23 producer/broker/3 state change to [closing] because write tcp 10.7.12.20:33872->10.7.12.103:9092: write: broken pipe
[sarama] 2022/02/12 06:09:23 Closed connection to broker 10.7.12.103:9092
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 state change to [retrying-2]
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 abandoning broker 3
[sarama] 2022/02/12 06:09:23 producer/broker/3 state change to [closing] because kafka: broker not connected
[sarama] 2022/02/12 06:09:23 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:09:23 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/12 06:09:23 producer/broker/3 starting up
[sarama] 2022/02/12 06:09:23 producer/broker/3 state change to [open] on realtime/2
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 selected broker 3
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 state change to [flushing-2]
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 state change to [normal]
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 state change to [retrying-1]
[sarama] 2022/02/12 06:09:23 producer/leader/realtime/2 abandoning broker 3
[sarama] 2022/02/12 06:09:23 producer/broker/3 input chan closed
[sarama] 2022/02/12 06:09:23 Connected to broker at 10.7.12.103:9092 (registered as #3)
license:[sarama] 2022/02/12 06:09:23 producer/broker/3 shut down
[sarama] 2022/02/12 06:09:24 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:09:24 producer/broker/3 starting up
[sarama] 2022/02/12 06:09:24 producer/broker/3 state change to [open] on realtime/2
[sarama] 2022/02/12 06:09:24 producer/leader/realtime/2 selected broker 3
[sarama] 2022/02/12 06:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 06:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 06:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 06:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 06:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 06:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 06:36:02 producer/broker/2 state change to [closing] because write tcp 10.7.12.20:56716->10.7.12.102:9092: write: broken pipe
[sarama] 2022/02/12 06:36:02 Closed connection to broker 10.7.12.102:9092
[sarama] 2022/02/12 06:36:02 producer/leader/realtime/19 state change to [retrying-1]
[sarama] 2022/02/12 06:36:02 producer/leader/realtime/19 abandoning broker 2
[sarama] 2022/02/12 06:36:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:36:02 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/12 06:36:02 producer/broker/2 starting up
[sarama] 2022/02/12 06:36:02 producer/broker/2 state change to [open] on realtime/19
[sarama] 2022/02/12 06:36:02 producer/leader/realtime/19 selected broker 2
[sarama] 2022/02/12 06:36:02 producer/leader/realtime/19 state change to [flushing-1]
[sarama] 2022/02/12 06:36:02 producer/leader/realtime/19 state change to [normal]
[sarama] 2022/02/12 06:36:02 Connected to broker at 10.7.12.102:9092 (registered as #2)
[sarama] 2022/02/12 06:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 06:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 06:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 06:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 06:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 06:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 06:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 06:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 06:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 06:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 06:57:00 consumer/broker/2 abandoned subscription to realtime/16 because consuming was taking too long
[sarama] 2022/02/12 07:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 07:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 07:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 07:16:00 producer/leader/realtime/10 state change to [retrying-1]
[sarama] 2022/02/12 07:16:00 producer/leader/realtime/10 abandoning broker 2
[sarama] 2022/02/12 07:16:00 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 07:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 07:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 state change to [retrying-1]
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 abandoning broker 1
[sarama] 2022/02/12 07:26:00 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 selected broker 1
[sarama] 2022/02/12 07:26:00 producer/broker/1 state change to [open] on realtime/12
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 state change to [flushing-1]
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 state change to [normal]
[sarama] 2022/02/12 07:26:00 producer/broker/1 state change to [closing] because write tcp 10.7.12.20:50365->10.7.12.101:9092: write: broken pipe
[sarama] 2022/02/12 07:26:00 Closed connection to broker 10.7.12.101:9092
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 state change to [retrying-2]
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 abandoning broker 1
[sarama] 2022/02/12 07:26:00 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:26:00 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/12 07:26:00 producer/broker/1 starting up
[sarama] 2022/02/12 07:26:00 producer/broker/1 state change to [open] on realtime/12
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 selected broker 1
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 state change to [flushing-2]
[sarama] 2022/02/12 07:26:00 producer/leader/realtime/12 state change to [normal]
[sarama] 2022/02/12 07:26:00 Connected to broker at 10.7.12.101:9092 (registered as #1)
[sarama] 2022/02/12 07:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 07:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 07:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 07:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 07:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 07:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 07:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 07:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 07:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 07:47:00 consumer/broker/2 abandoned subscription to realtime/19 because consuming was taking too long
[sarama] 2022/02/12 07:55:15 consumer/broker/1 abandoned subscription to realtime/3 because consuming was taking too long
[sarama] 2022/02/12 07:56:00 consumer/broker/1 abandoned subscription to realtime/0 because consuming was taking too long
[sarama] 2022/02/12 07:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 07:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 07:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 07:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 08:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 08:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 08:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 08:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 08:07:00 consumer/broker/3 abandoned subscription to realtime/2 because consuming was taking too long
[sarama] 2022/02/12 08:15:10 consumer/broker/3 abandoned subscription to realtime/8 because consuming was taking too long
[sarama] 2022/02/12 08:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 08:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 08:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 08:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 08:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 08:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 08:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 08:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 08:27:00 consumer/broker/2 abandoned subscription to realtime/10 because consuming was taking too long
[sarama] 2022/02/12 08:31:00 consumer/broker/1 abandoned subscription to realtime/12 because consuming was taking too long
[sarama] 2022/02/12 08:32:00 consumer/broker/1 abandoned subscription to realtime/18 because consuming was taking too long
[sarama] 2022/02/12 08:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 08:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 08:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 08:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 08:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 08:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 08:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 08:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 08:56:00 producer/leader/realtime/6 state change to [retrying-1]
[sarama] 2022/02/12 08:56:00 producer/leader/realtime/6 abandoning broker 1
[sarama] 2022/02/12 08:56:00 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 08:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 08:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 08:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 08:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 09:00:50 consumer/broker/3 abandoned subscription to realtime/11 because consuming was taking too long
[sarama] 2022/02/12 09:01:00 consumer/broker/2 abandoned subscription to realtime/4 because consuming was taking too long
[sarama] 2022/02/12 09:06:02 producer/leader/realtime/23 state change to [retrying-1]
[sarama] 2022/02/12 09:06:02 producer/leader/realtime/23 abandoning broker 3
[sarama] 2022/02/12 09:06:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 09:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 09:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 09:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 09:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 09:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 09:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 09:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 09:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 09:17:00 consumer/broker/3 abandoned subscription to realtime/20 because consuming was taking too long
[sarama] 2022/02/12 09:17:00 consumer/broker/2 abandoned subscription to realtime/22 because consuming was taking too long
[sarama] 2022/02/12 09:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 09:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 09:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 09:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 09:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 09:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 09:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 09:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 09:43:11 consumer/broker/3 abandoned subscription to realtime/14 because consuming was taking too long
[sarama] 2022/02/12 09:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 09:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 09:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 09:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 09:51:00 consumer/broker/1 abandoned subscription to realtime/15 because consuming was taking too long
[sarama] 2022/02/12 09:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 09:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 09:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 09:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 10:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 10:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 10:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 10:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 10:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 10:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 10:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 10:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 10:17:01 producer/leader/realtime/15 state change to [retrying-1]
[sarama] 2022/02/12 10:17:01 producer/leader/realtime/15 abandoning broker 1
[sarama] 2022/02/12 10:17:01 producer/leader/realtime/4 state change to [retrying-1]
[sarama] 2022/02/12 10:17:01 producer/leader/realtime/4 abandoning broker 2
[sarama] 2022/02/12 10:17:01 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 10:17:01 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/12 10:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 10:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 10:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 10:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 10:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 10:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 10:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 10:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 10:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 10:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 10:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 10:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 10:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 10:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 10:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 10:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 11:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 11:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 11:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 11:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 11:16:32 consumer/broker/3 abandoned subscription to realtime/23 because consuming was taking too long
[sarama] 2022/02/12 11:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 11:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 11:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 11:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 11:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 11:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 11:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 11:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 11:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 11:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 11:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 11:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 11:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 11:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 11:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 11:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 11:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 11:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 11:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 11:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 12:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 12:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 12:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 12:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 12:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 12:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 12:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 12:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 12:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 12:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 12:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 12:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 12:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 12:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 12:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 12:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 12:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 12:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 12:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 12:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 12:51:18 consumer/broker/2 abandoned subscription to realtime/7 because consuming was taking too long
[sarama] 2022/02/12 12:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 12:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 12:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 12:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 13:03:11 consumer/broker/1 abandoned subscription to realtime/6 because consuming was taking too long
[sarama] 2022/02/12 13:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 13:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 13:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 13:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 13:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 13:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 13:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 13:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 13:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 13:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 13:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 13:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 13:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 13:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 13:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 13:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 13:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 13:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 13:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 13:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 13:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 13:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 13:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 13:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 14:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 14:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 14:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 14:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 14:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 14:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 14:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 14:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 14:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 14:26:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 14:26:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 14:26:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 14:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 14:36:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 14:36:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 14:36:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 14:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 14:46:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 14:46:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 14:46:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 14:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 14:56:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 14:56:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 14:56:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 15:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 15:06:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 15:06:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 15:06:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092
[sarama] 2022/02/12 15:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/12 15:16:52 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/12 15:16:52 client/metadata fetching metadata for all topics from broker 10.7.22.81:9092
[sarama] 2022/02/12 15:16:52 client/metadata fetching metadata for all topics from broker 10.7.12.101:9092