[sarama] 2022/02/10 10:07:56 Initializing new client
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 10:07:56 Connected to broker at 10.7.12.102:9092 (unregistered)
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #2 at 10.7.12.102:9092
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #1 at 10.7.12.101:9092
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #3 at 10.7.12.103:9092
[sarama] 2022/02/10 10:07:56 Successfully initialized new client
[sarama] 2022/02/10 10:07:56 Initializing new client
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
[sarama] 2022/02/10 10:07:56 Connected to broker at 172.17.133.192:9092 (unregistered)
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #2 at 172.17.133.192:9092
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #1 at 172.17.133.191:9092
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #3 at 172.17.133.193:9092
[sarama] 2022/02/10 10:07:56 Successfully initialized new client
[sarama] 2022/02/10 10:07:56 Initializing new client
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 10:07:56 Connected to broker at 10.7.22.80:9092 (unregistered)
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #2 at 10.7.22.80:9092
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #1 at 10.7.22.79:9092
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #3 at 10.7.22.81:9092
[sarama] 2022/02/10 10:07:56 Successfully initialized new client
[sarama] 2022/02/10 10:07:56 Initializing new client
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 10:07:56 Connected to broker at 10.7.12.103:9092 (unregistered)
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #2 at 10.7.12.102:9092
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #1 at 10.7.12.101:9092
[sarama] 2022/02/10 10:07:56 client/brokers registered new broker #3 at 10.7.12.103:9092
[sarama] 2022/02/10 10:07:56 Successfully initialized new client
[sarama] 2022/02/10 10:07:56 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/10 10:07:56 client/coordinator requesting coordinator for consumergroup realtime_campaign_consumer_group_for_engine from 10.7.12.103:9092
[sarama] 2022/02/10 10:07:56 client/coordinator coordinator for consumergroup realtime_campaign_consumer_group_for_engine is #3 (10.7.12.103:9092)
[sarama] 2022/02/10 10:07:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:07:56 Connected to broker at 10.7.12.103:9092 (registered as #3)
[sarama] 2022/02/10 10:08:04 client/coordinator requesting coordinator for consumergroup realtime_campaign_consumer_group_for_engine from 10.7.12.103:9092
[sarama] 2022/02/10 10:08:04 client/coordinator coordinator for consumergroup realtime_campaign_consumer_group_for_engine is #3 (10.7.12.103:9092)
[sarama] 2022/02/10 10:08:04 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:08:04 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:08:04 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/10 10:08:04 Connected to broker at 10.7.12.101:9092 (registered as #1)
[sarama] 2022/02/10 10:08:04 Connected to broker at 10.7.12.102:9092 (registered as #2)
[sarama] 2022/02/10 10:08:04 consumer/broker/3 added subscription to realtime/11
[sarama] 2022/02/10 10:08:04 consumer/broker/2 added subscription to realtime/13
[sarama] 2022/02/10 10:08:04 consumer/broker/1 added subscription to realtime/12
[sarama] 2022/02/10 10:08:05 consumer/broker/3 abandoned subscription to realtime/11 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/3 added subscription to realtime/2
[sarama] 2022/02/10 10:08:05 consumer/broker/2 abandoned subscription to realtime/13 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/2 added subscription to realtime/1
[sarama] 2022/02/10 10:08:05 consumer/broker/2 added subscription to realtime/19
[sarama] 2022/02/10 10:08:05 consumer/broker/2 added subscription to realtime/22
[sarama] 2022/02/10 10:08:05 consumer/broker/2 added subscription to realtime/16
[sarama] 2022/02/10 10:08:05 consumer/broker/3 added subscription to realtime/20
[sarama] 2022/02/10 10:08:05 consumer/broker/3 added subscription to realtime/23
[sarama] 2022/02/10 10:08:05 consumer/broker/3 added subscription to realtime/14
[sarama] 2022/02/10 10:08:05 consumer/broker/3 added subscription to realtime/5
[sarama] 2022/02/10 10:08:05 consumer/broker/3 added subscription to realtime/8
[sarama] 2022/02/10 10:08:05 consumer/broker/3 added subscription to realtime/17
[sarama] 2022/02/10 10:08:05 consumer/broker/2 added subscription to realtime/7
[sarama] 2022/02/10 10:08:05 consumer/broker/2 added subscription to realtime/4
[sarama] 2022/02/10 10:08:05 consumer/broker/2 added subscription to realtime/10
[sarama] 2022/02/10 10:08:05 consumer/broker/1 abandoned subscription to realtime/12 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/1 added subscription to realtime/15
[sarama] 2022/02/10 10:08:05 consumer/broker/1 added subscription to realtime/0
[sarama] 2022/02/10 10:08:05 consumer/broker/1 added subscription to realtime/9
[sarama] 2022/02/10 10:08:05 consumer/broker/1 added subscription to realtime/6
[sarama] 2022/02/10 10:08:05 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/10 10:08:05 consumer/broker/1 added subscription to realtime/3
[sarama] 2022/02/10 10:08:05 consumer/broker/1 added subscription to realtime/18
[sarama] 2022/02/10 10:08:05 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:08:05 producer/broker/3 starting up
[sarama] 2022/02/10 10:08:05 producer/broker/3 state change to [open] on realtime/20
[sarama] 2022/02/10 10:08:05 Connected to broker at 10.7.12.103:9092 (registered as #3)
[sarama] 2022/02/10 10:08:05 consumer/broker/2 abandoned subscription to realtime/1 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/2 abandoned subscription to realtime/19 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/2 abandoned subscription to realtime/16 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/2 abandoned subscription to realtime/7 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/2 abandoned subscription to realtime/4 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/2 abandoned subscription to realtime/10 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/1 abandoned subscription to realtime/9 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/1 abandoned subscription to realtime/3 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/1 abandoned subscription to realtime/18 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/1 abandoned subscription to realtime/15 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/1 abandoned subscription to realtime/0 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:08:05 producer/broker/2 starting up
[sarama] 2022/02/10 10:08:05 producer/broker/2 state change to [open] on realtime/34
[sarama] 2022/02/10 10:08:05 Connected to broker at 10.7.12.102:9092 (registered as #2)
[sarama] 2022/02/10 10:08:05 consumer/broker/3 abandoned subscription to realtime/20 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/3 abandoned subscription to realtime/23 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/3 abandoned subscription to realtime/5 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/3 abandoned subscription to realtime/8 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/3 abandoned subscription to realtime/17 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 consumer/broker/3 abandoned subscription to realtime/2 because consuming was taking too long
[sarama] 2022/02/10 10:08:05 producer/broker/3 state change to [open] on realtime/23
[sarama] 2022/02/10 10:08:05 producer/broker/3 state change to [open] on realtime/11
[sarama] 2022/02/10 10:08:05 producer/broker/2 state change to [open] on realtime/16
[sarama] 2022/02/10 10:08:06 producer/broker/2 state change to [open] on realtime/25
[sarama] 2022/02/10 10:08:08 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:08:08 producer/broker/1 starting up
[sarama] 2022/02/10 10:08:08 producer/broker/1 state change to [open] on realtime/6
[sarama] 2022/02/10 10:08:08 Connected to broker at 10.7.12.101:9092 (registered as #1)
[sarama] 2022/02/10 10:08:08 producer/broker/3 state change to [open] on realtime/17
[sarama] 2022/02/10 10:08:11 producer/broker/2 state change to [open] on realtime/22
[sarama] 2022/02/10 10:08:11 producer/broker/3 state change to [open] on realtime/5
[sarama] 2022/02/10 10:08:22 producer/broker/3 state change to [open] on realtime/14
[sarama] 2022/02/10 10:08:51 consumer/broker/3 added subscription to realtime/11
[sarama] 2022/02/10 10:08:51 consumer/broker/3 abandoned subscription to realtime/11 because consuming was taking too long
[sarama] 2022/02/10 10:08:52 consumer/broker/3 added subscription to realtime/11
[sarama] 2022/02/10 10:08:59 producer/broker/3 state change to [open] on realtime/38
[sarama] 2022/02/10 10:09:02 consumer/broker/1 added subscription to realtime/3
[sarama] 2022/02/10 10:09:02 consumer/broker/1 abandoned subscription to realtime/3 because consuming was taking too long
[sarama] 2022/02/10 10:09:03 consumer/broker/1 added subscription to realtime/3
license:[sarama] 2022/02/10 10:09:06 consumer/broker/3 abandoned subscription to realtime/11 because consuming was taking too long
[sarama] 2022/02/10 10:09:06 consumer/broker/3 added subscription to realtime/11
[sarama] 2022/02/10 10:09:07 producer/broker/3 state change to [open] on realtime/2
[sarama] 2022/02/10 10:09:12 producer/broker/1 state change to [open] on realtime/18
[sarama] 2022/02/10 10:09:16 consumer/broker/1 abandoned subscription to realtime/3 because consuming was taking too long
[sarama] 2022/02/10 10:09:16 consumer/broker/1 added subscription to realtime/3
[sarama] 2022/02/10 10:09:16 producer/broker/1 state change to [open] on realtime/39
[sarama] 2022/02/10 10:09:16 producer/broker/2 state change to [open] on realtime/4
[sarama] 2022/02/10 10:09:21 consumer/broker/2 added subscription to realtime/19
[sarama] 2022/02/10 10:09:21 consumer/broker/2 abandoned subscription to realtime/19 because consuming was taking too long
[sarama] 2022/02/10 10:09:22 consumer/broker/2 added subscription to realtime/19
[sarama] 2022/02/10 10:09:25 consumer/broker/2 abandoned subscription to realtime/19 because consuming was taking too long
[sarama] 2022/02/10 10:09:25 consumer/broker/2 added subscription to realtime/19
[sarama] 2022/02/10 10:09:28 producer/broker/1 state change to [open] on realtime/12
[sarama] 2022/02/10 10:09:29 consumer/broker/2 abandoned subscription to realtime/19 because consuming was taking too long
[sarama] 2022/02/10 10:09:29 consumer/broker/2 added subscription to realtime/19
[sarama] 2022/02/10 10:09:37 producer/broker/2 state change to [open] on realtime/1
[sarama] 2022/02/10 10:09:56 producer/broker/2 state change to [open] on realtime/31
[sarama] 2022/02/10 10:09:59 consumer/broker/2 abandoned subscription to realtime/19 because consuming was taking too long
[sarama] 2022/02/10 10:09:59 consumer/broker/2 added subscription to realtime/19
[sarama] 2022/02/10 10:10:04 consumer/broker/1 abandoned subscription to realtime/3 because consuming was taking too long
[sarama] 2022/02/10 10:10:04 consumer/broker/1 added subscription to realtime/3
[sarama] 2022/02/10 10:10:08 producer/broker/1 state change to [open] on realtime/27
[sarama] 2022/02/10 10:10:11 consumer/broker/1 abandoned subscription to realtime/3 because consuming was taking too long
[sarama] 2022/02/10 10:10:11 consumer/broker/1 added subscription to realtime/3
[sarama] 2022/02/10 10:10:13 producer/broker/2 state change to [open] on realtime/19
[sarama] 2022/02/10 10:10:13 producer/broker/1 state change to [open] on realtime/45
[sarama] 2022/02/10 10:10:20 producer/broker/3 state change to [open] on realtime/41
[sarama] 2022/02/10 10:10:20 producer/broker/3 state change to [open] on realtime/32
[sarama] 2022/02/10 10:10:42 producer/broker/2 state change to [open] on realtime/28
[sarama] 2022/02/10 10:10:42 producer/broker/1 state change to [open] on realtime/15
[sarama] 2022/02/10 10:10:51 producer/broker/1 state change to [open] on realtime/21
[sarama] 2022/02/10 10:10:54 producer/broker/1 state change to [open] on realtime/3
[sarama] 2022/02/10 10:10:54 producer/broker/1 state change to [open] on realtime/33
[sarama] 2022/02/10 10:11:00 consumer/broker/3 abandoned subscription to realtime/11 because consuming was taking too long
[sarama] 2022/02/10 10:11:00 consumer/broker/3 added subscription to realtime/11
[sarama] 2022/02/10 10:11:00 consumer/broker/3 abandoned subscription to realtime/11 because consuming was taking too long
[sarama] 2022/02/10 10:11:00 consumer/broker/3 added subscription to realtime/11
[sarama] 2022/02/10 10:11:22 consumer/broker/3 added subscription to realtime/2
[sarama] 2022/02/10 10:11:22 consumer/broker/3 abandoned subscription to realtime/2 because consuming was taking too long
[sarama] 2022/02/10 10:11:28 producer/broker/2 state change to [open] on realtime/37
[sarama] 2022/02/10 10:11:29 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/10 10:11:29 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/10 10:11:37 consumer/broker/3 added subscription to realtime/2
[sarama] 2022/02/10 10:11:37 consumer/broker/3 abandoned subscription to realtime/2 because consuming was taking too long
[sarama] 2022/02/10 10:11:37 consumer/broker/3 added subscription to realtime/2
[sarama] 2022/02/10 10:11:40 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/10 10:11:45 consumer/broker/1 added subscription to realtime/12
license:[sarama] 2022/02/10 10:11:45 consumer/broker/1 abandoned subscription to realtime/12 because consuming was taking too long
license:[sarama] 2022/02/10 10:11:48 consumer/broker/1 abandoned subscription to realtime/21 because consuming was taking too long
[sarama] 2022/02/10 10:11:48 consumer/broker/1 added subscription to realtime/21
[sarama] 2022/02/10 10:12:01 consumer/broker/1 added subscription to realtime/12
[sarama] 2022/02/10 10:12:01 consumer/broker/1 abandoned subscription to realtime/12 because consuming was taking too long
[sarama] 2022/02/10 10:12:03 producer/broker/2 state change to [open] on realtime/46
[sarama] 2022/02/10 10:12:06 consumer/broker/2 added subscription to realtime/16
[sarama] 2022/02/10 10:12:06 consumer/broker/2 abandoned subscription to realtime/16 because consuming was taking too long
[sarama] 2022/02/10 10:12:08 consumer/broker/3 added subscription to realtime/8
[sarama] 2022/02/10 10:12:08 consumer/broker/3 abandoned subscription to realtime/8 because consuming was taking too long
[sarama] 2022/02/10 10:12:09 producer/broker/2 state change to [open] on realtime/7
[sarama] 2022/02/10 10:12:09 consumer/broker/1 added subscription to realtime/0
[sarama] 2022/02/10 10:12:09 consumer/broker/1 abandoned subscription to realtime/0 because consuming was taking too long
[sarama] 2022/02/10 10:12:10 consumer/broker/2 added subscription to realtime/4
[sarama] 2022/02/10 10:12:10 consumer/broker/2 abandoned subscription to realtime/4 because consuming was taking too long
[sarama] 2022/02/10 10:12:10 consumer/broker/3 added subscription to realtime/20
[sarama] 2022/02/10 10:12:10 consumer/broker/3 abandoned subscription to realtime/20 because consuming was taking too long
[sarama] 2022/02/10 10:12:15 producer/broker/3 state change to [open] on realtime/47
[sarama] 2022/02/10 10:12:16 consumer/broker/1 added subscription to realtime/12
[sarama] 2022/02/10 10:12:16 consumer/broker/1 abandoned subscription to realtime/12 because consuming was taking too long
[sarama] 2022/02/10 10:12:18 consumer/broker/1 added subscription to realtime/12
[sarama] 2022/02/10 10:12:19 consumer/broker/1 added subscription to realtime/18
[sarama] 2022/02/10 10:12:19 consumer/broker/1 abandoned subscription to realtime/18 because consuming was taking too long
[sarama] 2022/02/10 10:12:20 producer/broker/1 state change to [open] on realtime/9
[sarama] 2022/02/10 10:12:20 producer/broker/2 state change to [open] on realtime/43
[sarama] 2022/02/10 10:12:28 consumer/broker/2 added subscription to realtime/10
[sarama] 2022/02/10 10:12:28 consumer/broker/2 abandoned subscription to realtime/10 because consuming was taking too long
[sarama] 2022/02/10 10:12:30 consumer/broker/2 added subscription to realtime/1
[sarama] 2022/02/10 10:12:30 consumer/broker/2 abandoned subscription to realtime/1 because consuming was taking too long
[sarama] 2022/02/10 10:12:30 producer/broker/3 state change to [open] on realtime/8
[sarama] 2022/02/10 10:12:34 consumer/broker/1 added subscription to realtime/15
[sarama] 2022/02/10 10:12:34 consumer/broker/1 abandoned subscription to realtime/15 because consuming was taking too long
[sarama] 2022/02/10 10:12:36 consumer/broker/1 added subscription to realtime/9
[sarama] 2022/02/10 10:12:36 consumer/broker/1 abandoned subscription to realtime/9 because consuming was taking too long
[sarama] 2022/02/10 10:12:38 producer/broker/2 state change to [open] on realtime/13
[sarama] 2022/02/10 10:12:40 consumer/broker/3 added subscription to realtime/17
[sarama] 2022/02/10 10:12:40 consumer/broker/3 abandoned subscription to realtime/17 because consuming was taking too long
[sarama] 2022/02/10 10:12:44 producer/broker/1 state change to [open] on realtime/24
[sarama] 2022/02/10 10:12:57 consumer/broker/1 added subscription to realtime/15
[sarama] 2022/02/10 10:12:57 consumer/broker/2 added subscription to realtime/7
[sarama] 2022/02/10 10:12:57 consumer/broker/2 abandoned subscription to realtime/7 because consuming was taking too long
license:[sarama] 2022/02/10 10:12:57 consumer/broker/3 added subscription to realtime/23
[sarama] 2022/02/10 10:12:57 consumer/broker/3 abandoned subscription to realtime/23 because consuming was taking too long
[sarama] 2022/02/10 10:12:59 producer/broker/2 state change to [open] on realtime/10
[sarama] 2022/02/10 10:13:05 producer/broker/1 state change to [open] on realtime/42
[sarama] 2022/02/10 10:13:06 consumer/broker/3 added subscription to realtime/5
[sarama] 2022/02/10 10:13:06 consumer/broker/3 abandoned subscription to realtime/5 because consuming was taking too long
[sarama] 2022/02/10 10:13:08 consumer/broker/2 added subscription to realtime/13
[sarama] 2022/02/10 10:13:08 consumer/broker/2 abandoned subscription to realtime/13 because consuming was taking too long
[sarama] 2022/02/10 10:13:23 producer/broker/1 state change to [open] on realtime/36
[sarama] 2022/02/10 10:13:27 consumer/broker/2 added subscription to realtime/1
[sarama] 2022/02/10 10:13:27 consumer/broker/2 abandoned subscription to realtime/1 because consuming was taking too long
license:[sarama] 2022/02/10 10:13:27 consumer/broker/1 abandoned subscription to realtime/15 because consuming was taking too long
[sarama] 2022/02/10 10:13:27 consumer/broker/1 added subscription to realtime/15
[sarama] 2022/02/10 10:13:28 consumer/broker/2 added subscription to realtime/1
[sarama] 2022/02/10 10:13:30 producer/broker/3 state change to [open] on realtime/35
[sarama] 2022/02/10 10:13:35 consumer/broker/3 added subscription to realtime/23
[sarama] 2022/02/10 10:13:35 consumer/broker/3 abandoned subscription to realtime/23 because consuming was taking too long
[sarama] 2022/02/10 10:13:35 consumer/broker/3 added subscription to realtime/23
[sarama] 2022/02/10 10:13:35 consumer/broker/2 added subscription to realtime/4
[sarama] 2022/02/10 10:13:35 consumer/broker/2 abandoned subscription to realtime/4 because consuming was taking too long
[sarama] 2022/02/10 10:13:36 consumer/broker/2 added subscription to realtime/4
[sarama] 2022/02/10 10:14:01 consumer/broker/1 added subscription to realtime/18
[sarama] 2022/02/10 10:14:01 consumer/broker/1 abandoned subscription to realtime/18 because consuming was taking too long
[sarama] 2022/02/10 10:14:01 consumer/broker/1 added subscription to realtime/18
[sarama] 2022/02/10 10:14:10 producer/broker/3 state change to [open] on realtime/44
[sarama] 2022/02/10 10:14:14 producer/broker/2 state change to [open] on realtime/40
[sarama] 2022/02/10 10:14:25 consumer/broker/2 added subscription to realtime/13
[sarama] 2022/02/10 10:14:25 consumer/broker/2 abandoned subscription to realtime/13 because consuming was taking too long
[sarama] 2022/02/10 10:14:25 consumer/broker/2 added subscription to realtime/13
[sarama] 2022/02/10 10:14:28 producer/broker/1 state change to [open] on realtime/30
[sarama] 2022/02/10 10:14:31 producer/broker/3 state change to [open] on realtime/29
[sarama] 2022/02/10 10:14:39 consumer/broker/2 added subscription to realtime/7
[sarama] 2022/02/10 10:14:39 consumer/broker/2 abandoned subscription to realtime/7 because consuming was taking too long
[sarama] 2022/02/10 10:14:40 consumer/broker/2 added subscription to realtime/7
[sarama] 2022/02/10 10:14:40 consumer/broker/2 abandoned subscription to realtime/7 because consuming was taking too long
[sarama] 2022/02/10 10:14:40 consumer/broker/2 added subscription to realtime/7
[sarama] 2022/02/10 10:14:40 consumer/broker/3 added subscription to realtime/20
[sarama] 2022/02/10 10:14:40 consumer/broker/3 abandoned subscription to realtime/20 because consuming was taking too long
[sarama] 2022/02/10 10:14:42 consumer/broker/3 added subscription to realtime/20
[sarama] 2022/02/10 10:14:58 consumer/broker/2 abandoned subscription to realtime/7 because consuming was taking too long
[sarama] 2022/02/10 10:14:58 consumer/broker/2 added subscription to realtime/7
[sarama] 2022/02/10 10:15:00 producer/broker/3 state change to [open] on realtime/26
[sarama] 2022/02/10 10:15:01 consumer/broker/3 added subscription to realtime/5
[sarama] 2022/02/10 10:15:01 consumer/broker/3 abandoned subscription to realtime/5 because consuming was taking too long
[sarama] 2022/02/10 10:15:02 consumer/broker/3 added subscription to realtime/5
license:[sarama] 2022/02/10 10:15:13 consumer/broker/2 abandoned subscription to realtime/13 because consuming was taking too long
[sarama] 2022/02/10 10:15:13 consumer/broker/2 added subscription to realtime/13
[sarama] 2022/02/10 10:15:18 consumer/broker/2 added subscription to realtime/10
[sarama] 2022/02/10 10:15:18 consumer/broker/2 abandoned subscription to realtime/10 because consuming was taking too long
[sarama] 2022/02/10 10:15:19 consumer/broker/2 added subscription to realtime/10
[sarama] 2022/02/10 10:15:21 consumer/broker/3 abandoned subscription to realtime/5 because consuming was taking too long
[sarama] 2022/02/10 10:15:21 consumer/broker/3 added subscription to realtime/5
[sarama] 2022/02/10 10:16:00 consumer/broker/2 abandoned subscription to realtime/1 because consuming was taking too long
[sarama] 2022/02/10 10:16:00 consumer/broker/2 added subscription to realtime/1
[sarama] 2022/02/10 10:16:00 consumer/broker/2 abandoned subscription to realtime/1 because consuming was taking too long
[sarama] 2022/02/10 10:16:00 consumer/broker/2 added subscription to realtime/1
[sarama] 2022/02/10 10:16:28 consumer/broker/3 added subscription to realtime/17
[sarama] 2022/02/10 10:16:28 consumer/broker/3 abandoned subscription to realtime/17 because consuming was taking too long
[sarama] 2022/02/10 10:16:32 producer/broker/1 state change to [open] on realtime/0
[sarama] 2022/02/10 10:16:39 consumer/broker/3 added subscription to realtime/17
[sarama] 2022/02/10 10:17:22 consumer/broker/3 added subscription to realtime/8
[sarama] 2022/02/10 10:17:22 consumer/broker/3 abandoned subscription to realtime/8 because consuming was taking too long
[sarama] 2022/02/10 10:17:23 consumer/broker/2 added subscription to realtime/16
[sarama] 2022/02/10 10:17:23 consumer/broker/2 abandoned subscription to realtime/16 because consuming was taking too long
[sarama] 2022/02/10 10:17:23 consumer/broker/1 added subscription to realtime/9
[sarama] 2022/02/10 10:17:23 consumer/broker/1 abandoned subscription to realtime/9 because consuming was taking too long
[sarama] 2022/02/10 10:17:41 consumer/broker/3 abandoned subscription to realtime/17 because consuming was taking too long
[sarama] 2022/02/10 10:17:41 consumer/broker/3 added subscription to realtime/17
[sarama] 2022/02/10 10:17:50 consumer/broker/1 added subscription to realtime/0
[sarama] 2022/02/10 10:17:50 consumer/broker/1 abandoned subscription to realtime/0 because consuming was taking too long
[sarama] 2022/02/10 10:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 10:17:56 client/metadata fetching metadata for all topics from broker 172.17.133.192:9092
license:[sarama] 2022/02/10 10:17:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 10:17:56 client/metadata got error from broker -1 while fetching metadata: EOF
[sarama] 2022/02/10 10:17:56 Closed connection to broker 172.17.133.192:9092
[sarama] 2022/02/10 10:17:56 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 10:17:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 10:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 10:17:56 Connected to broker at 172.17.133.193:9092 (unregistered)
[sarama] 2022/02/10 10:18:00 consumer/broker/1 added subscription to realtime/9
[sarama] 2022/02/10 10:18:00 consumer/broker/1 abandoned subscription to realtime/9 because consuming was taking too long
[sarama] 2022/02/10 10:18:00 consumer/broker/1 added subscription to realtime/9
[sarama] 2022/02/10 10:18:03 consumer/broker/3 added subscription to realtime/8
[sarama] 2022/02/10 10:18:30 consumer/broker/3 abandoned subscription to realtime/8 because consuming was taking too long
[sarama] 2022/02/10 10:18:30 consumer/broker/3 added subscription to realtime/8
[sarama] 2022/02/10 10:18:47 consumer/broker/1 added subscription to realtime/0
[sarama] 2022/02/10 10:18:47 consumer/broker/1 abandoned subscription to realtime/0 because consuming was taking too long
[sarama] 2022/02/10 10:18:48 consumer/broker/1 added subscription to realtime/0
[sarama] 2022/02/10 10:19:52 consumer/broker/2 added subscription to realtime/16
[sarama] 2022/02/10 10:27:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 10:27:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 10:27:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 10:27:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 10:37:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 10:37:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 10:37:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 10:37:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 10:47:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 10:47:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 10:47:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 10:47:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 10:57:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 10:57:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 10:57:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 10:57:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 11:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 11:07:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 11:07:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 11:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 11:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 11:17:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 11:17:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 11:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 11:27:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 11:27:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 11:27:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 11:27:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 11:37:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 11:37:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 11:37:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 11:37:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 11:47:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 11:47:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 11:47:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 11:47:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 11:57:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 11:57:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 11:57:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 11:57:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 12:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 12:07:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 12:07:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 12:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 12:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 12:17:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 12:17:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 12:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 12:27:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 12:27:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 12:27:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 12:27:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 12:37:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 12:37:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 12:37:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 12:37:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 12:47:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 12:47:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 12:47:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 12:47:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 12:51:34 consumergroup/realtime_campaign_consumer_group_for_engine loop check partition number coroutine will exit, topics [realtime]
[sarama] 2022/02/10 12:51:35 consumer/broker/1 closed dead subscription to realtime/12
[sarama] 2022/02/10 12:51:35 consumer/broker/1 closed dead subscription to realtime/6
[sarama] 2022/02/10 12:51:35 consumer/broker/1 closed dead subscription to realtime/15
[sarama] 2022/02/10 12:51:35 consumer/broker/1 closed dead subscription to realtime/18
[sarama] 2022/02/10 12:51:35 consumer/broker/1 closed dead subscription to realtime/9
[sarama] 2022/02/10 12:51:35 consumer/broker/1 closed dead subscription to realtime/0
[sarama] 2022/02/10 12:51:35 consumer/broker/1 closed dead subscription to realtime/3
[sarama] 2022/02/10 12:51:35 consumer/broker/1 closed dead subscription to realtime/21
[sarama] 2022/02/10 12:51:35 consumer/broker/2 closed dead subscription to realtime/10
[sarama] 2022/02/10 12:51:35 consumer/broker/2 closed dead subscription to realtime/16
[sarama] 2022/02/10 12:51:35 consumer/broker/2 closed dead subscription to realtime/19
[sarama] 2022/02/10 12:51:35 consumer/broker/2 closed dead subscription to realtime/1
[sarama] 2022/02/10 12:51:35 consumer/broker/2 closed dead subscription to realtime/22
[sarama] 2022/02/10 12:51:35 consumer/broker/2 closed dead subscription to realtime/4
[sarama] 2022/02/10 12:51:35 consumer/broker/2 closed dead subscription to realtime/13
[sarama] 2022/02/10 12:51:35 consumer/broker/2 closed dead subscription to realtime/7
[sarama] 2022/02/10 12:51:35 consumer/broker/3 closed dead subscription to realtime/5
[sarama] 2022/02/10 12:51:35 consumer/broker/3 closed dead subscription to realtime/17
[sarama] 2022/02/10 12:51:35 consumer/broker/3 closed dead subscription to realtime/8
[sarama] 2022/02/10 12:51:35 consumer/broker/3 closed dead subscription to realtime/11
[sarama] 2022/02/10 12:51:35 consumer/broker/3 closed dead subscription to realtime/2
[sarama] 2022/02/10 12:51:35 consumer/broker/3 closed dead subscription to realtime/23
[sarama] 2022/02/10 12:51:35 consumer/broker/3 closed dead subscription to realtime/14
[sarama] 2022/02/10 12:51:35 consumer/broker/3 closed dead subscription to realtime/20
[sarama] 2022/02/10 12:51:35 consumergroup/session/sarama-eb3007f1-cea7-4130-907d-9ac7dd468a1c/129 heartbeat loop stopped
[sarama] 2022/02/10 12:51:35 consumergroup/session/sarama-eb3007f1-cea7-4130-907d-9ac7dd468a1c/129 released
[sarama] 2022/02/10 12:51:35 client/metadata fetching metadata for [realtime] from broker 10.7.12.103:9092
[sarama] 2022/02/10 12:51:38 client/coordinator requesting coordinator for consumergroup realtime_campaign_consumer_group_for_engine from 10.7.12.103:9092
[sarama] 2022/02/10 12:51:38 client/coordinator coordinator for consumergroup realtime_campaign_consumer_group_for_engine is #3 (10.7.12.103:9092)
[sarama] 2022/02/10 12:51:38 consumer/broker/3 added subscription to realtime/26
[sarama] 2022/02/10 12:51:38 consumer/broker/2 added subscription to realtime/28
[sarama] 2022/02/10 12:51:38 consumer/broker/2 added subscription to realtime/25
[sarama] 2022/02/10 12:51:38 consumer/broker/1 added subscription to realtime/27
[sarama] 2022/02/10 12:51:38 consumer/broker/1 added subscription to realtime/24
[sarama] 2022/02/10 12:51:39 consumer/broker/1 abandoned subscription to realtime/24 because consuming was taking too long
[sarama] 2022/02/10 12:51:39 consumer/broker/1 added subscription to realtime/30
[sarama] 2022/02/10 12:51:39 consumer/broker/1 added subscription to realtime/33
[sarama] 2022/02/10 12:51:39 consumer/broker/1 added subscription to realtime/36
[sarama] 2022/02/10 12:51:39 consumer/broker/1 added subscription to realtime/39
[sarama] 2022/02/10 12:51:39 consumer/broker/1 added subscription to realtime/42
[sarama] 2022/02/10 12:51:39 consumer/broker/1 added subscription to realtime/45
[sarama] 2022/02/10 12:51:39 consumer/broker/3 abandoned subscription to realtime/26 because consuming was taking too long
[sarama] 2022/02/10 12:51:39 consumer/broker/3 added subscription to realtime/29
[sarama] 2022/02/10 12:51:39 consumer/broker/3 added subscription to realtime/32
[sarama] 2022/02/10 12:51:39 consumer/broker/3 added subscription to realtime/41
[sarama] 2022/02/10 12:51:39 consumer/broker/3 added subscription to realtime/35
[sarama] 2022/02/10 12:51:39 consumer/broker/3 added subscription to realtime/38
[sarama] 2022/02/10 12:51:39 consumer/broker/3 added subscription to realtime/44
[sarama] 2022/02/10 12:51:39 consumer/broker/3 added subscription to realtime/47
[sarama] 2022/02/10 12:51:40 consumer/broker/3 abandoned subscription to realtime/32 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/3 abandoned subscription to realtime/41 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/3 abandoned subscription to realtime/38 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/3 abandoned subscription to realtime/47 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/2 abandoned subscription to realtime/25 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/2 added subscription to realtime/31
[sarama] 2022/02/10 12:51:40 consumer/broker/2 added subscription to realtime/34
[sarama] 2022/02/10 12:51:40 consumer/broker/2 added subscription to realtime/37
[sarama] 2022/02/10 12:51:40 consumer/broker/2 added subscription to realtime/40
[sarama] 2022/02/10 12:51:40 consumer/broker/2 added subscription to realtime/43
[sarama] 2022/02/10 12:51:40 consumer/broker/2 added subscription to realtime/46
[sarama] 2022/02/10 12:51:40 consumer/broker/1 abandoned subscription to realtime/33 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/1 abandoned subscription to realtime/39 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/1 abandoned subscription to realtime/42 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/1 abandoned subscription to realtime/30 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/2 abandoned subscription to realtime/34 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/2 abandoned subscription to realtime/40 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/2 abandoned subscription to realtime/46 because consuming was taking too long
[sarama] 2022/02/10 12:51:40 consumer/broker/2 abandoned subscription to realtime/31 because consuming was taking too long
[sarama] 2022/02/10 12:52:14 consumer/broker/2 added subscription to realtime/40
[sarama] 2022/02/10 12:52:14 consumer/broker/2 abandoned subscription to realtime/40 because consuming was taking too long
[sarama] 2022/02/10 12:52:15 consumer/broker/2 added subscription to realtime/40
[sarama] 2022/02/10 12:52:26 consumer/broker/1 added subscription to realtime/30
[sarama] 2022/02/10 12:52:26 consumer/broker/1 abandoned subscription to realtime/30 because consuming was taking too long
[sarama] 2022/02/10 12:52:27 consumer/broker/2 added subscription to realtime/34
[sarama] 2022/02/10 12:52:29 consumer/broker/1 added subscription to realtime/30
[sarama] 2022/02/10 12:52:32 consumer/broker/1 added subscription to realtime/42
[sarama] 2022/02/10 12:52:32 consumer/broker/1 abandoned subscription to realtime/42 because consuming was taking too long
license:[sarama] 2022/02/10 12:52:34 consumer/broker/1 added subscription to realtime/42
[sarama] 2022/02/10 12:52:34 consumer/broker/2 abandoned subscription to realtime/40 because consuming was taking too long
[sarama] 2022/02/10 12:52:34 consumer/broker/2 added subscription to realtime/40
[sarama] 2022/02/10 12:52:38 consumer/broker/2 abandoned subscription to realtime/40 because consuming was taking too long
[sarama] 2022/02/10 12:52:38 consumer/broker/2 added subscription to realtime/40
[sarama] 2022/02/10 12:52:44 consumer/broker/2 added subscription to realtime/46
[sarama] 2022/02/10 12:52:44 consumer/broker/2 abandoned subscription to realtime/46 because consuming was taking too long
[sarama] 2022/02/10 12:52:44 consumer/broker/2 added subscription to realtime/46
[sarama] 2022/02/10 12:52:53 consumer/broker/3 added subscription to realtime/26
[sarama] 2022/02/10 12:52:53 consumer/broker/3 abandoned subscription to realtime/26 because consuming was taking too long
[sarama] 2022/02/10 12:52:54 consumer/broker/3 added subscription to realtime/26
[sarama] 2022/02/10 12:53:11 consumer/broker/3 added subscription to realtime/38
[sarama] 2022/02/10 12:53:11 consumer/broker/3 abandoned subscription to realtime/38 because consuming was taking too long
[sarama] 2022/02/10 12:53:12 consumer/broker/3 added subscription to realtime/38
[sarama] 2022/02/10 12:53:26 consumer/broker/3 abandoned subscription to realtime/26 because consuming was taking too long
[sarama] 2022/02/10 12:53:26 consumer/broker/3 added subscription to realtime/26
[sarama] 2022/02/10 12:53:40 consumer/broker/3 added subscription to realtime/41
[sarama] 2022/02/10 12:53:40 consumer/broker/3 abandoned subscription to realtime/41 because consuming was taking too long
[sarama] 2022/02/10 12:53:44 consumer/broker/3 added subscription to realtime/41
[sarama] 2022/02/10 12:53:44 consumer/broker/1 added subscription to realtime/24
[sarama] 2022/02/10 12:53:44 consumer/broker/1 abandoned subscription to realtime/24 because consuming was taking too long
[sarama] 2022/02/10 12:53:44 consumer/broker/1 added subscription to realtime/24
[sarama] 2022/02/10 12:53:45 consumer/broker/1 added subscription to realtime/39
[sarama] 2022/02/10 12:53:45 consumer/broker/1 abandoned subscription to realtime/39 because consuming was taking too long
[sarama] 2022/02/10 12:53:46 consumer/broker/1 added subscription to realtime/39
[sarama] 2022/02/10 12:53:52 consumer/broker/3 added subscription to realtime/32
[sarama] 2022/02/10 12:53:52 consumer/broker/3 abandoned subscription to realtime/32 because consuming was taking too long
[sarama] 2022/02/10 12:53:52 consumer/broker/3 added subscription to realtime/32
[sarama] 2022/02/10 12:54:38 consumer/broker/3 abandoned subscription to realtime/26 because consuming was taking too long
[sarama] 2022/02/10 12:54:38 consumer/broker/3 added subscription to realtime/26
[sarama] 2022/02/10 12:54:55 consumer/broker/1 added subscription to realtime/33
[sarama] 2022/02/10 12:54:55 consumer/broker/1 abandoned subscription to realtime/33 because consuming was taking too long
[sarama] 2022/02/10 12:54:59 consumer/broker/1 added subscription to realtime/33
[sarama] 2022/02/10 12:54:59 consumer/broker/3 added subscription to realtime/47
[sarama] 2022/02/10 12:54:59 consumer/broker/3 abandoned subscription to realtime/47 because consuming was taking too long
[sarama] 2022/02/10 12:55:01 consumer/broker/3 added subscription to realtime/47
[sarama] 2022/02/10 12:55:23 consumer/broker/2 added subscription to realtime/31
[sarama] 2022/02/10 12:55:23 consumer/broker/2 abandoned subscription to realtime/31 because consuming was taking too long
[sarama] 2022/02/10 12:55:26 consumer/broker/2 added subscription to realtime/31
[sarama] 2022/02/10 12:55:43 consumer/broker/2 added subscription to realtime/25
[sarama] 2022/02/10 12:55:43 consumer/broker/2 abandoned subscription to realtime/25 because consuming was taking too long
[sarama] 2022/02/10 12:55:47 consumer/broker/2 added subscription to realtime/25
[sarama] 2022/02/10 12:55:56 consumer/broker/1 abandoned subscription to realtime/42 because consuming was taking too long
[sarama] 2022/02/10 12:55:56 consumer/broker/1 added subscription to realtime/42
[sarama] 2022/02/10 12:56:00 consumer/broker/2 abandoned subscription to realtime/46 because consuming was taking too long
[sarama] 2022/02/10 12:56:00 consumer/broker/2 added subscription to realtime/46
license:[sarama] 2022/02/10 12:56:00 consumer/broker/1 abandoned subscription to realtime/33 because consuming was taking too long
[sarama] 2022/02/10 12:56:00 consumer/broker/1 added subscription to realtime/33
[sarama] 2022/02/10 12:56:00 consumer/broker/1 abandoned subscription to realtime/39 because consuming was taking too long
[sarama] 2022/02/10 12:56:00 consumer/broker/1 added subscription to realtime/39
[sarama] 2022/02/10 12:57:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 12:57:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 12:57:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 12:57:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 13:07:01 producer/broker/2 state change to [closing] because write tcp 10.7.12.21:59442->10.7.12.102:9092: write: broken pipe
[sarama] 2022/02/10 13:07:01 producer/leader/realtime/1 state change to [retrying-1]
[sarama] 2022/02/10 13:07:01 producer/leader/realtime/1 abandoning broker 2
[sarama] 2022/02/10 13:07:01 Closed connection to broker 10.7.12.102:9092
[sarama] 2022/02/10 13:07:01 producer/broker/2 closing done
[sarama] 2022/02/10 13:07:01 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:07:01 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 13:07:01 producer/broker/2 starting up
[sarama] 2022/02/10 13:07:01 producer/broker/2 state change to [open] on realtime/1
[sarama] 2022/02/10 13:07:01 producer/leader/realtime/1 selected broker 2
[sarama] 2022/02/10 13:07:01 producer/leader/realtime/1 state change to [flushing-1]
[sarama] 2022/02/10 13:07:01 producer/leader/realtime/1 state change to [normal]
[sarama] 2022/02/10 13:07:01 Connected to broker at 10.7.12.102:9092 (registered as #2)
[sarama] 2022/02/10 13:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:07:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 13:07:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 13:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 13:16:01 producer/broker/3 state change to [closing] because write tcp 10.7.12.21:35342->10.7.12.103:9092: write: broken pipe
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/29 state change to [retrying-1]
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/29 abandoning broker 3
[sarama] 2022/02/10 13:16:01 Closed connection to broker 10.7.12.103:9092
[sarama] 2022/02/10 13:16:01 producer/broker/3 closing done
[sarama] 2022/02/10 13:16:01 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:16:01 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 13:16:01 producer/broker/3 starting up
[sarama] 2022/02/10 13:16:01 producer/broker/3 state change to [open] on realtime/29
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/29 selected broker 3
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/29 state change to [flushing-1]
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/29 state change to [normal]
[sarama] 2022/02/10 13:16:01 Connected to broker at 10.7.12.103:9092 (registered as #3)
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/46 state change to [retrying-1]
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/46 abandoning broker 2
[sarama] 2022/02/10 13:16:01 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/46 selected broker 2
[sarama] 2022/02/10 13:16:01 producer/broker/2 state change to [open] on realtime/46
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/46 state change to [flushing-1]
[sarama] 2022/02/10 13:16:01 producer/leader/realtime/46 state change to [normal]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/25 state change to [retrying-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/25 abandoning broker 2
[sarama] 2022/02/10 13:16:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/25 selected broker 2
[sarama] 2022/02/10 13:16:02 producer/broker/2 state change to [open] on realtime/25
license:[sarama] 2022/02/10 13:16:02 producer/leader/realtime/25 state change to [flushing-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/25 state change to [normal]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/34 state change to [retrying-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/34 abandoning broker 2
[sarama] 2022/02/10 13:16:02 producer/broker/1 state change to [closing] because write tcp 10.7.12.21:49300->10.7.12.101:9092: write: broken pipe
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/39 state change to [retrying-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/39 abandoning broker 1
[sarama] 2022/02/10 13:16:02 Closed connection to broker 10.7.12.101:9092
[sarama] 2022/02/10 13:16:02 producer/broker/1 closing done
[sarama] 2022/02/10 13:16:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/34 selected broker 2
[sarama] 2022/02/10 13:16:02 producer/broker/2 state change to [open] on realtime/34
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/34 state change to [flushing-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/34 state change to [normal]
[sarama] 2022/02/10 13:16:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:16:02 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 13:16:02 producer/broker/1 starting up
[sarama] 2022/02/10 13:16:02 producer/broker/1 state change to [open] on realtime/39
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/39 selected broker 1
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/39 state change to [flushing-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/39 state change to [normal]
[sarama] 2022/02/10 13:16:02 Connected to broker at 10.7.12.101:9092 (registered as #1)
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/27 state change to [retrying-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/27 abandoning broker 1
[sarama] 2022/02/10 13:16:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/27 selected broker 1
[sarama] 2022/02/10 13:16:02 producer/broker/1 state change to [open] on realtime/27
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/27 state change to [flushing-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/27 state change to [normal]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/32 state change to [retrying-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/32 abandoning broker 3
[sarama] 2022/02/10 13:16:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/32 selected broker 3
[sarama] 2022/02/10 13:16:02 producer/broker/3 state change to [open] on realtime/32
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/32 state change to [flushing-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/32 state change to [normal]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/47 state change to [retrying-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/47 abandoning broker 3
[sarama] 2022/02/10 13:16:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/47 selected broker 3
[sarama] 2022/02/10 13:16:02 producer/broker/3 state change to [open] on realtime/47
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/47 state change to [flushing-1]
[sarama] 2022/02/10 13:16:02 producer/leader/realtime/47 state change to [normal]
[sarama] 2022/02/10 13:17:01 producer/leader/realtime/36 state change to [retrying-1]
[sarama] 2022/02/10 13:17:01 producer/leader/realtime/36 abandoning broker 1
[sarama] 2022/02/10 13:17:01 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:17:01 producer/leader/realtime/36 selected broker 1
[sarama] 2022/02/10 13:17:01 producer/broker/1 state change to [open] on realtime/36
[sarama] 2022/02/10 13:17:01 producer/leader/realtime/36 state change to [flushing-1]
[sarama] 2022/02/10 13:17:01 producer/leader/realtime/36 state change to [normal]
[sarama] 2022/02/10 13:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:17:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 13:17:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 13:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 13:26:00 producer/leader/realtime/41 state change to [retrying-1]
[sarama] 2022/02/10 13:26:00 producer/leader/realtime/41 abandoning broker 3
[sarama] 2022/02/10 13:26:00 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:26:00 producer/leader/realtime/41 selected broker 3
[sarama] 2022/02/10 13:26:00 producer/broker/3 state change to [open] on realtime/41
[sarama] 2022/02/10 13:26:00 producer/leader/realtime/41 state change to [flushing-1]
[sarama] 2022/02/10 13:26:00 producer/leader/realtime/41 state change to [normal]
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 state change to [retrying-1]
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 abandoning broker 1
[sarama] 2022/02/10 13:27:04 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 selected broker 1
[sarama] 2022/02/10 13:27:04 producer/broker/1 state change to [open] on realtime/9
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 state change to [flushing-1]
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 state change to [normal]
[sarama] 2022/02/10 13:27:04 producer/broker/1 state change to [closing] because EOF
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 state change to [retrying-2]
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 abandoning broker 1
[sarama] 2022/02/10 13:27:04 producer/broker/1 state change to [closing] because EOF
[sarama] 2022/02/10 13:27:04 Closed connection to broker 10.7.12.101:9092
[sarama] 2022/02/10 13:27:04 producer/broker/1 closing done
[sarama] 2022/02/10 13:27:04 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:27:04 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 13:27:04 producer/broker/1 starting up
[sarama] 2022/02/10 13:27:04 producer/broker/1 state change to [open] on realtime/9
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 selected broker 1
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 state change to [flushing-2]
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 state change to [normal]
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 state change to [retrying-1]
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 abandoning broker 1
[sarama] 2022/02/10 13:27:04 producer/broker/1 input chan closed
[sarama] 2022/02/10 13:27:04 Connected to broker at 10.7.12.101:9092 (registered as #1)
license:[sarama] 2022/02/10 13:27:04 producer/broker/1 shut down
[sarama] 2022/02/10 13:27:04 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:27:04 producer/broker/1 starting up
[sarama] 2022/02/10 13:27:04 producer/broker/1 state change to [open] on realtime/9
[sarama] 2022/02/10 13:27:04 producer/leader/realtime/9 selected broker 1
[sarama] 2022/02/10 13:27:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:27:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 13:27:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 13:27:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 13:36:00 producer/leader/realtime/38 state change to [retrying-1]
[sarama] 2022/02/10 13:36:00 producer/leader/realtime/38 abandoning broker 3
[sarama] 2022/02/10 13:36:00 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:36:00 producer/leader/realtime/38 selected broker 3
[sarama] 2022/02/10 13:36:00 producer/broker/3 state change to [open] on realtime/38
[sarama] 2022/02/10 13:36:00 producer/leader/realtime/38 state change to [flushing-1]
[sarama] 2022/02/10 13:36:00 producer/leader/realtime/38 state change to [normal]
[sarama] 2022/02/10 13:37:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:37:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 13:37:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 13:37:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 13:47:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:47:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 13:47:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 13:47:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 state change to [retrying-1]
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 abandoning broker 2
[sarama] 2022/02/10 13:56:00 consumer/broker/2 abandoned subscription to realtime/43 because consuming was taking too long
[sarama] 2022/02/10 13:56:00 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 selected broker 2
[sarama] 2022/02/10 13:56:00 producer/broker/2 state change to [open] on realtime/37
[sarama] 2022/02/10 13:56:00 producer/broker/2 state change to [closing] because write tcp 10.7.12.21:58712->10.7.12.102:9092: write: broken pipe
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 state change to [flushing-1]
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 state change to [normal]
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 state change to [retrying-2]
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 abandoning broker 2
[sarama] 2022/02/10 13:56:00 Closed connection to broker 10.7.12.102:9092
[sarama] 2022/02/10 13:56:00 producer/broker/2 closing done
[sarama] 2022/02/10 13:56:00 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:56:00 ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2022/02/10 13:56:00 producer/broker/2 starting up
[sarama] 2022/02/10 13:56:00 producer/broker/2 state change to [open] on realtime/37
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 selected broker 2
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 state change to [flushing-2]
[sarama] 2022/02/10 13:56:00 producer/leader/realtime/37 state change to [normal]
[sarama] 2022/02/10 13:56:00 Connected to broker at 10.7.12.102:9092 (registered as #2)
[sarama] 2022/02/10 13:56:02 producer/leader/realtime/44 state change to [retrying-1]
[sarama] 2022/02/10 13:56:02 producer/leader/realtime/44 abandoning broker 3
[sarama] 2022/02/10 13:56:02 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:57:01 producer/leader/realtime/34 state change to [retrying-1]
[sarama] 2022/02/10 13:57:01 producer/leader/realtime/34 abandoning broker 2
[sarama] 2022/02/10 13:57:01 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:57:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 13:57:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 13:57:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 13:57:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 14:07:00 consumer/broker/2 abandoned subscription to realtime/46 because consuming was taking too long
[sarama] 2022/02/10 14:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 14:07:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 14:07:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 14:07:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 14:11:00 consumer/broker/2 abandoned subscription to realtime/28 because consuming was taking too long
[sarama] 2022/02/10 14:11:00 consumer/broker/2 abandoned subscription to realtime/31 because consuming was taking too long
[sarama] 2022/02/10 14:12:00 consumer/broker/1 abandoned subscription to realtime/27 because consuming was taking too long
[sarama] 2022/02/10 14:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.102:9092
[sarama] 2022/02/10 14:17:56 client/metadata fetching metadata for all topics from broker 172.17.133.193:9092
[sarama] 2022/02/10 14:17:56 client/metadata fetching metadata for all topics from broker 10.7.22.80:9092
[sarama] 2022/02/10 14:17:56 client/metadata fetching metadata for all topics from broker 10.7.12.103:9092
[sarama] 2022/02/10 14:22:00 consumer/broker/2 abandoned subscription to realtime/25 because consuming was taking too long
[sarama] 2022/02/10 14:26:00 consumer/broker/3 abandoned subscription to realtime/32 because consuming was taking too long
[sarama] 2022/02/10 14:26:00 consumer/broker/1 abandoned subscription to realtime/39 because consuming was taking too long
[sarama] 2022/02/10 14:26:04 producer/leader/realtime/26 state change to [retrying-1]
[sarama] 2022/02/10 14:26:04 producer/leader/realtime/26 abandoning broker 3
[sarama] 2022/02/10 14:26:04 client/metadata fetching metadata for [realtime] from broker 10.7.12.102:9092
[sarama] 2022/02/10 14:27:00 consumer/broker/1 abandoned subscription to realtime/24 because consuming was taking too long
[sarama] 2022/02/10 14:27:00 consumer/broker/2 abandoned subscription to realtime/37 because consuming was taking too long
[sarama] 2022/02/10 14:27:00 consumer/broker/3 abandoned subscription to realtime/41 because consuming was taking too long
[sarama] 2022/02/10 14:27:00 consumer/broker/1 abandoned subscription to realtime/36 because consuming was taking too long
[sarama] 2022/02/10 14:27:00 consumer/broker/3 abandoned subscription to realtime/35 because consuming was taking too long