Apache Pinot

Any idea how to find the kafka serialization exception which is breaking my new real time confluent avro kafka flow. Im not finding the right log message/full stack trace.  I can see the controller is getting sent a segment exception update from I guess the server process.

See string deserializer hard-coded here <https://www.github.com/apache/pinot/tree/master/pinot-plugins%2Fpinot-stream-ingestion%2Fpinot-kafka-2.0%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fpinot%2Fplugin%2Fstream%2Fkafka20%2FKafkaPartitionLevelConnectionHandler.java|https://www.github.com/apache/pinot/tree/master/pinot-plugins%2Fpinot-stream-ingestion%2Fpinot-kafka-2.0%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fpinot%2Fplugin%2Fstream%2Fkafka20%2FKafkaPartitionLevelConnectionHandler.java>

Yeah you are right, it seems to be hardcoded. Do you mind filing an issue?

Created <https://github.com/apache/pinot/issues/7239|https://github.com/apache/pinot/issues/7239> thanks