This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from f1bb29b93a2 MINOR: migrate BrokerCompressionTest to storage module
(#19277)
add db4e74b46e3 MINOR: Add Functional Interface annotation to interfaces
used by Lambdas (#19234)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java | 1 +
streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java | 1 +
.../src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java | 1 +
streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java | 1 +
.../src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java | 1 +
streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java | 1 +
streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java | 1 +
streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java | 1 +
.../main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java | 1 +
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java | 1 +
.../main/java/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java | 1 +
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java | 1 +
.../main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java | 1 +
.../java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java | 1 +
.../apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java | 1 +
.../org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java | 1 +
.../src/main/java/org/apache/kafka/streams/processor/Cancellable.java | 1 +
streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java | 1 +
.../java/org/apache/kafka/streams/processor/StateRestoreCallback.java | 1 +
.../main/java/org/apache/kafka/streams/processor/StreamPartitioner.java | 1 +
.../main/java/org/apache/kafka/streams/processor/TimestampExtractor.java | 1 +
.../main/java/org/apache/kafka/streams/processor/TopicNameExtractor.java | 1 +
.../java/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java | 1 +
.../src/main/java/org/apache/kafka/streams/processor/api/Processor.java | 1 +
.../kafka/streams/processor/api/WrappedFixedKeyProcessorSupplier.java | 1 +
.../org/apache/kafka/streams/processor/api/WrappedProcessorSupplier.java | 1 +
26 files changed, 26 insertions(+)
