diff --git a/test/plugin/test_in_kafka_group.rb b/test/plugin/test_in_kafka_group.rb
index 0637068..f2b100c 100644
--- a/test/plugin/test_in_kafka_group.rb
+++ b/test/plugin/test_in_kafka_group.rb
@@ -39,6 +39,7 @@ def test_multi_worker_support
   class ConsumeTest < self
     def setup
       @kafka = Kafka.new(["localhost:9092"], client_id: 'kafka')
+      @kafka.create_topic(TOPIC_NAME)
       @producer = @kafka.producer
     end
 
@@ -59,6 +60,7 @@ def test_consume
       d = create_driver
 
       d.run(expect_records: 1, timeout: 10) do
+        sleep 0.1
         @producer.produce("Hello, fluent-plugin-kafka!", topic: TOPIC_NAME)
         @producer.deliver_messages
       end