removed topology ID from bolt and spout case classes
renamed Kafka consumer classes
renamed subscriber references to consumer
relocated method
cleaned up client ID generation
getOffsetsBefore now returns an iteration of offsets