equivalenceUpdatingMessageListener is an Optional<KafkaConsumer>
clean up from test