Podczas wdrażania mikroserwisów w klastrze, jeśli chcemy wydać polecenia wszystkim aplikacjom, możemy subskrybować aplikacje do tematów Kafki, ale należy zauważyć, że dla wszystkich aplikacji ten sam temat musi być ustawiony różne groupID.
Użyj Dockera do zbudowania aplikacji Kafka za pomocą następujących poleceń:
Uwaga: Zastąp 192.168.1.166 swoim rzeczywistym adresem IP
pom.xml Wprowadź pakiet spring-kafka w następujący sposób:
Aby dostosować konfigurację konsumencką Kafka, utwórz nowy plik KafkaConsumer w następujący sposób:
Utwórz nowego konsumenckiego ConfigConsumer, który ma domyślną konfigurację: topic:defaultTopic,groupid:defaultGroupId, a kod jest następujący:
application.properties do skonfigurowania adresu Kafki:
Aby rozpocząć projekt, subskrypcja aplikacji jest domyślnie skonfigurowana, jak następuje:
KafkaMessageListenerContainer dziedziczy abstrakcyjną klasę AbstractMessageListenerContainer, a metoda createSimpleLoggingConsumerRebalanceListener generuje grupid i temat użytkownika jako partycję.
2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: przypisane partycje: [defaultTopic-0]
Temat jest ustawiony na a1, a grupid to itsvse.com
2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partycje przypisane: [a1-0]
(Koniec)
|
Opublikowano 14.11.2021 20:03:45
|
|
|
|
