Matthias J. Sax created KAFKA-20885:
---------------------------------------
Summary: Incorrect IQ metadata in "streams" protocol
Key: KAFKA-20885
URL: https://issues.apache.org/jira/browse/KAFKA-20885
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 4.1.0
Reporter: Matthias J. Sax
Note, I am setting 4.1.0 as affected version, because this code shipped with
4.1.0, even if "streams" protocol is only an "early access" in 4.1.0.
IQ metadata reports non-existent partitions when a member owns a non-prefix
task set of a subtopology with uneven source-topic partition counts: There is a
Task T with two input topic A (5 partitions) and B (2 partitions). A member has
tasks 0_1 and 0_3 assigned. For topic B, it should only report to host task 0_1
(because 0_3 has no B partition assigned), but it incorrectly reports to host
both 0_1 and 0_3.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)