[kafka] branch kafka-10867-improved-task-idling updated (b73a533 -> 7917638)

[vv...@apache.org]

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

vvcephei pushed a change to branch kafka-10867-improved-task-idling
in repository https://gitbox.apache.org/repos/asf/kafka.git.


 discard b73a533  ditto
 discard d6d7f80  disable idling for selected ITs
 discard a108f2d  fix diff
 discard d22143b  switch default
 discard 2ede9c8  KAFKA-10867: Improved task idling
     add 86e267b  Consumer changes to cope with cached metadata response
     add 41900e1  Rollback consumer-side metadata caching
     add 1c5ee1c  KAFKA-10867: Improved task idling
     add 1309a25  switch default
     add 9cfd8cc  fix diff
     add 4ac9c41  disable idling for selected ITs
     add 884f81b  ditto
     add bc0a57c  Streams changes to cope with cached metadata response
     add 7917638  Rollback streams-side metadata caching

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   (b73a533)
            \
             N -- N -- N   refs/heads/kafka-10867-improved-task-idling (7917638)

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:
 checkstyle/suppressions.xml                        |  2 +-
 .../kafka/clients/consumer/ConsumerRecords.java    | 34 +++++++++++++++-------
 .../clients/consumer/internals/FetchedRecords.java | 22 ++++++++++----
 .../kafka/clients/consumer/internals/Fetcher.java  | 34 ++++++++--------------
 .../consumer/internals/SubscriptionState.java      | 12 ++++++++
 .../kafka/clients/consumer/KafkaConsumerTest.java  | 24 +++++++--------
 .../kafka/api/PlaintextConsumerTest.scala          | 29 +++++-------------
 .../processor/internals/PartitionGroup.java        | 27 ++++++++++++++---
 .../streams/processor/internals/StreamThread.java  |  9 ++++--
 .../internals/StreamsPartitionAssignor.java        |  2 ++
 .../KStreamRepartitionIntegrationTest.java         |  1 -
 ...bleForeignKeyInnerJoinMultiIntegrationTest.java |  1 -
 .../KTableKTableForeignKeyJoinDistributedTest.java |  1 -
 .../integration/RegexSourceIntegrationTest.java    |  1 +
 .../SmokeTestDriverIntegrationTest.java            |  1 -
 .../integration/utils/IntegrationTestUtils.java    |  3 +-
 .../processor/internals/StreamTaskTest.java        |  2 +-
 .../org/apache/kafka/test/StreamsTestUtils.java    |  1 -
 ...StreamToTableJoinScalaIntegrationTestBase.scala |  1 -
 .../apache/kafka/streams/TopologyTestDriver.java   | 34 ++++++++--------------
 20 files changed, 132 insertions(+), 109 deletions(-)