mirror of https://github.com/apache/druid.git
0bc9f9f303
Fixes KafkaEmitter not emitting queryType for a native query. The Event to JSON serialization was extracted to the external class: EventToJsonSerializer. This was done to simplify the testing logic for the serialization as well as extract the responsibility of serialization to the separate class. The logic builds ObjectNode incrementally based on the event .toMap method. Parsing each entry individually ensures that the Jackson polymorphic annotations are respected. Not respecting these annotation caused the missing of the queryType from output event. |
||
|---|---|---|
| .. | ||
| main | ||
| test/java/org/apache/druid/emitter/kafka | ||