[kafka] branch trunk updated (af377b5 -> 14c6030)

[gu...@apache.org]

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

guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from af377b5  KAFKA-13423: GlobalThread should not log ERROR on clean shutdown (#11455)
     add 14c6030  KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes" (#11424)

No new revisions were added by this update.

Summary of changes:
 .../examples/pageview/PageViewTypedDemo.java       |   2 +-
 .../examples/pageview/PageViewUntypedDemo.java     |   2 +-
 .../examples/temperature/TemperatureDemo.java      |   2 +-
 .../streams/examples/wordcount/WordCountDemo.java  |   2 +-
 .../examples/wordcount/WordCountProcessorDemo.java |   2 +-
 .../wordcount/WordCountTransformerDemo.java        |   2 +-
 .../org/apache/kafka/streams/KafkaStreams.java     |  76 ++++---
 .../org/apache/kafka/streams/StreamsConfig.java    |  43 ++++
 .../kafka/streams/kstream/CogroupedKStream.java    |   8 +-
 .../kafka/streams/kstream/KGroupedStream.java      |  20 +-
 .../kafka/streams/kstream/KGroupedTable.java       |  22 +-
 .../kstream/SessionWindowedCogroupedKStream.java   |   8 +-
 .../streams/kstream/SessionWindowedKStream.java    |  24 +--
 .../kstream/TimeWindowedCogroupedKStream.java      |   8 +-
 .../kafka/streams/kstream/TimeWindowedKStream.java |  24 +--
 .../processor/internals/PartitionGroup.java        |  81 ++++---
 .../streams/processor/internals/RecordQueue.java   |  37 ++++
 .../streams/processor/internals/StreamTask.java    |  15 +-
 .../streams/processor/internals/StreamThread.java  |  40 +++-
 .../kafka/streams/processor/internals/Task.java    |   1 +
 .../streams/processor/internals/TaskManager.java   | 227 +++++++++++---------
 .../processor/internals/metrics/TaskMetrics.java   |  19 ++
 .../internals/namedtopology/TopologyConfig.java    |  35 +++-
 .../org/apache/kafka/streams/KafkaStreamsTest.java |   9 +-
 .../apache/kafka/streams/StreamsConfigTest.java    |  30 +++
 .../integration/AbstractJoinIntegrationTest.java   |   2 +-
 .../integration/AbstractResetIntegrationTest.java  |   2 +-
 .../integration/AdjustStreamThreadCountTest.java   |  89 +++++++-
 .../integration/EmitOnChangeIntegrationTest.java   |   2 +-
 .../streams/integration/EosIntegrationTest.java    |   6 +-
 .../integration/EosV2UpgradeIntegrationTest.java   |   2 +-
 .../FineGrainedAutoResetIntegrationTest.java       |   4 +-
 .../GlobalKTableEOSIntegrationTest.java            |   2 +-
 .../integration/GlobalKTableIntegrationTest.java   |   2 +-
 .../integration/GlobalThreadShutDownOrderTest.java |   2 +-
 .../integration/InternalTopicIntegrationTest.java  |   2 +-
 .../KStreamAggregationDedupIntegrationTest.java    |   2 +-
 .../KStreamAggregationIntegrationTest.java         |   2 +-
 .../KStreamRepartitionIntegrationTest.java         |   2 +-
 ...yInnerJoinCustomPartitionerIntegrationTest.java |   1 +
 ...bleForeignKeyInnerJoinMultiIntegrationTest.java |   2 +-
 .../KTableSourceTopicRestartIntegrationTest.java   |   2 +-
 .../integration/MetricsIntegrationTest.java        |   4 +-
 .../OptimizedKTableIntegrationTest.java            |   2 +-
 .../integration/QueryableStateIntegrationTest.java |   2 +-
 .../integration/RegexSourceIntegrationTest.java    |   2 +-
 .../integration/RestoreIntegrationTest.java        |   2 +-
 .../integration/RocksDBMetricsIntegrationTest.java |   2 +-
 .../integration/StandbyTaskEOSIntegrationTest.java |   2 +-
 .../integration/StoreUpgradeIntegrationTest.java   |   2 +-
 ...bleJoinTopologyOptimizationIntegrationTest.java |   2 +-
 .../kstream/internals/KTableFilterTest.java        |   4 +-
 .../internals/SessionWindowedKStreamImplTest.java  |   2 +-
 .../internals/InternalTopologyBuilderTest.java     |  18 +-
 .../processor/internals/PartitionGroupTest.java    | 101 +++++++++
 .../internals/RepartitionOptimizingTest.java       |   2 +-
 .../RepartitionWithMergeOptimizingTest.java        |   2 +-
 .../processor/internals/StandbyTaskTest.java       |   1 -
 .../processor/internals/StreamTaskTest.java        |   1 +
 .../processor/internals/StreamThreadTest.java      | 232 ++++++++++++++++++++-
 .../streams/tests/BrokerCompatibilityTest.java     |   2 +-
 .../apache/kafka/streams/tests/EosTestClient.java  |   2 +-
 .../streams/tests/StreamsNamedRepartitionTest.java |   2 +-
 .../kafka/streams/tests/StreamsOptimizedTest.java  |   2 +-
 .../streams/tests/StreamsStandByReplicaTest.java   |   2 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |   5 +-
 66 files changed, 966 insertions(+), 297 deletions(-)