Denna artikel är en spegelartikel om maskinöversättning, klicka här för att hoppa till originalartikeln.

Architect_Programmer_Code Jordbruksnätverket»Arkitekt › Programmering › Java › Spring Boot ställer dynamiskt in Kafkas ämne eller GroupId
Utsikt: 21474|Svar: 0

[Källa] Spring Boot ställer dynamiskt in Kafkas ämne eller GroupId

[Kopiera länk]
Publicerad på 2021-11-14 20:03:45 | | | |
När vi distribuerar mikrotjänster i ett kluster, om vi vill ge kommandon till alla applikationer, kan vi prenumerera applikationerna på Kafka-ämnen, men det bör noteras att olika grupp-ID:n måste sättas för att samma ämne ska tas emot av alla applikationer.

Använd docker för att bygga en Kafka-applikation med följande kommandon:

Obs: Byt ut 192.168.1.166 mot din faktiska IP-adress

pom.xml Introducera fjäder-kafka-paketet enligt följande:


För att anpassa Kafka-konsumentkonfigurationen, skapa en ny KafkaConsumer-fil enligt följande:


Skapa en ny konsument-ConfigConsumer, som har standardkonfigurationen: topic:defaultTopic,groupid:defaultGroupId, och koden är följande:

application.properties för att konfigurera adressen till Kafka:


För att starta ett projekt är appprenumerationen standardkonfigurationen, enligt följande:



KafkaMessageListenerContainer ärver abstraktklassen AbstractMessageListenerContainer, och metoden createSimpleLoggingConsumerRebalanceListener ger ut konsumentens groupid och ämne, partition.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitioner tilldelade: [defaultTopic-0]
Sätt dynamiskt topic och groupid, och projektstartkommandot är följande:



Ämnet är satt till a1 och gruppid är itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partitioner tilldelade: [a1-0]
Spring åsidosätter standardkonfigurationen i jar-paketet
https://www.itsvse.com/thread-10129-1-1.html

(Slut)





Föregående:Långsamma frågor för MySQL-prestandaoptimering
Nästa:Spring Boot Kafka startar om för att kassera gammal data

Relaterade inlägg
Friskrivning:
All programvara, programmeringsmaterial eller artiklar som publiceras av Code Farmer Network är endast för lärande- och forskningsändamål; Ovanstående innehåll får inte användas för kommersiella eller olagliga ändamål, annars kommer användarna att bära alla konsekvenser. Informationen på denna sida kommer från internet, och upphovsrättstvister har inget med denna sida att göra. Du måste helt radera ovanstående innehåll från din dator inom 24 timmar efter nedladdning. Om du gillar programmet, vänligen stöd äkta programvara, köp registrering och få bättre äkta tjänster. Om det finns något intrång, vänligen kontakta oss via e-post.
Mail To:help@itsvse.com