use kafka
equivalenceUpdatingMessageListener is an Optional<KafkaConsumer>
clean up from test
improve stringency of MessageQueueingResultHandlerTest
improve logging of messages received
encode message entity ids
decode ids in EquivalenceUpdatingWorker
Merge pull request #488 from atlasapi/kafka

Integrate Kafka