[
https://issues.apache.org/jira/browse/KAFKA-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-19246.
---------------------------------
Fix Version/s: (was: 4.0.1)
Resolution: Fixed
> OffsetFetch API does not return group level errors correctly with version 1
> ---------------------------------------------------------------------------
>
> Key: KAFKA-19246
> URL: https://issues.apache.org/jira/browse/KAFKA-19246
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 3.5.0, 3.6.0, 3.7.0, 3.8.0, 3.9.0, 4.0.0
> Reporter: David Jacot
> Assignee: David Jacot
> Priority: Blocker
> Fix For: 4.1.0
>
>
> The OffsetFetch API with version 1 does not correctly return group level
> errors such as NOT_COORDINATOR. The following test case demonstrate the issue.
> {code:java}
> @ClusterTest
> def testGroupErrors(): Unit = {
> createTopic(
> topic = "foo",
> numPartitions = 3
> )
> assertEquals(
> new OffsetFetchResponseData.OffsetFetchResponseGroup()
> .setGroupId("unknown")
> .setErrorCode(Errors.NOT_COORDINATOR.code),
> fetchOffsets(
> groupId = "unknown",
> memberId = "",
> memberEpoch = 0,
> partitions = List(
> new TopicPartition("foo", 0),
> new TopicPartition("foo", 1)
> ),
> requireStable = true,
> version = 1.toShort
> )
> )
> } {code}
> Here is the output:
> {noformat}
> Expected :OffsetFetchResponseGroup(groupId='unknown', topics=[], errorCode=16)
> Actual :OffsetFetchResponseGroup(groupId='unknown', topics=[],
> errorCode=0){noformat}
> The issue is here:
> https://github.com/apache/kafka/pull/19642#discussion_r2074839488.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
