THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
// KIP-915 dobumping the notversion bumpwill theno versionlonger andmake onlythis add/removerecord taggedbackward fieldscompatible. { "type": "data", "name": "GroupMetadataValue", "validVersions": "0-4", "flexibleVersions": "4+", "fields": [ { "name": "protocolType", "versions": "0+", "type": "string"}, { "name": "generation", "versions": "0+", "type": "int32" }, { "name": "protocol", "versions": "0+", "type": "string", "nullableVersions": "0+" }, { "name": "leader", "versions": "0+", "type": "string", "nullableVersions": "0+" }, { "name": "currentStateTimestamp", "versions": "2+", "type": "int64", "default": -1, "ignorable": true}, { "name": "members", "versions": "0+", "type": "[]MemberMetadata" } ], "commonStructs": [ { "name": "MemberMetadata", "versions": "0-4", "fields": [ { "name": "memberId", "versions": "0+", "type": "string" }, { "name": "groupInstanceId", "versions": "3+", "type": "string", "default": "null", "nullableVersions": "3+", "ignorable": true}, { "name": "clientId", "versions": "0+", "type": "string" }, { "name": "clientHost", "versions": "0+", "type": "string" }, { "name": "rebalanceTimeout", "versions": "1+", "type": "int32", "ignorable": true}, { "name": "sessionTimeout", "versions": "0+", "type": "int32" }, { "name": "subscription", "versions": "0+", "type": "bytes" }, { "name": "assignment", "versions": "0+", "type": "bytes" } ] } ] } |
...
Code Block | ||
---|---|---|
| ||
// KIP-915 dobumping the notversion bumpwill theno versionlonger andmake onlythis add/removerecord taggedbackward fieldscompatible. { "type": "data", "name": "OffsetCommitValue", "validVersions": "0-4", "flexibleVersions": "4+", "fields": [ { "name": "offset", "type": "int64", "versions": "0+" }, { "name": "leaderEpoch", "type": "int32", "versions": "3+", "default": -1, "ignorable": true}, { "name": "metadata", "type": "string", "versions": "0+" }, { "name": "commitTimestamp", "type": "int64", "versions": "0+" }, { "name": "expireTimestamp", "type": "int64", "versions": "1", "default": -1, "ignorable": true} ] } |
...
Code Block | ||
---|---|---|
| ||
// KIP-915 dobumping the notversion bumpwill theno versionlonger andmake onlythis add/removerecord taggedbackward fieldscompatible. { "type": "data", "name": "TransactionLogValue", "validVersions": "1", "flexibleVersions": "1+", "fields": [ { "name": "ProducerId", "type": "int64", "versions": "0", "about": "Producer id in use by the transactional id"}, { "name": "ProducerEpoch", "type": "int16", "versions": "0", "about": "Epoch associated with the producer id"}, { "name": "TransactionTimeoutMs", "type": "int32", "versions": "0", "about": "Transaction timeout in milliseconds"}, { "name": "TransactionStatus", "type": "int8", "versions": "0", "about": "TransactionState the transaction is in"}, { "name": "TransactionPartitions", "type": "[]PartitionsSchema", "versions": "0", "nullableVersions": "0", "about": "Set of partitions involved in the transaction", "fields": [ { "name": "Topic", "type": "string", "versions": "0"}, { "name": "PartitionIds", "type": "[]int32", "versions": "0"}]}, { "name": "TransactionLastUpdateTimestampMs", "type": "int64", "versions": "0", "about": "Time the transaction was last updated"}, { "name": "TransactionStartTimestampMs", "type": "int64", "versions": "0", "about": "Time the transaction was started"} ] } |
...