Kafka Batch Source Plugin- Initial offset not getting applied

Description

When setting the initial offset functionality of the Kafka Batch Source PlugIn, It ignores the initial offset or the partition set. The plugin retrieves all the data in the topic, even if the initial offset is set as "0:5" or "1:8".

Expected behaviour: The starting point for reading from Kafka should be from the offset specified and not start from the beginning.

Release Notes

Fixed bug where initial offset was not considered in Kafka batch source.

Activity

Show:

prashant singhMay 8, 2023 at 10:28 PM
Edited

PR Merged for 6.9 and 6.8 CDAP Release

Unresolved
Pinned fields
Click on the next to a field label to start pinning.

Details

Assignee

Reporter

Reviewer

Fix versions

Due date

Priority

Created April 25, 2023 at 1:32 PM
Updated May 11, 2023 at 6:22 PM