[jira] [Updated] (KAFKA-4176) Node stopped receiving heartbeat responses once another node started within the same group
[ https://issues.apache.org/jira/browse/KAFKA-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4176: --- Fix Version/s: (was: 0.10.1.1) 0.10.1.0 > Node stopped receiving heartbeat responses once another node started within > the same group > -- > > Key: KAFKA-4176 > URL: https://issues.apache.org/jira/browse/KAFKA-4176 > Project: Kafka > Issue Type: Bug > Components: consumer >Affects Versions: 0.10.0.1 > Environment: Centos 7: 3.10.0-229.el7.x86_64 #1 SMP Fri Mar 6 > 11:36:42 UTC 2015 x86_64 x86_64 x86_64 GNU/Linux > Java: java version "1.8.0_101" > Java(TM) SE Runtime Environment (build 1.8.0_101-b13) > Java HotSpot(TM) 64-Bit Server VM (build 25.101-b13, mixed mode) >Reporter: Marek Svitok >Assignee: Guozhang Wang > Fix For: 0.10.1.0, 0.10.2.0 > > > I have 3 nodes working in the same group. I started them one after the other. > As I can see from the log the node once started receives heartbeat responses > for the group it is part of. However once I start another node the former one > stops receiving these responses and the new one keeps receiving them. > Moreover it stops consuming any messages from previously assigner partitions: > Node0 > 03:14:36.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.223 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.429 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30170 after 0ms > 03:14:39.462 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30171 after 0ms > 03:14:42.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:42.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:45.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:45.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:48.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Attempt > to heart beat failed for group test_streams_id since it is rebalancing. > 03:14:48.224 [StreamThread-2] INFO o.a.k.c.c.i.ConsumerCoordinator - > Revoking previously assigned partitions [StreamTopic-2] for group > test_streams_id > 03:14:48.224 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - > Removing a task 0_2 > Node1 > 03:22:18.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:18.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:21.709 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:21.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.872 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30172 after 0ms > 03:22:24.992 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30173 after 0ms > 03:22:27.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:27.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:30.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:30.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > Configuration used: > 03:14:24.520 [main] INFO o.a.k.c.producer.ProducerConfig - Pr
[jira] [Updated] (KAFKA-4176) Node stopped receiving heartbeat responses once another node started within the same group
[ https://issues.apache.org/jira/browse/KAFKA-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-4176: Priority: Major (was: Blocker) > Node stopped receiving heartbeat responses once another node started within > the same group > -- > > Key: KAFKA-4176 > URL: https://issues.apache.org/jira/browse/KAFKA-4176 > Project: Kafka > Issue Type: Bug > Components: consumer >Affects Versions: 0.10.0.1 > Environment: Centos 7: 3.10.0-229.el7.x86_64 #1 SMP Fri Mar 6 > 11:36:42 UTC 2015 x86_64 x86_64 x86_64 GNU/Linux > Java: java version "1.8.0_101" > Java(TM) SE Runtime Environment (build 1.8.0_101-b13) > Java HotSpot(TM) 64-Bit Server VM (build 25.101-b13, mixed mode) >Reporter: Marek Svitok > > I have 3 nodes working in the same group. I started them one after the other. > As I can see from the log the node once started receives heartbeat responses > for the group it is part of. However once I start another node the former one > stops receiving these responses and the new one keeps receiving them. > Moreover it stops consuming any messages from previously assigner partitions: > Node0 > 03:14:36.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.223 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.429 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30170 after 0ms > 03:14:39.462 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30171 after 0ms > 03:14:42.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:42.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:45.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:45.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:48.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Attempt > to heart beat failed for group test_streams_id since it is rebalancing. > 03:14:48.224 [StreamThread-2] INFO o.a.k.c.c.i.ConsumerCoordinator - > Revoking previously assigned partitions [StreamTopic-2] for group > test_streams_id > 03:14:48.224 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - > Removing a task 0_2 > Node1 > 03:22:18.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:18.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:21.709 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:21.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.872 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30172 after 0ms > 03:22:24.992 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30173 after 0ms > 03:22:27.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:27.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:30.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:30.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > Configuration used: > 03:14:24.520 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig > values: > metric.reporters = [] > metadata.max.age.ms = 30 > reconnect.
[jira] [Updated] (KAFKA-4176) Node stopped receiving heartbeat responses once another node started within the same group
[ https://issues.apache.org/jira/browse/KAFKA-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marek Svitok updated KAFKA-4176: Priority: Blocker (was: Critical) > Node stopped receiving heartbeat responses once another node started within > the same group > -- > > Key: KAFKA-4176 > URL: https://issues.apache.org/jira/browse/KAFKA-4176 > Project: Kafka > Issue Type: Bug > Components: consumer >Affects Versions: 0.10.0.1 > Environment: Centos 7: 3.10.0-229.el7.x86_64 #1 SMP Fri Mar 6 > 11:36:42 UTC 2015 x86_64 x86_64 x86_64 GNU/Linux > Java: java version "1.8.0_101" > Java(TM) SE Runtime Environment (build 1.8.0_101-b13) > Java HotSpot(TM) 64-Bit Server VM (build 25.101-b13, mixed mode) >Reporter: Marek Svitok >Priority: Blocker > > I have 3 nodes working in the same group. I started them one after the other. > As I can see from the log the node once started receives heartbeat responses > for the group it is part of. However once I start another node the former one > stops receiving these responses and the new one keeps receiving them. > Moreover it stops consuming any messages from previously assigner partitions: > Node0 > 03:14:36.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.223 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.429 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30170 after 0ms > 03:14:39.462 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30171 after 0ms > 03:14:42.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:42.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:45.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:45.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:48.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Attempt > to heart beat failed for group test_streams_id since it is rebalancing. > 03:14:48.224 [StreamThread-2] INFO o.a.k.c.c.i.ConsumerCoordinator - > Revoking previously assigned partitions [StreamTopic-2] for group > test_streams_id > 03:14:48.224 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - > Removing a task 0_2 > Node1 > 03:22:18.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:18.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:21.709 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:21.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.872 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30172 after 0ms > 03:22:24.992 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30173 after 0ms > 03:22:27.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:27.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:30.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:30.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > Configuration used: > 03:14:24.520 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig > values: > metric.reporters = [] > metadata.max.
[jira] [Updated] (KAFKA-4176) Node stopped receiving heartbeat responses once another node started within the same group
[ https://issues.apache.org/jira/browse/KAFKA-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marek Svitok updated KAFKA-4176: Priority: Critical (was: Major) > Node stopped receiving heartbeat responses once another node started within > the same group > -- > > Key: KAFKA-4176 > URL: https://issues.apache.org/jira/browse/KAFKA-4176 > Project: Kafka > Issue Type: Bug > Components: consumer >Affects Versions: 0.10.0.1 > Environment: Centos 7: 3.10.0-229.el7.x86_64 #1 SMP Fri Mar 6 > 11:36:42 UTC 2015 x86_64 x86_64 x86_64 GNU/Linux > Java: java version "1.8.0_101" > Java(TM) SE Runtime Environment (build 1.8.0_101-b13) > Java HotSpot(TM) 64-Bit Server VM (build 25.101-b13, mixed mode) >Reporter: Marek Svitok >Priority: Critical > > I have 3 nodes working in the same group. I started them one after the other. > As I can see from the log the node once started receives heartbeat responses > for the group it is part of. However once I start another node the former one > stops receiving these responses and the new one keeps receiving them. > Moreover it stops consuming any messages from previously assigner partitions: > Node0 > 03:14:36.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.223 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:39.429 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30170 after 0ms > 03:14:39.462 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30171 after 0ms > 03:14:42.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:42.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:45.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:45.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:14:48.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Attempt > to heart beat failed for group test_streams_id since it is rebalancing. > 03:14:48.224 [StreamThread-2] INFO o.a.k.c.c.i.ConsumerCoordinator - > Revoking previously assigned partitions [StreamTopic-2] for group > test_streams_id > 03:14:48.224 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - > Removing a task 0_2 > Node1 > 03:22:18.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:18.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:21.709 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:21.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:24.872 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30172 after 0ms > 03:22:24.992 [main-SendThread(mujsignal-03:2182)] DEBUG > org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: > 0x256bc1ce8c30173 after 0ms > 03:22:27.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:27.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:30.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > 03:22:30.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - > Received successful heartbeat response for group test_streams_id > Configuration used: > 03:14:24.520 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig > values: > metric.reporters = [] > metadata.max.a
[jira] [Updated] (KAFKA-4176) Node stopped receiving heartbeat responses once another node started within the same group
[ https://issues.apache.org/jira/browse/KAFKA-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marek Svitok updated KAFKA-4176: Description: I have 3 nodes working in the same group. I started them one after the other. As I can see from the log the node once started receives heartbeat responses for the group it is part of. However once I start another node the former one stops receiving these responses and the new one keeps receiving them. Moreover it stops consuming any messages from previously assigner partitions: Node0 03:14:36.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:14:39.223 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:14:39.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:14:39.429 [main-SendThread(mujsignal-03:2182)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x256bc1ce8c30170 after 0ms 03:14:39.462 [main-SendThread(mujsignal-03:2182)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x256bc1ce8c30171 after 0ms 03:14:42.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:14:42.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:14:45.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:14:45.224 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:14:48.224 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Attempt to heart beat failed for group test_streams_id since it is rebalancing. 03:14:48.224 [StreamThread-2] INFO o.a.k.c.c.i.ConsumerCoordinator - Revoking previously assigned partitions [StreamTopic-2] for group test_streams_id 03:14:48.224 [StreamThread-2] INFO o.a.k.s.p.internals.StreamThread - Removing a task 0_2 Node1 03:22:18.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:18.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:21.709 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:21.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:24.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:24.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:24.872 [main-SendThread(mujsignal-03:2182)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x256bc1ce8c30172 after 0ms 03:22:24.992 [main-SendThread(mujsignal-03:2182)] DEBUG org.apache.zookeeper.ClientCnxn - Got ping response for sessionid: 0x256bc1ce8c30173 after 0ms 03:22:27.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:27.717 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:30.710 [StreamThread-2] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id 03:22:30.716 [StreamThread-1] DEBUG o.a.k.c.c.i.AbstractCoordinator - Received successful heartbeat response for group test_streams_id Configuration used: 03:14:24.520 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig values: metric.reporters = [] metadata.max.age.ms = 30 reconnect.backoff.ms = 50 sasl.kerberos.ticket.renew.window.factor = 0.8 bootstrap.servers = [mujsignal-03:9092, mujsignal-09:9093] ssl.keystore.type = JKS sasl.mechanism = GSSAPI max.block.ms = 6 interceptor.classes = null ssl.truststore.password = null client.id = Test-Streams-Processor-StreamThread-2-producer ssl.endpoint.identification.algorithm = null request.timeout.ms = 3 acks = 1 receive.buffer.bytes = 32768 ssl.truststore.type = JKS retries = 0 ssl.truststore.location = null ssl.keystore.password = null send.buffer.bytes = 131072 compression.type = none metadata.fetch.timeout.ms = 6 retry.backoff.ms = 100 sasl.kerberos.kinit.cmd = /usr/bin/kinit buffer.memory = 33554432 tim
