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 dbc9cd6 KAFKA-9144; Track timestamp from txn markers to prevent early producer expiration
(#7687)
add e94f5dc KAFKA-9294: Add tests for Named parameter (#7874)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/kstream/KStream.java | 4391 ++++++++++----------
.../streams/kstream/internals/AbstractStream.java | 2 +-
.../streams/kstream/internals/KStreamImpl.java | 882 ++--
.../streams/integration/EosIntegrationTest.java | 2 +-
.../streams/kstream/internals/KStreamImplTest.java | 1923 ++++++---
5 files changed, 4170 insertions(+), 3030 deletions(-)
|