From e56773acd5b8390a16fa8594af9a7e0c17d86795 Mon Sep 17 00:00:00 2001 From: Julien Viet Date: Thu, 30 Nov 2023 15:12:39 +0100 Subject: [PATCH] Use @JsonGen annotation --- .../io/vertx/kafka/admin/ClusterDescriptionConverter.java | 6 +++--- .../generated/io/vertx/kafka/admin/ConfigConverter.java | 6 +++--- .../io/vertx/kafka/admin/ConfigEntryConverter.java | 6 +++--- .../io/vertx/kafka/admin/ConfigSynonymConverter.java | 6 +++--- .../kafka/admin/ConsumerGroupDescriptionConverter.java | 6 +++--- .../io/vertx/kafka/admin/ConsumerGroupListingConverter.java | 6 +++--- .../vertx/kafka/admin/DescribeClusterOptionsConverter.java | 6 +++--- .../kafka/admin/DescribeConsumerGroupsOptionsConverter.java | 6 +++--- .../vertx/kafka/admin/DescribeTopicsOptionsConverter.java | 6 +++--- .../admin/ListConsumerGroupOffsetsOptionsConverter.java | 6 +++--- .../vertx/kafka/admin/ListOffsetsResultInfoConverter.java | 6 +++--- .../io/vertx/kafka/admin/MemberAssignmentConverter.java | 6 +++--- .../io/vertx/kafka/admin/MemberDescriptionConverter.java | 6 +++--- .../io/vertx/kafka/admin/NewPartitionsConverter.java | 6 +++--- .../generated/io/vertx/kafka/admin/NewTopicConverter.java | 6 +++--- .../generated/io/vertx/kafka/admin/OffsetSpecConverter.java | 6 +++--- .../io/vertx/kafka/admin/TopicDescriptionConverter.java | 6 +++--- .../vertx/kafka/client/common/ConfigResourceConverter.java | 6 +++--- .../kafka/client/common/KafkaClientOptionsConverter.java | 6 +++--- .../vertx/kafka/client/common/PartitionInfoConverter.java | 6 +++--- .../kafka/client/common/TopicPartitionInfoConverter.java | 6 +++--- src/main/java/io/vertx/kafka/admin/ClusterDescription.java | 4 +++- src/main/java/io/vertx/kafka/admin/Config.java | 4 +++- src/main/java/io/vertx/kafka/admin/ConfigEntry.java | 4 +++- src/main/java/io/vertx/kafka/admin/ConfigSynonym.java | 4 +++- .../java/io/vertx/kafka/admin/ConsumerGroupDescription.java | 4 +++- .../java/io/vertx/kafka/admin/ConsumerGroupListing.java | 4 +++- .../java/io/vertx/kafka/admin/DescribeClusterOptions.java | 6 ++++-- .../io/vertx/kafka/admin/DescribeConsumerGroupsOptions.java | 4 +++- .../java/io/vertx/kafka/admin/DescribeTopicsOptions.java | 4 +++- .../vertx/kafka/admin/ListConsumerGroupOffsetsOptions.java | 4 +++- .../java/io/vertx/kafka/admin/ListOffsetsResultInfo.java | 4 +++- src/main/java/io/vertx/kafka/admin/MemberAssignment.java | 4 +++- src/main/java/io/vertx/kafka/admin/MemberDescription.java | 4 +++- src/main/java/io/vertx/kafka/admin/NewPartitions.java | 4 +++- src/main/java/io/vertx/kafka/admin/NewTopic.java | 4 +++- src/main/java/io/vertx/kafka/admin/OffsetSpec.java | 4 +++- src/main/java/io/vertx/kafka/admin/TopicDescription.java | 4 +++- .../java/io/vertx/kafka/client/common/ConfigResource.java | 4 +++- .../io/vertx/kafka/client/common/KafkaClientOptions.java | 4 +++- .../java/io/vertx/kafka/client/common/PartitionInfo.java | 4 +++- .../io/vertx/kafka/client/common/TopicPartitionInfo.java | 4 +++- 42 files changed, 127 insertions(+), 85 deletions(-) diff --git a/src/main/generated/io/vertx/kafka/admin/ClusterDescriptionConverter.java b/src/main/generated/io/vertx/kafka/admin/ClusterDescriptionConverter.java index 3a1bad39..253d1415 100644 --- a/src/main/generated/io/vertx/kafka/admin/ClusterDescriptionConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/ClusterDescriptionConverter.java @@ -17,7 +17,7 @@ public class ClusterDescriptionConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, ClusterDescription obj) { + static void fromJson(Iterable> json, ClusterDescription obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "nodes": @@ -54,11 +54,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(ClusterDescription obj, JsonObject json) { + static void toJson(ClusterDescription obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(ClusterDescription obj, java.util.Map json) { + static void toJson(ClusterDescription obj, java.util.Map json) { if (obj.getNodes() != null) { JsonArray array = new JsonArray(); obj.getNodes().forEach(item -> array.add(item.toJson())); diff --git a/src/main/generated/io/vertx/kafka/admin/ConfigConverter.java b/src/main/generated/io/vertx/kafka/admin/ConfigConverter.java index d8119864..bb886a43 100644 --- a/src/main/generated/io/vertx/kafka/admin/ConfigConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/ConfigConverter.java @@ -17,7 +17,7 @@ public class ConfigConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, Config obj) { + static void fromJson(Iterable> json, Config obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "entries": @@ -34,11 +34,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(Config obj, JsonObject json) { + static void toJson(Config obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(Config obj, java.util.Map json) { + static void toJson(Config obj, java.util.Map json) { if (obj.getEntries() != null) { JsonArray array = new JsonArray(); obj.getEntries().forEach(item -> array.add(item.toJson())); diff --git a/src/main/generated/io/vertx/kafka/admin/ConfigEntryConverter.java b/src/main/generated/io/vertx/kafka/admin/ConfigEntryConverter.java index c28bd5dc..c1d6867c 100644 --- a/src/main/generated/io/vertx/kafka/admin/ConfigEntryConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/ConfigEntryConverter.java @@ -17,7 +17,7 @@ public class ConfigEntryConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, ConfigEntry obj) { + static void fromJson(Iterable> json, ConfigEntry obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "name": @@ -64,11 +64,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(ConfigEntry obj, JsonObject json) { + static void toJson(ConfigEntry obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(ConfigEntry obj, java.util.Map json) { + static void toJson(ConfigEntry obj, java.util.Map json) { if (obj.getName() != null) { json.put("name", obj.getName()); } diff --git a/src/main/generated/io/vertx/kafka/admin/ConfigSynonymConverter.java b/src/main/generated/io/vertx/kafka/admin/ConfigSynonymConverter.java index 0e893e4d..a967d3b6 100644 --- a/src/main/generated/io/vertx/kafka/admin/ConfigSynonymConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/ConfigSynonymConverter.java @@ -17,7 +17,7 @@ public class ConfigSynonymConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, ConfigSynonym obj) { + static void fromJson(Iterable> json, ConfigSynonym obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "name": @@ -39,11 +39,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(ConfigSynonym obj, JsonObject json) { + static void toJson(ConfigSynonym obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(ConfigSynonym obj, java.util.Map json) { + static void toJson(ConfigSynonym obj, java.util.Map json) { if (obj.getName() != null) { json.put("name", obj.getName()); } diff --git a/src/main/generated/io/vertx/kafka/admin/ConsumerGroupDescriptionConverter.java b/src/main/generated/io/vertx/kafka/admin/ConsumerGroupDescriptionConverter.java index 379b9dde..8b019a17 100644 --- a/src/main/generated/io/vertx/kafka/admin/ConsumerGroupDescriptionConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/ConsumerGroupDescriptionConverter.java @@ -17,7 +17,7 @@ public class ConsumerGroupDescriptionConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, ConsumerGroupDescription obj) { + static void fromJson(Iterable> json, ConsumerGroupDescription obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "groupId": @@ -69,11 +69,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(ConsumerGroupDescription obj, JsonObject json) { + static void toJson(ConsumerGroupDescription obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(ConsumerGroupDescription obj, java.util.Map json) { + static void toJson(ConsumerGroupDescription obj, java.util.Map json) { if (obj.getGroupId() != null) { json.put("groupId", obj.getGroupId()); } diff --git a/src/main/generated/io/vertx/kafka/admin/ConsumerGroupListingConverter.java b/src/main/generated/io/vertx/kafka/admin/ConsumerGroupListingConverter.java index a391bcbc..07e09858 100644 --- a/src/main/generated/io/vertx/kafka/admin/ConsumerGroupListingConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/ConsumerGroupListingConverter.java @@ -17,7 +17,7 @@ public class ConsumerGroupListingConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, ConsumerGroupListing obj) { + static void fromJson(Iterable> json, ConsumerGroupListing obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "groupId": @@ -34,11 +34,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(ConsumerGroupListing obj, JsonObject json) { + static void toJson(ConsumerGroupListing obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(ConsumerGroupListing obj, java.util.Map json) { + static void toJson(ConsumerGroupListing obj, java.util.Map json) { if (obj.getGroupId() != null) { json.put("groupId", obj.getGroupId()); } diff --git a/src/main/generated/io/vertx/kafka/admin/DescribeClusterOptionsConverter.java b/src/main/generated/io/vertx/kafka/admin/DescribeClusterOptionsConverter.java index 5828ae56..f4a3437c 100644 --- a/src/main/generated/io/vertx/kafka/admin/DescribeClusterOptionsConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/DescribeClusterOptionsConverter.java @@ -17,17 +17,17 @@ public class DescribeClusterOptionsConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, DescribeClusterOptions obj) { + static void fromJson(Iterable> json, DescribeClusterOptions obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { } } } - public static void toJson(DescribeClusterOptions obj, JsonObject json) { + static void toJson(DescribeClusterOptions obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(DescribeClusterOptions obj, java.util.Map json) { + static void toJson(DescribeClusterOptions obj, java.util.Map json) { } } diff --git a/src/main/generated/io/vertx/kafka/admin/DescribeConsumerGroupsOptionsConverter.java b/src/main/generated/io/vertx/kafka/admin/DescribeConsumerGroupsOptionsConverter.java index 6d59c195..fb1d3950 100644 --- a/src/main/generated/io/vertx/kafka/admin/DescribeConsumerGroupsOptionsConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/DescribeConsumerGroupsOptionsConverter.java @@ -17,17 +17,17 @@ public class DescribeConsumerGroupsOptionsConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, DescribeConsumerGroupsOptions obj) { + static void fromJson(Iterable> json, DescribeConsumerGroupsOptions obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { } } } - public static void toJson(DescribeConsumerGroupsOptions obj, JsonObject json) { + static void toJson(DescribeConsumerGroupsOptions obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(DescribeConsumerGroupsOptions obj, java.util.Map json) { + static void toJson(DescribeConsumerGroupsOptions obj, java.util.Map json) { } } diff --git a/src/main/generated/io/vertx/kafka/admin/DescribeTopicsOptionsConverter.java b/src/main/generated/io/vertx/kafka/admin/DescribeTopicsOptionsConverter.java index ffae4e39..095e8129 100644 --- a/src/main/generated/io/vertx/kafka/admin/DescribeTopicsOptionsConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/DescribeTopicsOptionsConverter.java @@ -17,17 +17,17 @@ public class DescribeTopicsOptionsConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, DescribeTopicsOptions obj) { + static void fromJson(Iterable> json, DescribeTopicsOptions obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { } } } - public static void toJson(DescribeTopicsOptions obj, JsonObject json) { + static void toJson(DescribeTopicsOptions obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(DescribeTopicsOptions obj, java.util.Map json) { + static void toJson(DescribeTopicsOptions obj, java.util.Map json) { } } diff --git a/src/main/generated/io/vertx/kafka/admin/ListConsumerGroupOffsetsOptionsConverter.java b/src/main/generated/io/vertx/kafka/admin/ListConsumerGroupOffsetsOptionsConverter.java index 8d632fa4..92824e85 100644 --- a/src/main/generated/io/vertx/kafka/admin/ListConsumerGroupOffsetsOptionsConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/ListConsumerGroupOffsetsOptionsConverter.java @@ -17,17 +17,17 @@ public class ListConsumerGroupOffsetsOptionsConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, ListConsumerGroupOffsetsOptions obj) { + static void fromJson(Iterable> json, ListConsumerGroupOffsetsOptions obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { } } } - public static void toJson(ListConsumerGroupOffsetsOptions obj, JsonObject json) { + static void toJson(ListConsumerGroupOffsetsOptions obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(ListConsumerGroupOffsetsOptions obj, java.util.Map json) { + static void toJson(ListConsumerGroupOffsetsOptions obj, java.util.Map json) { } } diff --git a/src/main/generated/io/vertx/kafka/admin/ListOffsetsResultInfoConverter.java b/src/main/generated/io/vertx/kafka/admin/ListOffsetsResultInfoConverter.java index 855cbd06..5b82b196 100644 --- a/src/main/generated/io/vertx/kafka/admin/ListOffsetsResultInfoConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/ListOffsetsResultInfoConverter.java @@ -17,7 +17,7 @@ public class ListOffsetsResultInfoConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, ListOffsetsResultInfo obj) { + static void fromJson(Iterable> json, ListOffsetsResultInfo obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "offset": @@ -39,11 +39,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(ListOffsetsResultInfo obj, JsonObject json) { + static void toJson(ListOffsetsResultInfo obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(ListOffsetsResultInfo obj, java.util.Map json) { + static void toJson(ListOffsetsResultInfo obj, java.util.Map json) { json.put("offset", obj.getOffset()); json.put("timestamp", obj.getTimestamp()); if (obj.getLeaderEpoch() != null) { diff --git a/src/main/generated/io/vertx/kafka/admin/MemberAssignmentConverter.java b/src/main/generated/io/vertx/kafka/admin/MemberAssignmentConverter.java index 023d5bc1..c3d4aa56 100644 --- a/src/main/generated/io/vertx/kafka/admin/MemberAssignmentConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/MemberAssignmentConverter.java @@ -17,7 +17,7 @@ public class MemberAssignmentConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, MemberAssignment obj) { + static void fromJson(Iterable> json, MemberAssignment obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "topicPartitions": @@ -34,11 +34,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(MemberAssignment obj, JsonObject json) { + static void toJson(MemberAssignment obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(MemberAssignment obj, java.util.Map json) { + static void toJson(MemberAssignment obj, java.util.Map json) { if (obj.getTopicPartitions() != null) { JsonArray array = new JsonArray(); obj.getTopicPartitions().forEach(item -> array.add(item.toJson())); diff --git a/src/main/generated/io/vertx/kafka/admin/MemberDescriptionConverter.java b/src/main/generated/io/vertx/kafka/admin/MemberDescriptionConverter.java index 645df24b..27a05993 100644 --- a/src/main/generated/io/vertx/kafka/admin/MemberDescriptionConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/MemberDescriptionConverter.java @@ -17,7 +17,7 @@ public class MemberDescriptionConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, MemberDescription obj) { + static void fromJson(Iterable> json, MemberDescription obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "consumerId": @@ -44,11 +44,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(MemberDescription obj, JsonObject json) { + static void toJson(MemberDescription obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(MemberDescription obj, java.util.Map json) { + static void toJson(MemberDescription obj, java.util.Map json) { if (obj.getConsumerId() != null) { json.put("consumerId", obj.getConsumerId()); } diff --git a/src/main/generated/io/vertx/kafka/admin/NewPartitionsConverter.java b/src/main/generated/io/vertx/kafka/admin/NewPartitionsConverter.java index 3c920b67..cb37234e 100644 --- a/src/main/generated/io/vertx/kafka/admin/NewPartitionsConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/NewPartitionsConverter.java @@ -17,7 +17,7 @@ public class NewPartitionsConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, NewPartitions obj) { + static void fromJson(Iterable> json, NewPartitions obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "totalCount": @@ -29,11 +29,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(NewPartitions obj, JsonObject json) { + static void toJson(NewPartitions obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(NewPartitions obj, java.util.Map json) { + static void toJson(NewPartitions obj, java.util.Map json) { json.put("totalCount", obj.getTotalCount()); } } diff --git a/src/main/generated/io/vertx/kafka/admin/NewTopicConverter.java b/src/main/generated/io/vertx/kafka/admin/NewTopicConverter.java index 9aeaf578..2e60e8aa 100644 --- a/src/main/generated/io/vertx/kafka/admin/NewTopicConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/NewTopicConverter.java @@ -17,7 +17,7 @@ public class NewTopicConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, NewTopic obj) { + static void fromJson(Iterable> json, NewTopic obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "name": @@ -49,11 +49,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(NewTopic obj, JsonObject json) { + static void toJson(NewTopic obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(NewTopic obj, java.util.Map json) { + static void toJson(NewTopic obj, java.util.Map json) { if (obj.getName() != null) { json.put("name", obj.getName()); } diff --git a/src/main/generated/io/vertx/kafka/admin/OffsetSpecConverter.java b/src/main/generated/io/vertx/kafka/admin/OffsetSpecConverter.java index f9ad4eac..f013bfff 100644 --- a/src/main/generated/io/vertx/kafka/admin/OffsetSpecConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/OffsetSpecConverter.java @@ -17,7 +17,7 @@ public class OffsetSpecConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, OffsetSpec obj) { + static void fromJson(Iterable> json, OffsetSpec obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "spec": @@ -29,11 +29,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(OffsetSpec obj, JsonObject json) { + static void toJson(OffsetSpec obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(OffsetSpec obj, java.util.Map json) { + static void toJson(OffsetSpec obj, java.util.Map json) { json.put("spec", obj.getSpec()); } } diff --git a/src/main/generated/io/vertx/kafka/admin/TopicDescriptionConverter.java b/src/main/generated/io/vertx/kafka/admin/TopicDescriptionConverter.java index 50e12572..371c4bd5 100644 --- a/src/main/generated/io/vertx/kafka/admin/TopicDescriptionConverter.java +++ b/src/main/generated/io/vertx/kafka/admin/TopicDescriptionConverter.java @@ -17,7 +17,7 @@ public class TopicDescriptionConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, TopicDescription obj) { + static void fromJson(Iterable> json, TopicDescription obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "internal": @@ -54,11 +54,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(TopicDescription obj, JsonObject json) { + static void toJson(TopicDescription obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(TopicDescription obj, java.util.Map json) { + static void toJson(TopicDescription obj, java.util.Map json) { json.put("internal", obj.isInternal()); if (obj.getName() != null) { json.put("name", obj.getName()); diff --git a/src/main/generated/io/vertx/kafka/client/common/ConfigResourceConverter.java b/src/main/generated/io/vertx/kafka/client/common/ConfigResourceConverter.java index 11d44e23..46edd9fe 100644 --- a/src/main/generated/io/vertx/kafka/client/common/ConfigResourceConverter.java +++ b/src/main/generated/io/vertx/kafka/client/common/ConfigResourceConverter.java @@ -17,7 +17,7 @@ public class ConfigResourceConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, ConfigResource obj) { + static void fromJson(Iterable> json, ConfigResource obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "name": @@ -39,11 +39,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(ConfigResource obj, JsonObject json) { + static void toJson(ConfigResource obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(ConfigResource obj, java.util.Map json) { + static void toJson(ConfigResource obj, java.util.Map json) { if (obj.getName() != null) { json.put("name", obj.getName()); } diff --git a/src/main/generated/io/vertx/kafka/client/common/KafkaClientOptionsConverter.java b/src/main/generated/io/vertx/kafka/client/common/KafkaClientOptionsConverter.java index 14ad9b23..9084729d 100644 --- a/src/main/generated/io/vertx/kafka/client/common/KafkaClientOptionsConverter.java +++ b/src/main/generated/io/vertx/kafka/client/common/KafkaClientOptionsConverter.java @@ -17,7 +17,7 @@ public class KafkaClientOptionsConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, KafkaClientOptions obj) { + static void fromJson(Iterable> json, KafkaClientOptions obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "config": @@ -44,11 +44,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(KafkaClientOptions obj, JsonObject json) { + static void toJson(KafkaClientOptions obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(KafkaClientOptions obj, java.util.Map json) { + static void toJson(KafkaClientOptions obj, java.util.Map json) { if (obj.getConfig() != null) { JsonObject map = new JsonObject(); obj.getConfig().forEach((key, value) -> map.put(key, value)); diff --git a/src/main/generated/io/vertx/kafka/client/common/PartitionInfoConverter.java b/src/main/generated/io/vertx/kafka/client/common/PartitionInfoConverter.java index 05b11d7a..5430595d 100644 --- a/src/main/generated/io/vertx/kafka/client/common/PartitionInfoConverter.java +++ b/src/main/generated/io/vertx/kafka/client/common/PartitionInfoConverter.java @@ -17,7 +17,7 @@ public class PartitionInfoConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, PartitionInfo obj) { + static void fromJson(Iterable> json, PartitionInfo obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "inSyncReplicas": @@ -59,11 +59,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(PartitionInfo obj, JsonObject json) { + static void toJson(PartitionInfo obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(PartitionInfo obj, java.util.Map json) { + static void toJson(PartitionInfo obj, java.util.Map json) { if (obj.getInSyncReplicas() != null) { JsonArray array = new JsonArray(); obj.getInSyncReplicas().forEach(item -> array.add(item.toJson())); diff --git a/src/main/generated/io/vertx/kafka/client/common/TopicPartitionInfoConverter.java b/src/main/generated/io/vertx/kafka/client/common/TopicPartitionInfoConverter.java index 3d12cf7f..4e4c7d28 100644 --- a/src/main/generated/io/vertx/kafka/client/common/TopicPartitionInfoConverter.java +++ b/src/main/generated/io/vertx/kafka/client/common/TopicPartitionInfoConverter.java @@ -17,7 +17,7 @@ public class TopicPartitionInfoConverter { private static final Base64.Decoder BASE64_DECODER = JsonUtil.BASE64_DECODER; private static final Base64.Encoder BASE64_ENCODER = JsonUtil.BASE64_ENCODER; - public static void fromJson(Iterable> json, TopicPartitionInfo obj) { + static void fromJson(Iterable> json, TopicPartitionInfo obj) { for (java.util.Map.Entry member : json) { switch (member.getKey()) { case "isr": @@ -54,11 +54,11 @@ public static void fromJson(Iterable> json, } } - public static void toJson(TopicPartitionInfo obj, JsonObject json) { + static void toJson(TopicPartitionInfo obj, JsonObject json) { toJson(obj, json.getMap()); } - public static void toJson(TopicPartitionInfo obj, java.util.Map json) { + static void toJson(TopicPartitionInfo obj, java.util.Map json) { if (obj.getIsr() != null) { JsonArray array = new JsonArray(); obj.getIsr().forEach(item -> array.add(item.toJson())); diff --git a/src/main/java/io/vertx/kafka/admin/ClusterDescription.java b/src/main/java/io/vertx/kafka/admin/ClusterDescription.java index 9b5f8709..83b017d3 100644 --- a/src/main/java/io/vertx/kafka/admin/ClusterDescription.java +++ b/src/main/java/io/vertx/kafka/admin/ClusterDescription.java @@ -17,6 +17,7 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import io.vertx.kafka.client.common.Node; @@ -30,7 +31,8 @@ /** * A detailed description of the cluster */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class ClusterDescription { private String clusterId; private Node controller; diff --git a/src/main/java/io/vertx/kafka/admin/Config.java b/src/main/java/io/vertx/kafka/admin/Config.java index 048b600a..94b30365 100644 --- a/src/main/java/io/vertx/kafka/admin/Config.java +++ b/src/main/java/io/vertx/kafka/admin/Config.java @@ -17,6 +17,7 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import java.util.List; @@ -24,7 +25,8 @@ /** * A configuration object containing the configuration entries for a resource */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class Config { private List entries; diff --git a/src/main/java/io/vertx/kafka/admin/ConfigEntry.java b/src/main/java/io/vertx/kafka/admin/ConfigEntry.java index 6eebd131..cb0df6a0 100644 --- a/src/main/java/io/vertx/kafka/admin/ConfigEntry.java +++ b/src/main/java/io/vertx/kafka/admin/ConfigEntry.java @@ -17,6 +17,7 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import org.apache.kafka.clients.admin.ConfigEntry.ConfigSource; @@ -25,7 +26,8 @@ /** * A class representing a configuration entry containing name, value and additional metadata */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class ConfigEntry { private String name; diff --git a/src/main/java/io/vertx/kafka/admin/ConfigSynonym.java b/src/main/java/io/vertx/kafka/admin/ConfigSynonym.java index e3af2171..82404430 100644 --- a/src/main/java/io/vertx/kafka/admin/ConfigSynonym.java +++ b/src/main/java/io/vertx/kafka/admin/ConfigSynonym.java @@ -17,13 +17,15 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import org.apache.kafka.clients.admin.ConfigEntry.ConfigSource; /** * Class representing a configuration synonym of a {@link ConfigEntry} */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class ConfigSynonym { private String name; diff --git a/src/main/java/io/vertx/kafka/admin/ConsumerGroupDescription.java b/src/main/java/io/vertx/kafka/admin/ConsumerGroupDescription.java index ccaacee0..2eea5b93 100644 --- a/src/main/java/io/vertx/kafka/admin/ConsumerGroupDescription.java +++ b/src/main/java/io/vertx/kafka/admin/ConsumerGroupDescription.java @@ -17,6 +17,7 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import io.vertx.kafka.client.common.Node; import org.apache.kafka.common.ConsumerGroupState; @@ -28,7 +29,8 @@ /** * A detailed description of a single consumer group in the cluster */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class ConsumerGroupDescription { private String groupId; diff --git a/src/main/java/io/vertx/kafka/admin/ConsumerGroupListing.java b/src/main/java/io/vertx/kafka/admin/ConsumerGroupListing.java index 20fb7678..5e738a5d 100644 --- a/src/main/java/io/vertx/kafka/admin/ConsumerGroupListing.java +++ b/src/main/java/io/vertx/kafka/admin/ConsumerGroupListing.java @@ -17,12 +17,14 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; /** * A listing of a consumer group in the cluster. */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class ConsumerGroupListing { private String groupId; diff --git a/src/main/java/io/vertx/kafka/admin/DescribeClusterOptions.java b/src/main/java/io/vertx/kafka/admin/DescribeClusterOptions.java index 1787788f..3324982a 100644 --- a/src/main/java/io/vertx/kafka/admin/DescribeClusterOptions.java +++ b/src/main/java/io/vertx/kafka/admin/DescribeClusterOptions.java @@ -17,9 +17,11 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class DescribeClusterOptions { private boolean includeAuthorizedOperations; @@ -69,5 +71,5 @@ public String toString() { "includeAuthorizedOperations=" + includeAuthorizedOperations + '}'; } - + } diff --git a/src/main/java/io/vertx/kafka/admin/DescribeConsumerGroupsOptions.java b/src/main/java/io/vertx/kafka/admin/DescribeConsumerGroupsOptions.java index bf32f7a3..8f090a67 100644 --- a/src/main/java/io/vertx/kafka/admin/DescribeConsumerGroupsOptions.java +++ b/src/main/java/io/vertx/kafka/admin/DescribeConsumerGroupsOptions.java @@ -17,9 +17,11 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class DescribeConsumerGroupsOptions { private boolean includeAuthorizedOperations; diff --git a/src/main/java/io/vertx/kafka/admin/DescribeTopicsOptions.java b/src/main/java/io/vertx/kafka/admin/DescribeTopicsOptions.java index 8f8e3425..22237fd9 100644 --- a/src/main/java/io/vertx/kafka/admin/DescribeTopicsOptions.java +++ b/src/main/java/io/vertx/kafka/admin/DescribeTopicsOptions.java @@ -17,9 +17,11 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class DescribeTopicsOptions { private boolean includeAuthorizedOperations; diff --git a/src/main/java/io/vertx/kafka/admin/ListConsumerGroupOffsetsOptions.java b/src/main/java/io/vertx/kafka/admin/ListConsumerGroupOffsetsOptions.java index 4aad7f30..2e055103 100644 --- a/src/main/java/io/vertx/kafka/admin/ListConsumerGroupOffsetsOptions.java +++ b/src/main/java/io/vertx/kafka/admin/ListConsumerGroupOffsetsOptions.java @@ -17,11 +17,13 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import io.vertx.kafka.client.common.TopicPartition; import java.util.List; -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class ListConsumerGroupOffsetsOptions { private List topicPartitions = null; diff --git a/src/main/java/io/vertx/kafka/admin/ListOffsetsResultInfo.java b/src/main/java/io/vertx/kafka/admin/ListOffsetsResultInfo.java index 14a694ec..7f9ee6f7 100644 --- a/src/main/java/io/vertx/kafka/admin/ListOffsetsResultInfo.java +++ b/src/main/java/io/vertx/kafka/admin/ListOffsetsResultInfo.java @@ -17,9 +17,11 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class ListOffsetsResultInfo { private long offset; private long timestamp; diff --git a/src/main/java/io/vertx/kafka/admin/MemberAssignment.java b/src/main/java/io/vertx/kafka/admin/MemberAssignment.java index c7464732..ac1e62b3 100644 --- a/src/main/java/io/vertx/kafka/admin/MemberAssignment.java +++ b/src/main/java/io/vertx/kafka/admin/MemberAssignment.java @@ -17,6 +17,7 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import io.vertx.kafka.client.common.TopicPartition; @@ -25,7 +26,8 @@ /** * A description of the assignments of a specific group member */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class MemberAssignment { private Set topicPartitions; diff --git a/src/main/java/io/vertx/kafka/admin/MemberDescription.java b/src/main/java/io/vertx/kafka/admin/MemberDescription.java index 3e6ef1c7..e01d7054 100644 --- a/src/main/java/io/vertx/kafka/admin/MemberDescription.java +++ b/src/main/java/io/vertx/kafka/admin/MemberDescription.java @@ -17,12 +17,14 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; /** * A detailed description of a single group instance in the cluster */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class MemberDescription { private String consumerId; diff --git a/src/main/java/io/vertx/kafka/admin/NewPartitions.java b/src/main/java/io/vertx/kafka/admin/NewPartitions.java index 16559fc6..e2acde88 100644 --- a/src/main/java/io/vertx/kafka/admin/NewPartitions.java +++ b/src/main/java/io/vertx/kafka/admin/NewPartitions.java @@ -17,6 +17,7 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import java.util.List; @@ -26,7 +27,8 @@ * Partitions can be increased only. If decrease, an exception from Kafka broker is received. * If no assignment is specifies brokers will randomly assign the partitions. */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class NewPartitions { private int totalCount; diff --git a/src/main/java/io/vertx/kafka/admin/NewTopic.java b/src/main/java/io/vertx/kafka/admin/NewTopic.java index abde4cc9..8a2501fa 100644 --- a/src/main/java/io/vertx/kafka/admin/NewTopic.java +++ b/src/main/java/io/vertx/kafka/admin/NewTopic.java @@ -17,6 +17,7 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import java.util.List; @@ -25,7 +26,8 @@ /** * A new topic to be created */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class NewTopic { private String name; diff --git a/src/main/java/io/vertx/kafka/admin/OffsetSpec.java b/src/main/java/io/vertx/kafka/admin/OffsetSpec.java index d48f8d9d..743a8f0c 100644 --- a/src/main/java/io/vertx/kafka/admin/OffsetSpec.java +++ b/src/main/java/io/vertx/kafka/admin/OffsetSpec.java @@ -17,9 +17,11 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class OffsetSpec { public final static OffsetSpec EARLIEST = new OffsetSpec(-2L); public final static OffsetSpec LATEST = new OffsetSpec(-1L); diff --git a/src/main/java/io/vertx/kafka/admin/TopicDescription.java b/src/main/java/io/vertx/kafka/admin/TopicDescription.java index ba15e527..b3dfa147 100644 --- a/src/main/java/io/vertx/kafka/admin/TopicDescription.java +++ b/src/main/java/io/vertx/kafka/admin/TopicDescription.java @@ -17,6 +17,7 @@ package io.vertx.kafka.admin; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import io.vertx.kafka.client.common.TopicPartitionInfo; import org.apache.kafka.common.Uuid; @@ -28,7 +29,8 @@ /** * A detailed description of a single topic in the cluster */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class TopicDescription { private boolean isInternal; diff --git a/src/main/java/io/vertx/kafka/client/common/ConfigResource.java b/src/main/java/io/vertx/kafka/client/common/ConfigResource.java index 41c69d58..5b2ae230 100644 --- a/src/main/java/io/vertx/kafka/client/common/ConfigResource.java +++ b/src/main/java/io/vertx/kafka/client/common/ConfigResource.java @@ -17,13 +17,15 @@ package io.vertx.kafka.client.common; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import org.apache.kafka.common.config.ConfigResource.Type; /** * A class representing resources that have configuration */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class ConfigResource { private String name; diff --git a/src/main/java/io/vertx/kafka/client/common/KafkaClientOptions.java b/src/main/java/io/vertx/kafka/client/common/KafkaClientOptions.java index e8ca2cfd..a49bc387 100644 --- a/src/main/java/io/vertx/kafka/client/common/KafkaClientOptions.java +++ b/src/main/java/io/vertx/kafka/client/common/KafkaClientOptions.java @@ -17,6 +17,7 @@ import io.vertx.codegen.annotations.DataObject; import io.vertx.codegen.annotations.GenIgnore; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import io.vertx.core.tracing.TracingPolicy; import org.apache.kafka.clients.consumer.ConsumerConfig; @@ -29,7 +30,8 @@ /** * Generic KafkaClient options. */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class KafkaClientOptions { /** * Default peer address to set in traces tags is null, and will automatically pick up bootstrap server from config diff --git a/src/main/java/io/vertx/kafka/client/common/PartitionInfo.java b/src/main/java/io/vertx/kafka/client/common/PartitionInfo.java index 261ef7c8..49d211a1 100644 --- a/src/main/java/io/vertx/kafka/client/common/PartitionInfo.java +++ b/src/main/java/io/vertx/kafka/client/common/PartitionInfo.java @@ -17,6 +17,7 @@ package io.vertx.kafka.client.common; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import java.util.List; @@ -24,7 +25,8 @@ /** * Information about a specific Kafka topic partition */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class PartitionInfo { private List inSyncReplicas; diff --git a/src/main/java/io/vertx/kafka/client/common/TopicPartitionInfo.java b/src/main/java/io/vertx/kafka/client/common/TopicPartitionInfo.java index e17c3e76..d7443c4e 100644 --- a/src/main/java/io/vertx/kafka/client/common/TopicPartitionInfo.java +++ b/src/main/java/io/vertx/kafka/client/common/TopicPartitionInfo.java @@ -17,6 +17,7 @@ package io.vertx.kafka.client.common; import io.vertx.codegen.annotations.DataObject; +import io.vertx.codegen.json.annotations.JsonGen; import io.vertx.core.json.JsonObject; import java.util.List; @@ -24,7 +25,8 @@ /** * A class containing leadership, replicas and ISR information for a topic partition. */ -@DataObject(generateConverter = true) +@DataObject +@JsonGen(publicConverter = false) public class TopicPartitionInfo { private List isr;