It's a difficult to explain briefly.
KIP-1035
(https://cwiki.apache.org/confluence/display/KAFKA/KIP-1035%3A+StateStore+managed+changelog+offsets)
introduced this issue, so maybe reading the KIP as a starting point
might help to understand?
Btw: The ticket is assigned to Bill as you can see, so he is looking
into it already.
-Matthias
On 1/17/25 9:44 AM, Swikar Patel wrote:
Hi Team,
As I am new contributing Kafka project, though I use Kafka before. While I was
looking at this Jira issue. I found following list of classes are prominent.
KAFKA-18498 <https://issues.apache.org/jira/browse/KAFKA-18498>Kafka Streams
main thread does not release lock
I am curious and I would like to know the purpose of this classes, which class
calling other class and how this 6 class interact each other. Any hierarchic
structure? Would anyone explain in briefly? Appreciated.
List of Classes:
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
--
Thanks,
Swikar
