Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Before we dive into how we could change the preexisting codebase, it would be helpful to clarify on some of the details regarding the current Kafka Streams design. Right now, threads are independent of one another–that is, each thread is in charge of its own stream task. There is no cooperation between threads. And as a result, they are not processing the same topicpartition, but instead distinct ones. For example, one thread processes topic1 partition1 while another processes topic2partition2. These two threads does not attempt to access the other topic because such knowledge is not given to them. In this manner, the two threads are isolated from one another. 

...