Comment obtenir les paramètres de configuration d'amorçage Kafka du connecteur Kafka

Question pour les experts Kafka:Comment obtenir les paramètres de configuration d'amorçage Kafka du connecteur Kafka

Tout le monde sait comment obtenir le paramètre de configuration du travailleur « bootstrap.servers » soit à partir SinkConnector ou SinkTask? Ou comment obtenir des informations de cluster Kafka à partir du connecteur?

Merci

Source

2017-03-03 Val Miscenko

AFAIK, Connect API ne fournit pas ces informations en ce moment. Si vous avez besoin de cette fonctionnalité, le mieux est peut-être d'ouvrir une JIRA sur le projet Apache Kafka et d'expliquer le cas d'utilisation (c'est-à-dire que prévoyez-vous de faire cette information).

Source

2017-03-04 01:51:44

Merci, Gwen, pour votre réponse. Le cas d'utilisation est assez simple pour rediriger certains messages vers le sujet d'erreur. Pour le moment, ma solution de contournement consiste à définir des paramètres supplémentaires pour le producteur qui transmet certains messages à la rubrique d'erreur (par exemple, lorsqu'une erreur SQL se produit). –

Ah, compris! Nous travaillons sur la gestion des erreurs directement dans le framework, donc vous n'avez pas besoin de le faire dans le connecteur. –

Génial! Ce serait génial d'avoir cette fonctionnalité. –

Comment obtenir les paramètres de configuration d'amorçage Kafka du connecteur Kafka

Répondre

Questions connexes