zoukankan      html  css  js  c++  java
  • Java访问kafka的时候java.nio.channels.ClosedChannelException解决办法

    import java.util.Properties;
    
    import kafka.javaapi.producer.Producer;
    import kafka.producer.KeyedMessage;
    import kafka.producer.ProducerConfig;
    
    public class KafkaTest2
    {
        public static void main(String[] args)
        {
            // 设置配置属性
            Properties props = new Properties();
            props.put("metadata.broker.list", "130.51.23.95:9092");
            props.put("serializer.class", "kafka.serializer.StringEncoder");
            // key.serializer.class默认为serializer.class
            props.put("key.serializer.class", "kafka.serializer.StringEncoder");
            // 可选配置,如果不配置,则使用默认的partitioner
    //        props.put("partitioner.class", "com.catt.kafka.demo.PartitionerDemo");
            // 触发acknowledgement机制,否则是fire and forget,可能会引起数据丢失
            // 值为0,1,-1,可以参考
            // http://kafka.apache.org/08/configuration.html
            props.put("request.required.acks", "1");
            ProducerConfig config = new ProducerConfig(props);
            
            // 创建producer
            Producer<String, String> producer = new Producer<String, String>(config);
            // 产生并发送消息
            long start = System.currentTimeMillis();
            KeyedMessage<String, String> data = new KeyedMessage<String, String>("test", "test123", "test123");
            producer.send(data);
            System.out.println("耗时:" + (System.currentTimeMillis() - start));
            // 关闭producer
            producer.close();
        }
    }

    运行之后,报一下错误:

    解决办法:

    修改  config/server.properties文件(多节点的话,每个节点都修改一下)

    上面的端口必须放开,并且写你的真实IP地址

  • 相关阅读:
    cocos2dx动画常见特效(转)
    cocos2dx常见Action(转)
    cocos2dx常见场景切换动画(转)
    android AlertDialog.Builder(Context context)换行
    使用NPOI操作Excel文件及其日期处理
    java jar文件打包成exe(Launch4j使用说明)
    知识日志2
    知识日记1
    框架体系对小软件作坊的 重要性 第二章
    框架体系对小软件作坊的 重要性 第一章
  • 原文地址:https://www.cnblogs.com/dragkiss/p/5662559.html
Copyright © 2011-2022 走看看