0.2.2

Release adds the following functionality:

• kafka config dictionaries are now templated fields
• the ConsumeFromTopicOperator has an additional kwarg to accept a function applied to a batch of messages.

Contributors:
@oboki
@dylanbstorey