Re: Avro DeSerializeation Issue in Kafka Streams

2020-05-05 Thread Nagendra Korrapati
When specific.avro.reader is set to true Deserializer tries to create the instance of the Class. The class name is formed by reading the schema (writer schema) from schema registry and concatenating the namespace and record name. It is trying to create that instance and it is not found in the c

Kafka Connect - AvroConverter - Unions with Enums Problem

2020-05-02 Thread Nagendra Korrapati
Hello Sorry to write this in this mailing list. This is more specific to my problem in using Kafka Connect 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.

Re: Rocksdb Statistics

2020-04-22 Thread Nagendra Korrapati
ll/8256> > > The issue is fixed and will be included in 2.6.0, 2.4.2, 2.5.1.> > > I am sorry for any inconveniences.> > > Best,> > Bruno> > > On Wed, Apr 22, 2020 at 5:48 PM Nagendra Korrapati> > wrote:> > >> > > I am usi

Rocksdb Statistics

2020-04-22 Thread Nagendra Korrapati
I am using kafka-streams-2.4.0. My issue details : metrics.recording.level is set to DEBUG Still all the stream-state-metrics values recorded are all 0. (Ex: bytes-written-total etc.,) Changed the code in RocksDBStore class openDB method. Moved the call to maybeSetupMetricsRecorder b