THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
{ "apiKey": 7, "type": "metadata", "name": "DeleteTopicRecord", "validVersions": "0", "fields": [ { "name": "Id", "type": "uuid", "versions": "0+", "about": "The topic to delete. All associated partitions will be deleted as well." } ] } |
DelegationToken
Code Block |
---|
{
"apiKey": 8,
"type": "metadata",
"name": "DelegationTokenRecord",
"validVersions": "0",
"fields": [
{ "name": "Owner", "type": "string", "versions": "0+",
"about": "The delegation token owner." },
{ "name": "Renewers", "type": "[]string", "versions": "0+",
"about": "The principals which have renewed this token." },
{ "name": "IssueTimestamp", "type": "int64", "versions": "0+",
"about": "The time at which this timestamp was issued." },
{ "name": "MaxTimestamp", "type": "int64", "versions": "0+",
"about": "The time at which this token cannot be renewed any more." },
{ "name": "ExpirationTimestamp", "type": "int64", "versions": "0+",
"about": "The next time at which this token must be renewed." },
{ "name": "TokenId", "type": "string", "versions": "0+",
"about": "The token id." },
]
} |
ScramUser
Code Block |
---|
{
"apiKey": 9,
"type": "metadata",
"name": "DelegationTokenRecord",
"validVersions": "0",
"fields": [
{ "name": "Name", "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." }]}
]
} |
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=MetadataCommitRate | The number of metadata messages per second committed to the metadata topic. |
kafka.controller:type=KafkaController,name=MetadataSnapshotLag | 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) |
...