David Jacot created KAFKA-19246:
-----------------------------------
Summary: 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: 4.0.0, 3.9.0, 3.8.0, 3.7.0, 3.6.0, 3.5.0
Reporter: David Jacot
Assignee: David Jacot
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)
