[shape.emitters]
kafka = shape_kafka:KafkaEmitter

[shape.stream_sources]
kafka = shape_kafka:KafkaStreamSource
