MINOR: revert KIP-770 (#12383)
KIP-770 introduced a performance regression and needs some re-design. Needed to resolve some conflict while reverting. This reverts commits 1317f3f7 and 0924fd3f. Reviewers: Sagar Rao <sagarmeansocean@gmail.com>, Guozhang Wang <guozhang@confluent.io>
显示
- checkstyle/suppressions.xml 1 个添加, 1 个删除checkstyle/suppressions.xml
- streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java 1 个添加, 1 个删除...he/kafka/streams/examples/pageview/PageViewTypedDemo.java
- streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java 1 个添加, 1 个删除.../kafka/streams/examples/pageview/PageViewUntypedDemo.java
- streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java 1 个添加, 1 个删除...e/kafka/streams/examples/temperature/TemperatureDemo.java
- streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java 1 个添加, 1 个删除...pache/kafka/streams/examples/wordcount/WordCountDemo.java
- streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java 1 个添加, 1 个删除...ka/streams/examples/wordcount/WordCountProcessorDemo.java
- streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java 1 个添加, 1 个删除.../streams/examples/wordcount/WordCountTransformerDemo.java
- streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java 32 个添加, 49 个删除.../src/main/java/org/apache/kafka/streams/KafkaStreams.java
- streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java 0 个添加, 23 个删除...src/main/java/org/apache/kafka/streams/StreamsConfig.java
- streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java 10 个添加, 53 个删除...rc/main/java/org/apache/kafka/streams/TopologyConfig.java
- streams/src/main/java/org/apache/kafka/streams/internals/StreamsConfigUtils.java 0 个添加, 31 个删除...rg/apache/kafka/streams/internals/StreamsConfigUtils.java
- streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java 4 个添加, 4 个删除...va/org/apache/kafka/streams/kstream/CogroupedKStream.java
- streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java 10 个添加, 10 个删除...java/org/apache/kafka/streams/kstream/KGroupedStream.java
- streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java 11 个添加, 11 个删除.../java/org/apache/kafka/streams/kstream/KGroupedTable.java
- streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java 4 个添加, 4 个删除...afka/streams/kstream/SessionWindowedCogroupedKStream.java
- streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java 12 个添加, 12 个删除.../apache/kafka/streams/kstream/SessionWindowedKStream.java
- streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java 4 个添加, 4 个删除...e/kafka/streams/kstream/TimeWindowedCogroupedKStream.java
- streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java 12 个添加, 12 个删除...org/apache/kafka/streams/kstream/TimeWindowedKStream.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java 7 个添加, 35 个删除...che/kafka/streams/processor/internals/PartitionGroup.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java 0 个添加, 11 个删除...apache/kafka/streams/processor/internals/RecordQueue.java
加载中
想要评论请 注册 或 登录