Este artigo é um artigo espelhado de tradução automática, por favor clique aqui para ir para o artigo original.

Architect_Programmer_Code Rede Agrícola»Arquiteto › Programação › Java › O Spring Boot define dinamicamente o Topic ou GroupId de Kafka
Vista: 21474|Resposta: 0

[Fonte] O Spring Boot define dinamicamente o Topic ou GroupId de Kafka

[Copiar link]
Publicado em 14/11/2021 20:03:45 | | | |
Ao implantar microserviços em um cluster, se quisermos emitir comandos para todas as aplicações, podemos assinar as aplicações para tópicos Kafka, mas deve-se notar que diferentes groupIDs precisam ser definidos para que o mesmo tópico seja recebido por todas as aplicações.

Use o docker para construir uma aplicação Kafka com os seguintes comandos:

Nota: Substitua 192.168.1.166 pelo seu endereço IP real

pom.xml Introduza o pacote spring-kafka da seguinte forma:


Para personalizar a configuração do Kafka Consumer, crie um novo arquivo KafkaConsumer da seguinte forma:


Crie um novo ConfigConsumer para consumidores, que tenha a configuração padrão: topic:defaultTopic,groupid:defaultGroupId, e o código é o seguinte:

application.properties para configurar o endereço de Kafka:


Para iniciar um projeto, a assinatura do aplicativo é a configuração padrão, da seguinte forma:



KafkaMessageListenerContainer herda a classe abstrata AbstractMessageListenerContainer, e o método createSimpleLoggingConsumerRebalanceListener gera a partição groupid e topic, do consumidor.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageMessageListenerContainer : defaultGroupId: partições atribuídas: [defaultTopic-0]
Defina dinamicamente o tópico e o groupid, e o comando início do projeto é o seguinte:



O tema está definido como a1 e o groupid é itsvse.com

2021-11-14 19:46:25.330 INFORMAÇÕES 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partições atribuídas: [a1-0]
O Spring sobrepõe a configuração padrão dentro do pacote jar
https://www.itsvse.com/thread-10129-1-1.html

(Fim)





Anterior:Consultas lentas para otimização de desempenho em MySQL
Próximo:O Spring Boot Kafka reinicia para descartar dados antigos

Posts Relacionados
Disclaimer:
Todo software, material de programação ou artigos publicados pela Code Farmer Network são apenas para fins de aprendizado e pesquisa; O conteúdo acima não deve ser usado para fins comerciais ou ilegais, caso contrário, os usuários terão todas as consequências. As informações deste site vêm da Internet, e disputas de direitos autorais não têm nada a ver com este site. Você deve deletar completamente o conteúdo acima do seu computador em até 24 horas após o download. Se você gosta do programa, por favor, apoie um software genuíno, compre o registro e obtenha serviços genuínos melhores. Se houver qualquer infração, por favor, entre em contato conosco por e-mail.
Mail To:help@itsvse.com