[jira] [Created] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure.

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

HunterHunter created FLINK-28435:
------------------------------------

             Summary: Flink version 1.15.0  consumption Kafka has backpressure.
                 Key: FLINK-28435
                 URL: https://issues.apache.org/jira/browse/FLINK-28435
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.15.0
            Reporter: HunterHunter


A simple SQL program
{code:java}
CREATE temporary TABLE `print_sink` (
  `id` VARCHAR(2147483647)
)WITH (
  'connector' = 'print'
);

insert into print_sink
select id
from kafka-source
/*+ OPTIONS('properties.bootstrap.servers'='brokers',
  'topic' = 'topicname',
  'properties.group.id'='test',
  'scan.startup.mode'='latest-offset')
  */ {code}
Back pressure occurs when I use `flink 1.15.0`,

When I use `flink 1.13/ flink 1.14`, it works normally.

I think this is caused by the version of Kafka.

I have tried to consume versions `Kafka 1.1` and `Kafka 2.7.1`, and `Flink 1.13/1.14` is normal （`Kafka 2.4.1` is used in `Flink 1.13/1.14`）;

But `Flink 1.15` has back pressure. (I had try to change Kafka version to `Kafka 2.7.1`, which is still back pressure).

 

 

 

 

 

 



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