HOTFIX: Correct ordering of input buffer and enforced processing sensors (#12363)
1. As titled, fix the right constructor param ordering. 2. Also added a few more loglines. Reviewers: Matthias J. Sax <matthias@confluent.io>, Sagar Rao <sagarmeansocean@gmail.com>, Hao Li <1127478+lihaosky@users.noreply.github.com>
显示
- streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java 6 个添加, 1 个删除.../src/main/java/org/apache/kafka/streams/KafkaStreams.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java 6 个添加, 5 个删除...che/kafka/streams/processor/internals/PartitionGroup.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java 1 个添加, 3 个删除.../apache/kafka/streams/processor/internals/StreamTask.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java 8 个添加, 3 个删除...pache/kafka/streams/processor/internals/StreamThread.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGroupTest.java 1 个添加, 1 个删除...kafka/streams/processor/internals/PartitionGroupTest.java
加载中
想要评论请 注册 或 登录