You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2021/02/02 06:01:06 UTC
[kafka] branch trunk updated (f5a2fba -> a022072)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from f5a2fba KAFKA-10366 & KAFKA-9649: Implement KIP-659 to allow TimeWindowedDeserializer and TimeWindowedSerde to handle window size (#9253)
add a022072 KAFKA-12248; Add BrokerHeartbeat/BrokerRegistration RPCs for KIP-500 (#9994)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/protocol/ApiKeys.java | 4 +-
.../kafka/common/requests/AbstractRequest.java | 4 ++
.../kafka/common/requests/AbstractResponse.java | 4 ++
...TxnRequest.java => BrokerHeartbeatRequest.java} | 42 ++++++++---------
...sResponse.java => BrokerHeartbeatResponse.java} | 25 ++++++-----
...Request.java => BrokerRegistrationRequest.java} | 46 +++++++++----------
...sponse.java => BrokerRegistrationResponse.java} | 43 +++++++++---------
.../common/message/BrokerHeartbeatRequest.json | 19 +++++---
...nResponse.json => BrokerHeartbeatResponse.json} | 21 ++++-----
.../common/message/BrokerRegistrationRequest.json | 45 ++++++++++---------
...sponse.json => BrokerRegistrationResponse.json} | 17 +++----
.../apache/kafka/common/protocol/ApiKeysTest.java | 4 ++
.../kafka/common/requests/RequestResponseTest.java | 52 ++++++++++++++++++++++
.../scala/kafka/network/RequestConvertToJson.scala | 4 ++
core/src/main/scala/kafka/server/KafkaApis.scala | 4 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 6 +++
16 files changed, 215 insertions(+), 125 deletions(-)
copy clients/src/main/java/org/apache/kafka/common/requests/{AddOffsetsToTxnRequest.java => BrokerHeartbeatRequest.java} (54%)
copy clients/src/main/java/org/apache/kafka/common/requests/{ListGroupsResponse.java => BrokerHeartbeatResponse.java} (64%)
copy clients/src/main/java/org/apache/kafka/common/requests/{ControlledShutdownRequest.java => BrokerRegistrationRequest.java} (53%)
copy clients/src/main/java/org/apache/kafka/common/requests/{SyncGroupResponse.java => BrokerRegistrationResponse.java} (65%)
copy metadata/src/main/resources/common/metadata/UnregisterBrokerRecord.json => clients/src/main/resources/common/message/BrokerHeartbeatRequest.json (56%)
copy clients/src/main/resources/common/message/{AddOffsetsToTxnResponse.json => BrokerHeartbeatResponse.json} (64%)
copy metadata/src/main/resources/common/metadata/RegisterBrokerRecord.json => clients/src/main/resources/common/message/BrokerRegistrationRequest.json (59%)
copy clients/src/main/resources/common/message/{AddOffsetsToTxnResponse.json => BrokerRegistrationResponse.json} (74%)