AHeise commented on a change in pull request #16769:
URL: https://github.com/apache/flink/pull/16769#discussion_r687689560
##########
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaWriter.java
##########
@@ -376,6 +378,11 @@ private void
initMetrics(FlinkKafkaInternalProducer<byte[], byte[]> producer) {
others,
kafkaSinkContext.getNumberOfParallelInstances())) {
return log.getTransactionsToAbort();
+ } catch (KafkaException e) {
+ LOG.warn(
+ "Cannot abort transactions before startup this might leave
lingering transactions from previous executions.",
Review comment:
I'd still give a pointer to the ACLs because it's not so obvious. But
I'd also add the possibility of temporary Kafka problems as you have said. It's
a log that is only emitted during recovery, so it can be more verbose.
(although it will appear for each subtask)
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
