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
