Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Update LastMirroredOffset schema

...

ListMirroredOffsetsRequest

Code Block
{
    "apiKey": TBD,
    "type": "request",
    "listeners": ["broker", "controller"],
    "name": "LastMirroredOffsetsRequest",
    "validVersions": "0",
    "flexibleVersions": "0+",
    "fields": [
        { "name": "MirrorName", "type": "string", "versions": "0+", "entityType": "mirrorName",
      "about": "The cluster mirror name." },
        { "name": "Topics", "type": "[]TopicStateTopicData", "versions": "0",
            "about": "The data responsesfor perthe topictopics.", "fields": [
            { "name": "Name", "type": "string", "versions": "0", "entityType": "topicName",
                "about": "The topic name." },
            { "name": "Partitions", "type": "[]PartitionStatePartitionData", "versions": "0",
                "about": "The responsesdata for perthe partitionpartitions.", "fields": [
                { "name": "PartitionIndex", "type": "int32", "versions": "0",
                    "about": "The partition index." }
            ]}
        ]}
    ]
}

LastMirroredOffsetsResponse

Code Block
{
    "apiKey": TBD,
    "type": "response",
    "name": "LastMirroredOffsetsResponse",
    "validVersions": "0",
    "flexibleVersions": "0+",
    "fields": [
        { "name": "ThrottleTimeMs", "type": "int32", "versions": "0+",
            "about": "The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota." },
        { "name": "ErrorCode", "type": "int16", "versions": "0+",
            "about": "The error code, or 0 if there was no error." },
        { "name": "Topics", "type": "[]OffsetResponseTopicTopicResult", "versions": "0",
            "about": "The results responsesfor perthe topictopics.", "fields": [
            { "name": "Name", "type": "string", "versions": "0", "entityType": "topicName",
                "about": "The topic name." },
            { "name": "Partitions", "type": "[]OffsetResponsePartitionPartitionResult", "versions": "0",
                "about": "The results responsesfor perthe partitionpartitions.", "fields": [
                { "name": "PartitionIndex", "type": "int32", "versions": "0",
                    "about": "The partition index." },
                { "name": "LastMirroredOffset", "type": "int64", "versions": "0",
                    "about": "The last mirrored record offset." },
                { "name": "ErrorCode", "type": "int16", "versions": "0",
                    "about": "The error code, or 0 if there was no error." }
            ]}
        ]}
    ]
}

ListMirrors

The ListMirrors API returns the current mirror names and their associated topic counts in the cluster.

...