You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2019/05/09 13:21:59 UTC
[kafka] branch trunk updated (cc4a7f0 -> c09e25f)

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

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


    from cc4a7f0  MINOR: cleanup policy doc update (#6692)
     add c09e25f  MINOR: Fix bug in Struct.equals and use Objects.equals/Long.hashCode (#6680)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/admin/MemberAssignment.java      |   3 +-
 .../kafka/clients/producer/ProducerRecord.java     |  22 +-
 .../main/java/org/apache/kafka/common/Node.java    |   8 +-
 .../apache/kafka/common/TopicPartitionInfo.java    |   9 +-
 .../common/header/internals/RecordHeader.java      |   2 +-
 .../common/header/internals/RecordHeaders.java     |   2 +-
 .../apache/kafka/common/protocol/types/Struct.java |   3 +-
 .../common/record/AbstractLegacyRecordBatch.java   |   7 +-
 .../apache/kafka/common/record/DefaultRecord.java  |   9 +-
 .../kafka/common/record/DefaultRecordBatch.java    |   3 +-
 .../kafka/common/record/FileLogInputStream.java    |   5 +-
 .../apache/kafka/common/record/FileRecords.java    |   2 +-
 .../common/record/LazyDownConversionRecords.java   |   2 +-
 .../apache/kafka/common/record/SimpleRecord.java   |   6 +-
 .../kafka/common/requests/FetchResponse.java       |  15 +-
 .../kafka/common/requests/RequestHeader.java       |   3 +-
 .../security/token/delegation/DelegationToken.java |   6 +-
 .../token/delegation/TokenInformation.java         |  23 +-
 .../java/org/apache/kafka/common/utils/Utils.java  |   4 -
 .../kafka/common/protocol/types/StructTest.java    |  84 ++++
 .../kafka/common/requests/RequestResponseTest.java | 463 ++++++++++-----------
 .../org/apache/kafka/connect/sink/SinkRecord.java  |   2 +-
 .../apache/kafka/connect/source/SourceRecord.java  |   9 +-
 .../apache/kafka/connect/util/ConnectorTaskId.java |   5 +-
 .../test/scala/unit/kafka/log/TimeIndexTest.scala  |   4 +-
 .../unit/kafka/network/SocketServerTest.scala      |   4 +-
 .../java/org/apache/kafka/streams/KeyValue.java    |   3 +-
 .../internals/InternalTopologyBuilder.java         |   7 +-
 28 files changed, 392 insertions(+), 323 deletions(-)
 create mode 100644 clients/src/test/java/org/apache/kafka/common/protocol/types/StructTest.java