The issue: we have a legacy Kafka topic with a custom text message format (no JSON, CVS, TSV or anything supported).
Question1: Is it possible to build a customParser that knows how to parse the text messages?
Looking over the tranquility code it seems the StringInputRowParser is hardcoded for the Tranquility-Kafka ingestion flow.
We already tried building a druid-extension with a custom InputRowParser but it doesn’t seem to be used at runtime as the default parser (StringInputRowParser) is always chosen.
Question2: Does the custom extension need to be loaded only by the realtime node(tranquility) or also by the master(overlord)?