THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public static class TopicMetadata { private final Errors error; private final String topic; private final boolean isInternal; private final List<PartitionMetadata> partitionMetadata; private int authorizedOperations; private int minInSyncReplicas; } |
MetadataResponseTopic.SCHEMA_10
Add one more field min_insync_replicas to the MetadataResponseTopic response and bump up the version.
Code Block | ||||
---|---|---|---|---|
| ||||
public static final Schema SCHEMA_10 = new Schema( new Field("error_code", Type.INT16, "The topic error, or 0 if there was no error."), new Field("name", Type.COMPACT_STRING, "The topic name."), new Field("is_internal", Type.BOOLEAN, "True if the topic is internal."), new Field("partitions", new CompactArrayOf(MetadataResponsePartition.SCHEMA_9), "Each partition in the topic."), new Field("topic_authorized_operations", Type.INT32, "32-bit bitfield to represent authorized operations for this topic."), new Field("min_insync_replicas", Type.INT16, "min.insync.replicas of this topic."), TaggedFieldsSection.of( ) ); |
...