Kafka Old Producer API使用样例

功能介绍

Producer是消息生产者的角色，负责发布消息到Kafka Broker。

下面代码片段在com.huawei.bigdata.kafka.example.Old_Producer类中，作用在于每秒向指定的Topic发送一条消息。（注意：Old Producer API仅支持通过不启用Kerberos认证模式端口访问未设置ACL的Topic，安全接口说明见Kafka安全接口介绍）

样例代码

Old Producer API的run方法中的逻辑

    /*
     * 启动执行producer，每秒发送一条消息。
     */
    public void run()
    {
        LOG.info("Old Producer: start.");
        int messageNo = 1;
        
        while (true)
        {
            String messageStr = new String("Message_" + messageNo);
            
            // 指定消息序号作为key值
            String key = String.valueOf(messageNo);
            producer.send(new KeyedMessage<String, String>(topic, key, messageStr));
            LOG.info("Producer: send " + messageStr + " to " + topic);
            messageNo++;
            
            // 每隔1s，发送1条消息
            try
            {
                Thread.sleep(1000);
            }
            catch (InterruptedException e)
            {
                e.printStackTrace();
            }
        }
    }