Add option to change Kafka Spout output field name

nathanmarz / storm-contrib

A collection of spouts, bolts, serializers, DSLs, and other goodies to use with Storm

Eclipse Public License 1.0

580 stars 340 forks source link

Add option to change Kafka Spout output field name #16

Open znewman01 opened 12 years ago

znewman01 commented 12 years ago

Previously, when using a StringScheme, the Kafka spout would always output the Kafka messages in a field called "str"; in this pull request, the constructor to StringScheme takes a parameter that can be used in place of "str", with "str" remaining the default.