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%)
