[kafka] branch iqv2-key-query updated (e7d8b33 -> 9f8d21b)

[vv...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

vvcephei pushed a change to branch iqv2-key-query
in repository https://gitbox.apache.org/repos/asf/kafka.git.


 discard e7d8b33  style
 discard f4d43c4  rebase and remove RawKeyQuery
 discard 7fc654d  KAFKA-13525: Implement KeyQuery in Streams IQv2
     add 065fba9  KAFKA-13539: Improve propagation and processing of SSL handshake failures (#11597)
     add b4602e8  MINOR: Timeout waitForBlock in connect BlockingConnectorTest (#11595)
     add 0e150a4  MINOR: Reset java.security.auth.login.config in ZK-tests to avoid config reload affecting subsequent tests (#11602)
     add 0478733  MINOR: Update log and method name in TopologyMetadata (#11589)
     add f653cb7  KAFKA-13488: Producer fails to recover if topic gets deleted midway (#11552)
     add b38f6ba  KAFKA-13479: Implement range and scan queries (#11598)
     add 247c271  MINOR: retry when deleting offsets for named topologies (#11604)
     add 9f8d21b  KAFKA-13525: Implement KeyQuery in Streams IQv2

This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version.  This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:

 * -- * -- B -- O -- O -- O   (e7d8b33)
            \
             N -- N -- N   refs/heads/iqv2-key-query (9f8d21b)

You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/clients/Metadata.java    |   7 +-
 .../org/apache/kafka/common/network/Selector.java  |   2 +-
 .../kafka/common/network/SslTransportLayer.java    |  59 ++++++++--
 .../org/apache/kafka/clients/MetadataTest.java     |  34 +++++-
 .../kafka/common/network/NetworkTestUtils.java     |   8 +-
 .../common/network/SslTransportLayerTest.java      |  18 ++-
 .../connect/integration/BlockingConnectorTest.java |   7 +-
 .../kafka/api/ProducerSendWhileDeletionTest.scala  |  83 +++++++++++++
 .../kafka/server/QuorumTestHarness.scala           |   1 +
 .../streams/processor/internals/StreamThread.java  |   2 +-
 .../processor/internals/TopologyMetadata.java      |   4 +-
 .../KafkaStreamsNamedTopologyWrapper.java          |   6 +
 .../org/apache/kafka/streams/query/KeyQuery.java   |  13 +++
 .../org/apache/kafka/streams/query/RangeQuery.java | 102 ++++++++++++++++
 .../state/internals/InMemoryKeyValueStore.java     |  10 ++
 .../state/internals/MemoryNavigableLRUCache.java   |  10 ++
 .../state/internals/MeteredKeyValueStore.java      | 129 +++++++++++++++++---
 .../streams/state/internals/RocksDBStore.java      |   1 +
 .../streams/state/internals/StoreQueryUtils.java   | 109 ++++++++++++-----
 .../integration/IQv2StoreIntegrationTest.java      | 130 +++++++++++++++++----
 20 files changed, 644 insertions(+), 91 deletions(-)
 create mode 100644 core/src/test/scala/integration/kafka/api/ProducerSendWhileDeletionTest.scala
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/query/RangeQuery.java