[
https://issues.apache.org/jira/browse/FLINK-39856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-39856:
-----------------------------------------
Assignee: Aleksandr Savonin
> Auto-derive a default transactionalIdPrefix for EXACTLY_ONCE from JobID when
> unset
> ----------------------------------------------------------------------------------
>
> Key: FLINK-39856
> URL: https://issues.apache.org/jira/browse/FLINK-39856
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Kafka
> Reporter: Aleksandr Savonin
> Assignee: Aleksandr Savonin
> Priority: Major
>
> We can provide a safe default when the user doesn't set one
> ({{{}transactionalIdPrefix{}}}), we can derive it from
> getJobInfo().getJobId() plus a per-sink discriminator.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
