Поэтому я использую alpakka-kafka, и моя проблема в том, что когда я запускаю свой потребительский поток kafka, после использования некоторых записей AbstractCoordinator отправляет запрос LeaveGroup координатору, а затем Consumer останавливается, почему это происходит?
[DEBUG] [08/01/2020 13:58:34] [] o.a.k.c.c.i.AbstractCoordinator | [Consumer clientId=consumer-1, groupId=product-projector] Sending Heartbeat request to coordinator 10.48.2.82:9092 (id: 2147483645 rack: null)
[DEBUG] [08/01/2020 13:58:34] [] o.a.k.c.c.KafkaConsumer | [Consumer clientId=consumer-1, groupId=product-projector] Pausing partitions [microloan.loan-product.snapshot-0]
[DEBUG] [08/01/2020 13:58:34] [] o.a.k.c.c.i.AbstractCoordinator | [Consumer clientId=consumer-1, groupId=product-projector] Received successful Heartbeat response
[DEBUG] [08/01/2020 13:58:35] [] o.a.k.c.c.KafkaConsumer | [Consumer clientId=consumer-1, groupId=product-projector] Pausing partitions [microloan.loan-product.snapshot-0]
[DEBUG] [08/01/2020 13:58:36] [] o.a.k.c.c.KafkaConsumer | [Consumer clientId=consumer-1, groupId=product-projector] Pausing partitions [microloan.loan-product.snapshot-0]
[DEBUG] [08/01/2020 13:58:37] [] o.a.k.c.c.i.AbstractCoordinator | [Consumer clientId=consumer-1, groupId=product-projector] Sending Heartbeat request to coordinator 10.48.2.82:9092 (id: 2147483645 rack: null)
[DEBUG] [08/01/2020 13:58:37] [] o.a.k.c.c.KafkaConsumer | [Consumer clientId=consumer-1, groupId=product-projector] Pausing partitions [microloan.loan-product.snapshot-0]
[DEBUG] [08/01/2020 13:58:37] [] o.a.k.c.c.i.AbstractCoordinator | [Consumer clientId=consumer-1, groupId=product-projector] Received successful Heartbeat response
[DEBUG] [08/01/2020 13:58:38] [] o.a.k.c.c.KafkaConsumer | [Consumer clientId=consumer-1, groupId=product-projector] Pausing partitions [microloan.loan-product.snapshot-0]
[DEBUG] [08/01/2020 13:58:39] [] o.a.k.c.c.KafkaConsumer | [Consumer clientId=consumer-1, groupId=product-projector] Pausing partitions [microloan.loan-product.snapshot-0]
[DEBUG] [08/01/2020 13:58:40] [] o.a.k.c.c.i.AbstractCoordinator | [Consumer clientId=consumer-1, groupId=product-projector] Heartbeat thread has closed
[INFO ] [08/01/2020 13:58:40] [] o.a.k.c.c.i.AbstractCoordinator | [Consumer clientId=consumer-1, groupId=product-projector] Sending LeaveGroup request to coordinator 10.48.2.82:9092 (id: 2147483645 rack: null)
[DEBUG] [08/01/2020 13:58:40] [] o.a.k.c.c.i.AbstractCoordinator | [Consumer clientId=consumer-1, groupId=product-projector] LeaveGroup request returned successfully
[DEBUG] [08/01/2020 13:58:40] [] o.a.k.c.c.KafkaConsumer | [Consumer clientId=consumer-1, groupId=product-projector] Kafka consumer has been closed