You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2020/04/09 22:33:21 UTC

[kafka] 01/01: Merge branch 'trunk' into temp-8436

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

vvcephei pushed a commit to branch temp-8436
in repository https://gitbox.apache.org/repos/asf/kafka.git

commit 872694be4eae988fc8dbbbf6e9a5062fdf23311a
Merge: 1f0a36b 0470e2b
Author: John Roesler <vv...@apache.org>
AuthorDate: Thu Apr 9 17:32:32 2020 -0500

    Merge branch 'trunk' into temp-8436

 checkstyle/import-control.xml                      |   5 +
 .../kafka/clients/consumer/internals/Fetcher.java  |   2 +-
 .../internals/OffsetsForLeaderEpochClient.java     |   2 +-
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   8 +-
 .../org/apache/kafka/common/protocol/Message.java  |  48 ++-
 .../apache/kafka/common/protocol/MessageUtil.java  | 103 ++++++
 .../kafka/common/requests/AbstractResponse.java    |   2 +-
 .../kafka/common/requests/AlterConfigsRequest.java | 146 +++-----
 .../common/requests/AlterConfigsResponse.java      |  86 +----
 .../apache/kafka/common/message/MessageTest.java   |  11 +
 .../kafka/common/requests/RequestResponseTest.java |  20 +-
 .../java/org/apache/kafka/connect/data/Values.java |   2 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  18 +-
 .../admin/TopicCommandWithAdminClientTest.scala    |   2 +-
 .../java/org/apache/kafka/message/FieldSpec.java   |   5 +
 .../java/org/apache/kafka/message/FieldType.java   |  12 +
 .../apache/kafka/message/IsNullConditional.java    |  47 ++-
 .../apache/kafka/message/MessageDataGenerator.java | 398 +++++++++++++++++++--
 .../org/apache/kafka/message/MessageGenerator.java |  24 ++
 .../main/java/org/apache/kafka/message/Target.java |  93 +++++
 .../kafka/message/IsNullConditionalTest.java       |   8 +-
 .../EOSUncleanShutdownIntegrationTest.java         |  21 +-
 .../GlobalKTableEOSIntegrationTest.java            |  29 +-
 .../KTableSourceTopicRestartIntegrationTest.java   |  14 +-
 .../ResetPartitionTimeIntegrationTest.java         |  25 +-
 .../integration/RocksDBMetricsIntegrationTest.java |   3 +-
 .../SuppressionDurabilityIntegrationTest.java      |  25 +-
 .../processor/internals/StreamThreadTest.java      |   5 +-
 .../StreamThreadStateStoreProviderTest.java        |   3 +-
 29 files changed, 874 insertions(+), 293 deletions(-)