Wie Kafka Bootstrap-Konfigurationseinstellung von Kafka Anschluss

Frage für Kafka Experten:Wie Kafka Bootstrap-Konfigurationseinstellung von Kafka Anschluss

Jeder weiß, wie Arbeiterkonfigurationseinstellung ‚bootstrap.servers‘ erhalten entweder von SinkConnector oder SinkTask? Oder wie man Kafka Cluster Informationen vom Connector bekommt?

Danke

Quelle

2017-03-03 Val Miscenko

AFAIK, wird die Connect-API diese Informationen jetzt nicht geben. Wenn Sie diese Funktionalität benötigen, ist es am besten, wenn Sie eine JIRA-Datei für das Apache Kafka-Projekt öffnen und den Anwendungsfall erläutern (d. H. Was planen Sie, diese Informationen zu erstellen).

Quelle

2017-03-04 01:51:44

Danke, Gwen, für Ihre Antwort. Der Anwendungsfall ist ziemlich einfach, einige Nachrichten an das Fehlerthema umzuleiten. Im Moment besteht meine Problemumgehung darin, eine zusätzliche Einstellung für den Producer einzurichten, die einige Nachrichten an das Fehlerthema weiterleitet (zum Beispiel wenn ein SQL-Fehler auftritt). –

Ah, hab es! Wir arbeiten daran, die Fehlerbehandlung direkt in das Framework zu integrieren, sodass Sie dies nicht im Connector tun müssen. –

Super! Es wäre großartig, diese Funktionalität zu haben. –

Wie Kafka Bootstrap-Konfigurationseinstellung von Kafka Anschluss

Antwort

Verwandte Themen