C0urante commented on a change in pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#discussion_r431434538
##########
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##########
@@ -695,6 +705,32 @@ ErrorHandlingMetrics errorHandlingMetrics(ConnectorTaskId
id) {
return reporters;
}
+ private WorkerErrantRecordReporter createWorkerErrantRecordReporter(
+ ConnectorTaskId id,
+ SinkConnectorConfig connConfig,
+ Class<? extends Connector> connectorClass,
+ Converter keyConverter,
+ Converter valueConverter,
+ HeaderConverter headerConverter
+ ) {
+ // check if errant record reporter topic is configured
+ String topic = connConfig.dlqTopicName();
+ if ((topic != null && !topic.isEmpty()) ||
connConfig.enableErrorLog()) {
Review comment:
The `SinkConnectorConfig` class isn't part of the public API; we can
modify it without a KIP if we want.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
