Spring Kafka Consumer Client-ID-Konfiguration

Ich bin dort, wo ich zwei Kafka-Listener-Komponenten habe, die jeweils einem anderen Thema zuhören und eine andere Nutzlast erwarten. Meine Frage ist, kann ich die gleiche Client-ID für beide verwenden oder muss es anders sein? Wenn die Client-ID anders sein muss, möchte ich einen Anwendungsfall verstehen, in dem die Client-ID effektiv verwendet werden kann.Spring Kafka Consumer Client-ID-Konfiguration

Quelle

2017-07-18 A_De

Nach der Dokumentation:

eine ID-Zeichenfolge an den Server zu übergeben, wenn Anfragen. Dies dient dazu, die Quelle von Anforderungen über ip/port hinaus verfolgen zu können, indem ein logischer Anwendungsname in die serverseitige Anforderungsprotokollierung aufgenommen wird.

Also, technisch wirklich Sie können den gleichen Wert haben für verschiedene Verbraucher/Hersteller

Quelle

2017-07-18 17:53:31

Hallo, Danke für die Antwort. Spring-Kafka zwingt mich jedoch dazu, für meine beiden Kafka-Hörer unterschiedliche client-ids zu verwenden, da es besagt, dass es einzigartig sein muss. –

Erzeugt einen Fehler "Ein anderer Endpunkt ist bereits mit ID registriert" in der Klasse KafkaListenerEndpointRegistry (Zeile 152) –

'@ KafkaListener.id()'? Siehst du irgendwo einen Zeiger, dass diese Bean-ID der "Client-ID" zugeordnet ist? Sie sollten 'ConsumerConfig.CLIENT_ID_CONFIG' direkt verwenden. –

Spring Kafka Consumer Client-ID-Konfiguration

Antwort

Verwandte Themen