首页
学习
活动
专区
圈层
工具
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Broker not available

前言 你正在处理一个重要的数据任务,但是突然发现Kafka Broker不可用了!这种情况会让任何一个数据工程师心急如焚。就像是电影中的情节一样,突如其来的危机让你不知所措。...但别担心,本文将带你一起进入Kafka的世界,探索Broker不可用的原因和应对方法。让我们一起来揭开这个神秘的面纱吧!...在这种情况下,需要确保网络正常工作,并且客户端可以访问 Kafka Broker 的网络端口。...总的来说就是这个错误可能是自己引发的 我执行了一下这个命令kafka-topics.sh --bootstrap-server localhost:9092 --list出现了这个错误 可以看到我ping...localhost的时候是可以ping通的,然而我去访问的时候它是ubable to connect to remote host 所以在执行的时候最好是填写所配的地址

7510

关于InputStream类的available()方法

比如,Socket通讯时,对方明明发来了1000个字节,但是自己的程序调用available()方法却只得到900,或者100,甚至是0,感觉有点莫名其妙,怎么也找不到原因。...其实,这是因为网络通讯往往是间断性的,一串字节往往分几批进行发送。本地程序调用available()方法有时得到0,这可能是对方还没有响应,也可能是对方已经响应了,但是数据还没有送达本地。...http://www.cnblogs.com/CandiceW/p/5486112.html 能否使用取决于实现了InputStream这个抽象类的具体子类中有没有实现available这个方法。...但是,网络编程的时候Socket中取到的InputStream,就没有实现这个方法,那么就不可以使用这种方式创建数组。...available()方法时,对发发送的数据可能还没有到达,你得到的count是0。

2K20
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    链式操作的用法reject的用法catch的用法all的用法race的用法

    链式操作的用法 所以,从表面上看,Promise只是能够简化层层回调的写法,而实质上,Promise的精髓是“状态”,用维护状态、传递状态的方式来使得回调函数能够及时调用,它比传递callback函数要简单...reject的用法 到这里,你应该对“Promise是什么玩意”有了最基本的了解。那么我们接着来看看ES6的Promise还有哪些功能。我们光用了resolve,还没用reject呢,它是做什么的呢?...catch的用法 我们知道Promise对象除了then方法,还有一个catch方法,它是做什么用的呢?...all的用法 Promise的all方法提供了并行执行异步操作的能力,并且在所有异步操作执行完后才执行回调。...race的用法 all方法的效果实际上是「谁跑的慢,以谁为准执行回调」,那么相对的就有另一个方法「谁跑的快,以谁为准执行回调」,这就是race方法,这个词本来就是赛跑的意思。

    4.7K20
    领券