Olá. Estou tentando criar um serviço de mensageria. Porém fiquei na dúvida de como eu faço pra filtrar para qual pessoa mandar a notificação.
Pois posso ter um grupo, mandar individualmente ou selecionar várias pessoas para eu mandar a notificação.
Eu filtraria isso via código de projeto ou tenho que ter alguma configuração no kafka para o consumer entender que aquele serviço é pra ele ouvir?
O Kafka não suporta a capacidade de filtragem de mensagens para os consumidores. Se um consumidor precisar ouvir um subconjunto de mensagens publicadas em um tópico do Kafka, ele precisará ler tudo e filtrar apenas o necessário. Isso é ineficiente, pois todas as mensagens devem ser desserializadas e tomar essa decisão. Para fazer isso você vai precisar utilizar o Kafka Streams: http://kafka.apache.org/documentation.html#streamsapi