Add a test based on a test for Kafka.