search

NetherlandsForensicInstitute / kafka-spout

Kafka consumer emitting messages as storm tuples
Apache License 2.0
103 stars 73 forks source link

Allow consumers to specify a serialization scheme. #11

Closed jrothfeder closed 9 years ago

jrothfeder commented 9 years ago

Serialization schemes are a convenient way for consumers to add deserialization logic right in the spout. Add the ability to set a scheme through the constructor.

akaIDIOT commented 9 years ago

Nice addition for those using Schemes, thanks :smile: I'll give this a go locally, but looks good to merge aside from the version in pom.xml.

jrothfeder commented 9 years ago

Sweet! Thanks for reviewing.