This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 2254136 Add support for infinite endpoints for range queries (#11120)
add 5d52de2 KAFKA-12648: minor followup from Pt. 2 and some new tests
(#11146)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 2 +-
.../internals/InternalTopologyBuilder.java | 2 +-
.../processor/internals/TopologyMetadata.java | 16 +-
.../KafkaStreamsNamedTopologyWrapper.java | 27 ++-
.../state/internals/MeteredSessionStore.java | 1 -
.../integration/NamedTopologyIntegrationTest.java | 220 ++++++++++++---------
.../integration/StoreQueryIntegrationTest.java | 122 ++++++++----
7 files changed, 255 insertions(+), 135 deletions(-)
