我是Kafka的新人。我试图通过java应用程序发送消息，并在命令行提示符下使用它，但该消息没有显示在cli上。
以下是java代码：

package com.kafka.prj;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Properties;

import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.KafkaProducer;

public class KafkaProd {

    private static KafkaProducer<String, String> producer;

    public void initialize() {

        Properties props = new Properties();
         props.put("bootstrap.servers", "localhost:9092");
         props.put("acks", "all");
         props.put("retries", 0);
         props.put("batch.size", 16384);
         props.put("linger.ms", 1);
         props.put("buffer.memory", 33554432);
         props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
         props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

//          ProducerConfig producerConfig = new ProducerConfig(producerProps);
          producer = new KafkaProducer<String, String>(props);

    }
    public void publishMesssage() throws Exception{            

        producer.send(new ProducerRecord<String, String>("test1", "dummy text msg"));

      return;
    }

    public static void main(String[] args) {

         KafkaProd kafkaProducer = new KafkaProd();
         // Initialize producer
         kafkaProducer.initialize();            
         // Publish message
         try {
            kafkaProducer.publishMesssage();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
         //Close the producer
         producer.close();

    }

}

在cli中，下面是am用于使用上面代码中发送的消息的命令：

$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1 --from-beginning

上面的命令不显示任何内容，没有错误，没有输出。
我哪里做错了？