kafka-connect-protobuf-converter issues

StackOverflow Exception while using my own protoClassName having field type google.protobuf.Struct

3

Hi, I'm using protobuf-converter for S3 sink connector for ingesting protobuf from kafka to S3. my sink config looks like - Map.entry("connector.class", "io.confluent.connect.s3.S3SinkConnector"), Map.entry("topics", "topicName"), Map.entry("tasks.max", 1), Map.entry("flush.size", 100), Map.entry("rotate.schedule.interval.ms",...

akanungoz

Fixed bug that was leading to failure in avro format

3

If you have a protobuf file like this MessageA{ MessageB hello = 1; } MessageB{ MessageC hello = 1; } MessageC{ String abc =1; } Then this would result in...

ashishmalgawa

Proto class is not a valid proto3 message class

2

Hello, I've installed protobuf convertor and build my own protobuf definition jar. I've put it into ../confluent/share/java/kafka-serde-tools/ directory in my connector definition I set up `"value.converter.protoClassName":"com.rl.messaging.messages.BusinessEventMessages$BusinessEvent"` `when I'm starting connector...

iguenkinrl

Support for camelCase

3

Currently, `kafka-connect-protobuf-converter` converts proto messages to the object with keys in `snake_case`. It happens on line 71: [https://github.com/blueapron/kafka-connect-protobuf-converter/blob/master/src/main/java/com/blueapron/connect/protobuf/ProtobufData.java#L71](https://github.com/blueapron/kafka-connect-protobuf-converter/blob/master/src/main/java/com/blueapron/connect/protobuf/ProtobufData.java#L71) ```String name = descriptor.getName();``` Having an option that toggles between `snake_case` and...

darwinbeard

Fields with same name and different type can cause issue for avro sink

1

Assume a following simple protobuf schema ``` message NestedStruct_1 { optional int64 nestedField_1 } message NestedStruct_2 { optional int64 nestedField_2 } message Struct_1 { optional NestedStruct_1 nested = 1; }...

abhishekagarwal87