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

Jin Xu updated FLINK-22800:
---------------------------
    Description: 
{code:java}
When isolation.level=read_uncommitted (default),

EXACTLY_ONCE KAFKA consumer cannot provide exactly-once semantic.

{code}

  was:
{code:java}
When isolation.level=read_uncommitted (default),

EXACTLY_ONCE kafka consumer cannot 

{code}


> EXACTLY_ONCE KAFKA consumer (FLINK-6988) has not set isolation.level
> --------------------------------------------------------------------
>
>                 Key: FLINK-22800
>                 URL: https://issues.apache.org/jira/browse/FLINK-22800
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Kafka
>            Reporter: Jin Xu
>            Priority: Critical
>
> {code:java}
> When isolation.level=read_uncommitted (default),
> EXACTLY_ONCE KAFKA consumer cannot provide exactly-once semantic.
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to