THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
{ "apiKey": 8, "type": "response", "name": "OffsetCommitResponse", // Versions 1 and 2 are the same as version 0. // // Version 3 adds the throttle time to the response. // // Starting in version 4, on quota violation, brokers send out responses before throttling. // // Versions 5 and 6 are the same as version 4. // // Version 7 offsetCommitRequest supports a new field called groupInstanceId to indicate member identity across restarts. // // Version 8 is the first flexible version. // // Version 9 adds TopicId field and can return FENCED_MEMBER_EPOCH, UNKNOWN_MEMBER_ID // and UNKNOWN_MEMBERTOPIC_ID errors (KIP-848). "validVersions": "0-9", "flexibleVersions": "8+", "fields": [ { "name": "ThrottleTimeMs", "type": "int32", "versions": "3+", "ignorable": true, "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": "Topics", "type": "[]OffsetCommitResponseTopic", "versions": "0+", "about": "The responses for each topic.", "fields": [ // Updated field. { "name": "Name", "type": "string", "versions": "0+", "nullableVersions": "9+", "default": "null", "entityType": "topicName", "about": "The topic name."}, // New field. { "name": "TopicId", "type": "uuid", "versions": "9+", "about": "The unique topic ID" }, { "name": "Partitions", "type": "[]OffsetCommitResponsePartition", "versions": "0+", "about": "The responses for each partition in the topic.", "fields": [ { "name": "PartitionIndex", "type": "int32", "versions": "0+", "about": "The partition index." }, { "name": "ErrorCode", "type": "int16", "versions": "0+", "about": "The error code, or 0 if there was no error." } ]} ]} ] } |
...
Code Block | ||||
---|---|---|---|---|
| ||||
{ "apiKey": 9, "type": "response", "name": "OffsetFetchResponse", // Version 1 is the same as version 0. // // Version 2 adds a top-level error code. // // Version 3 adds the throttle time. // // Starting in version 4, on quota violation, brokers send out responses before throttling. // // Version 5 adds the leader epoch to the committed offset. // // Version 6 is the first flexible version. // // Version 7 adds pending offset commit as new error response on partition level. // // Version 8 is adding support for fetching offsets for multiple groups // // Version 9 adds TopicId field and can return FENCED_MEMBER_EPOCH, UNKNOWN_MEMBER_ID, // ILLEGAL_GENERATION, and ILLEGALUNKNOWN_TOPIC_GENERATIONID errors. "validVersions": "0-8", "flexibleVersions": "6+", "fields": [ { "name": "ThrottleTimeMs", "type": "int32", "versions": "3+", "ignorable": true, "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": "Topics", "type": "[]OffsetFetchResponseTopic", "versions": "0-7", "about": "The responses per topic.", "fields": [ { "name": "Name", "type": "string", "versions": "0-7", "entityType": "topicName", "about": "The topic name." }, { "name": "Partitions", "type": "[]OffsetFetchResponsePartition", "versions": "0-7", "about": "The responses per partition", "fields": [ { "name": "PartitionIndex", "type": "int32", "versions": "0-7", "about": "The partition index." }, { "name": "CommittedOffset", "type": "int64", "versions": "0-7", "about": "The committed message offset." }, { "name": "CommittedLeaderEpoch", "type": "int32", "versions": "5-7", "default": "-1", "ignorable": true, "about": "The leader epoch." }, { "name": "Metadata", "type": "string", "versions": "0-7", "nullableVersions": "0-7", "about": "The partition metadata." }, { "name": "ErrorCode", "type": "int16", "versions": "0-7", "about": "The error code, or 0 if there was no error." } ]} ]}, { "name": "ErrorCode", "type": "int16", "versions": "2-7", "default": "0", "ignorable": true, "about": "The top-level error code, or 0 if there was no error." }, { "name": "Groups", "type": "[]OffsetFetchResponseGroup", "versions": "8+", "about": "The responses per group id.", "fields": [ { "name": "groupId", "type": "string", "versions": "8+", "entityType": "groupId", "about": "The group ID." }, { "name": "Topics", "type": "[]OffsetFetchResponseTopics", "versions": "8+", "about": "The responses per topic.", "fields": [ { "name": "Name", "type": "string", "versions": "8+", "nullableVersions": "9+", "default": "null", "entityType": "topicName", "about": "The topic name."}, { "name": "TopicId", "type": "uuid", "versions": "9+", "about": "The unique topic ID" }, { "name": "Partitions", "type": "[]OffsetFetchResponsePartitions", "versions": "8+", "about": "The responses per partition", "fields": [ { "name": "PartitionIndex", "type": "int32", "versions": "8+", "about": "The partition index." }, { "name": "CommittedOffset", "type": "int64", "versions": "8+", "about": "The committed message offset." }, { "name": "CommittedLeaderEpoch", "type": "int32", "versions": "8+", "default": "-1", "ignorable": true, "about": "The leader epoch." }, { "name": "Metadata", "type": "string", "versions": "8+", "nullableVersions": "8+", "about": "The partition metadata." }, { "name": "ErrorCode", "type": "int16", "versions": "8+", "about": "The partition-level error code, or 0 if there was no error." } ]} ]}, { "name": "ErrorCode", "type": "int16", "versions": "8+", "default": "0", "about": "The group-level error code, or 0 if there was no error." } ]} ] } |
...