From 15394e83361ea5035d08acb84030821cfceec95a Mon Sep 17 00:00:00 2001 From: ubiquitousbyte Date: Sun, 5 Oct 2025 17:17:46 +0200 Subject: [PATCH] use hasPresence instead of proto3 checks --- .../main/java/io/confluent/connect/protobuf/ProtobufData.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/protobuf-converter/src/main/java/io/confluent/connect/protobuf/ProtobufData.java b/protobuf-converter/src/main/java/io/confluent/connect/protobuf/ProtobufData.java index 4e84dc9794c..1fff714cc9c 100644 --- a/protobuf-converter/src/main/java/io/confluent/connect/protobuf/ProtobufData.java +++ b/protobuf-converter/src/main/java/io/confluent/connect/protobuf/ProtobufData.java @@ -1309,7 +1309,7 @@ private boolean isPrimitiveOrRepeated(FieldDescriptor fieldDescriptor) { } private boolean isOptional(FieldDescriptor fieldDescriptor) { - return fieldDescriptor.toProto().getProto3Optional() + return fieldDescriptor.hasPresence() || (supportOptionalForProto2 && hasOptionalKeyword(fieldDescriptor)); }