Github user nickwallen commented on a diff in the pull request:
https://github.com/apache/metron/pull/1082#discussion_r199613819
--- Diff:
metron-platform/metron-writer/src/main/java/org/apache/metron/writer/kafka/KafkaWriter.java
---
@@ -197,6 +209,15 @@ public void init(Map stormConf, TopologyContext
topologyContext, WriterConfigura
return producerConfig;
}
+ public Optional<String> getKafkaTopic(JSONObject message) {
--- End diff --
Ok, that makes sense to me. A user would have to take additional steps to
really shoot their self in the foot here. If 'topic field' was a global
setting this might happen, but its not.
I agree with you. I don't think there is anything we need to change here.
---
