You are correct, the BulkMessageWriterBolt/MessageGetters combination is
not flexible enough. You would have to modify BulkMessageWriterBolt. I
have addressed this in METRON-695 which will be submitted as a PR shortly.
It will be easy to do what you want after that is merged in.
Ryan
On Tue
I am trying to use the `BulkMessageWriterBolt` to write a specific tuple
field named "measurement" to a Kafka topic.
- id: "kafkaBolt"
className: "org.apache.metron.writer.bolt.BulkMessageWriterBolt"
constructorArgs:
- "${kafka.zk}"
configMethods: