Solucionado (ver solução)
Solucionado
(ver solução)
1
resposta

LogService não conectou em nenhuma partição

Segui o passo a passo da aula, porém o LogService não imprimiu nenhuma das mensagens produzidas.

O log gerado é o abaixo:

15:09:18.685 [main] INFO  o.a.k.clients.consumer.KafkaConsumer - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] Subscribed to pattern: 'ECOMMERCE_*'
15:09:19.510 [main] INFO  org.apache.kafka.clients.Metadata - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] Cluster ID: nA-A0EjKRaOaw38vCgA7Yw
15:09:19.517 [main] INFO  o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] Discovered group coordinator MGA10340.db1.com.br:9092 (id: 2147483647 rack: null)
15:09:19.526 [main] INFO  o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] (Re-)joining group
15:09:19.543 [main] INFO  o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group.
15:09:19.543 [main] INFO  o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] (Re-)joining group
15:09:19.552 [main] INFO  o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] Finished assignment for group at generation 1: {LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d-79491849-1e08-4fef-8bc5-f118437e8261=Assignment(partitions=[])}
15:09:19.560 [main] INFO  o.a.k.c.c.i.AbstractCoordinator - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] Successfully joined group with generation 1
15:09:19.561 [main] INFO  o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] Notifying assignor about the new Assignment(partitions=[])
15:09:19.561 [main] INFO  o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=LogService_f8df0e54-10bc-4738-b1dc-da44a6bfdd3d, groupId=LogService] Adding newly assigned partitions: 
1 resposta
solução!

O copy/paste acabou me aplicando uma pegadinha, pois usei "ECOMMERCE_*" e não "ECOMMERCE.*" no pattern.