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
