You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2022/10/14 22:32:59 UTC
[kafka] branch trunk updated (78b4ba7d85a -> dfb59296654)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 78b4ba7d85a MINOR; Add kraft controller log level in log4j prop (#12707)
add dfb59296654 Kafka Streams Threading P2: Skeleton TaskExecutor Impl (#12744)
No new revisions were added by this update.
Summary of changes:
.../internals/tasks/DefaultTaskExecutor.java | 158 +++++++++++++++++++++
.../processor/internals/tasks/TaskExecutor.java | 15 +-
.../processor/internals/tasks/TaskManager.java | 5 +-
.../internals/tasks/DefaultTaskExecutorTest.java | 107 ++++++++++++++
4 files changed, 281 insertions(+), 4 deletions(-)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutorTest.java