Mám nastavenie aplikácie Spring Boot na príjem správ Kafky od existujúceho a pracujúceho producenta Kafka. Nastavenie je štandardné a je založené na nasledujúcich skutočnostiach: https://www.codenotfound.com/spring-kafka-consumer-producer-example.html
Správy sa neprijímajú a v konzole sa zobrazuje priebežne:
WARN org.apache.clients.NetworkClient :Bootstrap broker <hostname>:9092 disconnected
Okrem toho je zaznamenaná nasledujúca ladiaca správa:
org.apache.common.errors.Timeout: Failed to update metadata after 60000 ms.
Správa o konzole sa preberá na nasledujúcom odkazu: https://community.hortonworks.com/content/supportkb/150148/errorwarn-bootstrap-broker-6668-disconnected-orgap.html
Zaznamenaná správa je tu diskutovaná: https://community.cloudera.com/t5/Data-Ingestion-Integration/Error-when-sending-message-to-topic-in-Kafka/td-p/41440
Je pravdepodobné, že časový limit sa nestane po vyriešení prvého problému.
Riešenie správy konzoly, ktorá je daná, má explicitne prejsť --security-protocol SSL ako argument pre výrobcu alebo spotrebiteľské velenie.
Vzhľadom na to, že počúvam na existujúceho makléra a tému Kafka, tam nie je možné meniť žiadne nastavenia. Akékoľvek zmeny musia byť na strane "Spring Boot".
Je možné konfigurovať application.yml tak to --security-protocol SSL je pre spotrebiteľa predložený argument? Tiež to niekto zažil už predtým a existuje iný spôsob, ako vyriešiť problém pomocou konfiguračných možností dostupných v programe Spring Boot a Spring Kafka?
Vďaka
odpovede:
1 pre odpoveď č. 1vidieť dokumentáciu.
Prejdite nadol na Kafku. Vlastné vlastnosti Kafky je možné nastaviť pomocou
spring:
kafka:
properties:
security.protocol: SSL
vzťahuje sa na spotrebiteľov a výrobcov (a administrátorov v 2.0).
V nadchádzajúcom vydaní 2.0 (v súčasnosti RC1) je tiež
spring:
kafka:
properties:
consumer:
some.property: foo
pre vlastnosti, ktoré sa vzťahujú iba na spotrebiteľov (a podobne pre výrobcov a administrátorov).