[jira] [Created] (FLINK-32266) Kafka Source Continues Consuming Previous Topic After Loading Savepoint

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

xiechenling created FLINK-32266:
-----------------------------------

             Summary: Kafka Source Continues Consuming Previous Topic After Loading Savepoint
                 Key: FLINK-32266
                 URL: https://issues.apache.org/jira/browse/FLINK-32266
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.15.3
         Environment: Flink version: 1.15.3
Kafka Connector version: 1.15.3 FLIP-27
            Reporter: xiechenling


I encountered an issue with the Flink Kafka Connector's Kafka Source where it continues consuming data from a previously consumed topic even after loading a savepoint and configuring it to consume data from a different topic.

 

Steps to reproduce:
 # Set up the Kafka Source to consume data from Topic A.
 # Start the Flink job.
 # Stop the job and create a savepoint.
 # Modify the configuration to consume data from Topic B.
 # Load the job from the savepoint and start it.
 # Observe that the job consumes data from both Topic A and Topic B, instead of just Topic B.

 

Expected behavior:

After loading a savepoint and configuring the Kafka Source to consume data from a new topic, the job should only consume data from the newly configured topic.

 

Actual behavior:

The Kafka Source continues consuming data from the previous topic (Topic A), in addition to the newly configured topic (Topic B).



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