Skip to content

Instantly share code, notes, and snippets.

@andrewstevenson

andrewstevenson/plumber-consumer-happy.sh

Created September 11, 2016 15:36
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save andrewstevenson/4139ea961829609e62a430790828f820 to your computer and use it in GitHub Desktop.
Save andrewstevenson/4139ea961829609e62a430790828f820 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
plumber-consumer-happy.sh
./plumber.sh -i nasty -d avro \
-o nice -s avro=nice.avsc \
-l flatten.lua -t flatten.test.lua \
-p nasty-to-nice.properties
2016-07-18 16:16:09,862 INFO [main] [com.eneco.energy.kafka.streams.plumber.StreamingOperations] [<init>:136] we output key-values of type KeyValueType(com.eneco.energy.kafka.streams.plumber.VoidType$@12468a38,AvroType(Some({"type":"record","name":"nice","namespace":"example","fields":[{"name":"elements","type":{"type":"array","items":{"type":"record","name":"element","namespace":"example.nice","fields":[{"name":"value","type":"string"},{"name":"id","type":"int"},{"name":"parent","type":"int"}]}}}]})))
2016-07-18 16:16:09,889 INFO [main] [com.eneco.energy.kafka.streams.plumber.Plumber$] [exec:37] OK, expectations provided in `flatten.test.lua` were met
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment