THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
{
"apiKey": 0,
"type": "metadata",
"name": "RegisterBrokerRecord"
,
"validVersions": "0",
"fields": [
{ "name": "IdBrokerId", "type": "int32", "versions": "0+",
"about": "The broker id." },
{ "name": "IncarnationId", "type": "uuid", "versions": "0+",
"about": "The incarnation id of the broker process." },
{ "name": "BrokerEpoch", "type": "int64", "versions": "0+",
"about": "The broker epoch assigned by the controller." },
{ "name": "EndPoints", "type": "[]BrokerEndpoint", "versions": "0+", "nullableVersions": "0+",
"about": "The endpoints that can be used to communicate with this broker.", "fields": [
{ "name": "Name", "type": "string", "versions": "0+", "mapKey": true,
"about": "The name of the endpoint." },
{ "name": "Host", "type": "string", "versions": "0+",
"about": "The hostname." },
{ "name": "Port", "type": "uint16", "versions": "0+",
"about": "The port." },
{ "name": "SecurityProtocol", "type": "int16", "versions": "0+",
"about": "The security protocol." }
]},
{ "name": "Features", "type": "[]BrokerFeature", "versions": "0+", "nullableVersions": "0+",
"about": "The features that this broker supports.", "fields": [
{ "name": "Name", "type": "string", "versions": "0+", "mapKey": true,
"about": "The name of the feature." },
{ "name": "MinVersion", "type": "int16", "versions": "0+",
"about": "The minimum feature level that this broker supports." },
{ "name": "MaxVersion", "type": "int16", "versions": "0+",
"about": "The maximum feature level that this broker supports." }
]},
{ "name": "Rack", "type": "string", "versions": "0+", "nullableVersions": "0+",
"about": "The broker rack." }
]
}
|
...
| Code Block |
|---|
{
"apiKey": 1,
"type": "metadata",
"name": "UnregisterBrokerRecord",
"validVersions": "0",
"fields": [
{ "name": "IdBrokerId", "type": "int32", "versions": "0+",
"about": "The broker id." },
{ "name": "EpochBrokerEpoch", "type": "int64", "versions": "0+",
"about": "The broker epoch." }
]
}
|
...
| Code Block |
|---|
{
"apiKey": 2,
"type": "metadata",
"name": "TopicRecord",
"validVersions": "0",
"fields": [
{ "name": "NameTopicName", "type": "string", "versions": "0+",
"about": "The topic name." },
{ "name": "TopicId", "type": "uuid", "versions": "0+",
"about": "The unique ID of this topic." }
]
}
|
...
| Code Block |
|---|
{
"apiKey": 7,
"type": "metadata",
"name": "FenceBrokerRecord",
"validVersions": "0",
"fields": [
{ "name": "IdBrokerId", "type": "int32", "versions": "0+",
"about": "The broker ID to fence. It will be removed from all ISRs." }
{ "name": "EpochBrokerEpoch", "type": "int64", "versions": "0+",
"about": "The epoch of the broker to fence." }
]
} |
...
| Code Block |
|---|
{
"apiKey": 8,
"type": "metadata",
"name": "UnfenceBrokerRecord",
"validVersions": "0",
"fields": [
{ "name": "IdBrokerId", "type": "int32", "versions": "0+",
"about": "The broker ID to unfence." }
{ "name": "EpochBrokerEpoch", "type": "int64", "versions": "0+",
"about": "The epoch of the broker to unfence." }
]
} |
...
| Code Block |
|---|
{
"apiKey": 9,
"type": "metadata",
"name": "RemoveTopicRecord",
"validVersions": "0",
"fields": [
{ "name": "IdTopicId", "type": "uuid", "versions": "0+",
"about": "The topic to remove. All associated partitions will be removed as well." }
]
} |
...
| Code Block |
|---|
{
"apiKey": 11,
"type": "metadata",
"name": "UserScramCredentialRecord",
"validVersions": "0",
"fields": [
{ "name": "NameUserName", "type": "string", "versions": "0+",
"about": "The user name." },
{ "name": "CredentialInfos", "type": "[]CredentialInfo", "versions": "0+",
"about": "The mechanism and related information associated with the user's SCRAM credential.", "fields": [
{ "name": "Mechanism", "type": "int8", "versions": "0+",
"about": "The SCRAM mechanism." },
{ "name": "Salt", "type": "bytes", "versions": "0+",
"about": "A random salt generated by the client." },
{ "name": "SaltedPassword", "type": "bytes", "versions": "0+",
"about": "The salted password." },
{ "name": "Iterations", "type": "int32", "versions": "0+",
"about": "The number of iterations used in the SCRAM credential." }]}
]
} |
...
| Code Block |
|---|
{
"apiKey": 13,
"type": "metadata",
"name": "FailedReplicasRecord",
"validVersions": "0",
"fields": [
{ "name": "BrokerBrokerId", "type": "int32", "versions": "0+",
"about": "The broker id." },
{ "name": "Topics", "type": "[]TopicWithFailures", "versions": "0+",
"about": "The topics with failed replicas.", "fields": [
{ "name": "TopicTopicId", "type": "uuid", "versions": "0+",
"about": "The topic UUID." },
{ "name": "Partitions", "type": "[]int32", "versions": "0+",
"about": "The partition ids." }
]}
]
} |
QuotaRecord
| Code Block |
|---|
{
"apiKey": 14,
"type": "metadata",
"name": "QuotaRecord",
"validVersions": "0",
"fields": [
{ "name": "Entity", "type": "[]EntityData", "versions": "0+",
"about": "The quota entity to alter.", "fields": [
{ "name": "EntityType", "type": "string", "versions": "0+",
"about": "The entity type." },
{ "name": "EntityName", "type": "string", "versions": "0+", "nullableVersions": "0+",
"about": "The name of the entity, or null if the default." }
]},
{ "name": "Key", "type": "string", "versions": "0+",
"about": "The quota configuration key." },
{ "name": "Value", "type": "float64", "versions": "0+",
"about": "The value to set, otherwise ignored if the value is to be removed." },
{ "name": "Remove", "type": "bool", "versions": "0+",
"about": "Whether the quota configuration value should be removed, otherwise set." }
]
} |
New Metrics
| Full Name | Description |
|---|---|
kafka.controller:type=KafkaController,name=MetadataLag | The offset delta between the latest metadata record this controller has replayed and the last stable offset of the metadata topic. |
| kafka.controller:type=KafkaServer,name=MetadataLag | The offset delta between the latest metadata record this broker has replayed and the last stable offset of the metadata topic. |
| kafka.controller:type=KafkaController,name=MetadataCommitLatencyMs | The latency of committing a message to the metadata topic. Relevant on the active controller. |
| kafka.controller:type=KafkaController,name=MetadataCommitRatePerSec | The number of metadata messages per second committed to the metadata topic. |
| kafka.controller:type=KafkaController,name=MetadataSnapshotOffsetLag | New name for kafka.controller:type=KafkaController,name=SnapshotLag The offset delta between the latest stable offset of the metadata topic and the offset of the last snapshot (or the last stable offset itself, if there are no snapshots) |
...