Apache Kafka distributed publish-subscribe messaging system test