metron-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ryan Merriman <merrim...@gmail.com>
Subject Re: BulkMessageWriterBolt and MessageGetters
Date Tue, 07 Feb 2017 19:28:35 GMT
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, Feb 7, 2017 at 1:24 PM, Nick Allen <nick@nickallen.org> wrote:

> 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:
>             -   name: "withMessageWriter"
>                 args:
>                     - ref: "kafkaWriter"
>             -   name: "withMessageGetter"
>                 args:
>                     - "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
> "measurement".
>
> Am I missing something?  Is there a way to do this out-of-the-box?
>

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