kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nagendra Korrapati <nkorrap...@icloud.com.INVALID>
Subject Kafka Connect - AvroConverter - Unions with Enums Problem
Date Sat, 02 May 2020 17:22:43 GMT

Sorry to write this in this mailing list. This is more specific to my problem in using Kafka

I have Union with Enum in it. ToConnectSchema converted it into Schema.STRUCT type with fields
and the enum field as STRING. 

The SpeicficRecord has that enum field as of Type Enum class. 

But in AvroData class the method isInstanceOfAvroSchemaTypeForSimpleSchema compares value
is of  CharSequence instance. 

But in the SpecifiRecord the value type is Enum and it fails. So the end result the toConnectData
throws exception with the message 

“Did not find matching union field for data : enumstring”

Please some one comment!!

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message