metron-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nick Allen <>
Subject BulkMessageWriterBolt and MessageGetters
Date Tue, 07 Feb 2017 19:24:21 GMT
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"
            - "${kafka.zk}"
            -   name: "withMessageWriter"
                    - ref: "kafkaWriter"
            -   name: "withMessageGetter"
                    - "measurement"

Rather than wanting the name of a field, it wants the name of a valid
`MessageGetters` enum; either RAW or NAMED.  It seems like there is no way
for me to plugin a `NamedMessageGetter` with a custom field name like

Am I missing something?  Is there a way to do this out-of-the-box?

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message