专栏首页Jed的技术阶梯Kafka 0.8.2.2 Producer报错:java.net.ConnectException: Connection timed out: no further information

Kafka 0.8.2.2 Producer报错:java.net.ConnectException: Connection timed out: no further information

以下是一个简单的Kafka Producer代码:

package com.bonc.rdpe.spark.kafka08

import java.io.{BufferedReader, FileReader}
import java.util.Properties

import org.apache.kafka.clients.producer.{Callback, KafkaProducer, ProducerRecord, RecordMetadata}

/**
  * Author: YangYunhe
  * Description: 
  * Create: 2018/7/24 19:33
  */
object Kafka08Producer {

  def main(args: Array[String]): Unit = {

    val props = new Properties()

    props.put("bootstrap.servers", "jed:9095,jed:9096,jed:9097")
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer")

    val producer = new KafkaProducer[String, String](props)

    val br = new BufferedReader(new FileReader("D:\\data\\news_profile_data.txt"))
    var line = ""

    while((line = br.readLine()) != null) {
      val record = new ProducerRecord[String, String]("topic001", line)
      producer.send(record, new Callback {
        override def onCompletion(recordMetadata: RecordMetadata, e: Exception): Unit = {
          if(recordMetadata != null) {
            println(s"topic: ${recordMetadata.topic()}, partition: ${recordMetadata.partition()}, offset: ${recordMetadata.offset()}")
          }
          if(e != null) {
            e.printStackTrace()
          }
        }
      })
      Thread.sleep(1000)
    }

    producer.close()
  }
}

运行后程序报错:

java.net.ConnectException: Connection timed out: no further information

解决办法: 关闭Linux防火墙

CentOS 7
[root@jed bin]# systemctl stop firewalld.service # 关闭防火墙
[root@jed bin]# systemctl disable firewalld.service # 禁止开机启动

CentOS 6
[root@jed bin]# servcie iptables stop # 临时关闭
[root@jed bin]# chkconfig iptables off # 永久关闭

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 015.组合模式

    从这个树状结构上分析,有两种节点:有分支的节点(如研发部经理)和无分支的节点(如员工A、员工D等),总经理叫做根节点,类似研发部经理有分支的节点叫做树枝节点,类...

    CoderJed
  • 在VMware Workstation中安装完CentOS-7.6-Minimal版后的常用配置

    首先确定可以设置的IP地址,在vmware的虚拟网络配置中查看自己的虚拟网络网段:

    CoderJed
  • Java设计模式之适配器模式

    今天讲适配器模式,这个模式也很简单,你笔记本上的那个拖在外面的黑盒子就是个适配器,一般你在中国能用,在日本也能用,虽然两个国家的的电源电压不同,中国是220V,...

    CoderJed
  • docker运行storm及wordcount实例

    本文简单介绍下怎么使用docker运行storm以及在springboot中使用storm。

    codecraft
  • Java IO

    java中涉及到的io流基本都是从以上四个抽象基类派生出来的,其子类都是以其父类的名字做后缀。

    万能青年
  • App向后台传不固定张数的图片

    用户5899361
  • 高考季,献给各位学子

    今天,举国瞩目的高考已经结束了,在这样的时刻“LZUGIS”携手“GIS讲堂”为大家从GIS和数据方面给大家做一个分析。

    lzugis
  • Netty实现简单RPC调用

    我们知道Dubbo是一个RPC框架,那RPC框架需要实现什么?需要实现的是调用远程服务和本地服务一样方便,同时提高调用远程服务的性能。而服务端和客户端之间的关系...

    路行的亚洲
  • win10 uwp 气泡 WPF 气泡

    假设尖头宽度 10 高度 5 ,那么可以看到第一个点是 (0,5) 第二个点是 (5,0) 第三个点是 (10,5)

    林德熙
  • .Net Core微服务入门全纪录(七)——IdentityServer4-授权认证

    上一篇【.Net Core微服务入门全纪录(六)——EventBus-事件总线】中使用CAP完成了一个简单的Eventbus,实现了服务之间的解耦和异步调用,并...

    xhznl

扫码关注云+社区

领取腾讯云代金券