search

confluentinc / camus

Mirror of Linkedin's Camus
Apache License 2.0
0 stars 62 forks source link

Added new decoder to support Plain String Events from Kafka #20

Closed mvalleavila closed 8 years ago

mvalleavila commented 9 years ago

Added support to read plain String events. To use this decoder set the property camus.message.decoder.class to

camus.message.decoder.class=com.keedio.camus.etl.kafka.coders.StringMessageDecoder

The events will be stored in HDFS as plain Strings, the timestamp used in the events will be the current timestamp of the system.

ConfluentJenkins commented 9 years ago

Can one of the admins verify this patch?

ghost commented 9 years ago

It looks like @mvalleavila hasn't signed our Contributor License Agreement, yet.

Appreciation of efforts,

clabot

mvalleavila commented 9 years ago

[clabot:check]

ghost commented 9 years ago

@confluentinc It looks like @mvalleavila just signed our Contributor License Agreement. :+1:

Always at your service,

clabot

ewencp commented 8 years ago

Camus is also deprecated from CP 3.0.0 on and we won't be making further changes. This looks like a change that might have been better targeted at the upstream repository before it was deprecated, but also looks like there was a mismatch on the target branch anyway.