[jira] [Assigned] (FLINK-39854) Log JobID in KafkaCommitter

["Roman Khachatryan (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-39854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Roman Khachatryan reassigned FLINK-39854:
-----------------------------------------

    Assignee: Aleksandr Savonin

> Log JobID in KafkaCommitter
> ---------------------------
>
>                 Key: FLINK-39854
>                 URL: https://issues.apache.org/jira/browse/FLINK-39854
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Kafka
>            Reporter: Aleksandr Savonin
>            Assignee: Aleksandr Savonin
>            Priority: Minor
>
> We have multiple logs in {{KafkaCommitter}} that will benefit from having {{JobId}} in the logs. 
> E.g.
> {code:java}
> LOG.warn(
>         "Unable to commit transaction ({}) because its producer is already fenced."
>                 + " If this warning appears as part of the recovery of a checkpoint, it is expected in some cases (e.g., aborted checkpoints in previous attempt)."
>                 + " If it's outside of recovery, this means that you either have a different sink with the same '{}'"
>                 + " or recovery took longer than '{}' ({}ms). In both cases this most likely signals data loss,"
>                 + " please consult the Flink documentation for more details.",
>         request,
>         ProducerConfig.TRANSACTIONAL_ID_CONFIG,
>         ProducerConfig.TRANSACTION_TIMEOUT_CONFIG,
>         kafkaProducerConfig.getProperty(ProducerConfig.TRANSACTION_TIMEOUT_CONFIG),
>         e); {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)