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

Reply via email to