added support for output writers
added support for output writers
added support for labels
added support for JSON objects
removed label parsing logic
refactored the output writer: remove dependency on the [KafkaModule] MessageData class
updated signatures: JValue is now a natively handled type
import optimization and clean up
refactored output handlers for all modules
removed kexport
readability clean up
refactored TxConfig: moved ZKProxy into the module implementations
now shuts down all modules
modified path references for consistency with output flags
the Zookeeper Proxy instance is now passed in, so no need to close it
added local Zookeeper node
removing implicit runtime context where possible
partition manager consumers are now retrieved concurrently by default
clean up
updated