adding initial code for kafka integration
add kafka_stream to swap package
adding code to replay space warps classifications through kafka