Batch containing 11 record(s) expired due to timeo

背景:
Kafka集群在一个192.168.0.x网段的,而我们的生产者在192.168.17.x网段的一台机器上,故当生产者发送消息给Kafka时,
无法将消息发送过去。

错误:
11:21:13,936 ERROR KafkaProducer - Batch containing 11 record(s) expired due to timeout while requesting metadata from brokers for onlinelogs-1

分析:
1.做Kafka集群的demo测试是OK的,详情参考:
Kafka 0.10.1.0 Cluster的搭建和Topic简单操作实验

2.在生产者机器上 telnet kafka节点ip 9092 ,也是通的,甚是奇怪。

3.谷歌了几下:
需要配置advertised.host.name 参数,将Kafka各个节点,该参数配置为当前机器的IP即可,重启生效配置,测试OK。

原文地址:https://blog.51cto.com/14309075/2412197

时间: 2024-10-13 22:08:28

Batch containing 11 record(s) expired due to timeo的相关文章

Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers

一.异常信息如下: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for user-video-0 at org.apache.kafka.clients.producer.inter

使用Larave5.6l提交POST请求出现The page has expired due to inactivity错误

一般是由于没有添加 csrf造成的 在表单下面的 第一个行 添加如下代码即可 <input type="hidden" name="_token" value="{{csrf_token()}}"> 切记是第一行 如果还有问题,那么检查form下的 第一行是不是以上数据  如果有其他的数据请放到别的行 原文地址:https://www.cnblogs.com/baker95935/p/9300388.html

kafka+windows+java+springboot中的配置

1.百度kafka+zookeeper+windows配置 1.1  zookeeper配置 dataDir=/tmp/zookeeper # the port at which the clients will connect clientPort=2181 # disable the per-ip limit on the number of connections since this is a non-production config maxClientCnxns=0 1.2 kafk

阿里云上部署kafka--遇到的坑

阿里云防火墙关闭,并且配置规则.不然会导致访问不到服务. 问题一: Caused by: java.net.UnknownHostException: iZuf68tztea6l5ccdz7wemZ: iZuf68tztea6l5ccdz7wemZ: Name or service not known vi /etc/hosts 127.0.0.1 iZuf68tztea6l5ccdz7wemZ iZuf68tztea6l5ccdz7wemZ 自己的主机名 问题二: ERROR Error wh

Cryptographic method and system

The present invention relates to the field of security of electronic data and/or communications. In one form, the invention relates to data security and/or privacy in a distributed and/or decentralised network environment. In another form, the invent

RTSP Spectification

Refer: https://www.ietf.org/rfc/rfc2326.txt Network Working Group H. SchulzrinneRequest for Comments: 2326 Columbia U.Category: Standards Track A. Rao Netscape R. Lanphier RealNetworks April 1998 Real Time Streaming Protocol (RTSP) Status of this Mem

Android 新老两代 Camera API 大起底

https://blog.csdn.net/Byeweiyang/article/details/80515192 0.背景简介 最近有一部分相机相关的需求,专注于对拍摄的照片.视频的噪点.色温.明暗等方面进行优化.一般我们在生活中使用相机来拍照的话,在前期拍摄时,就可以通过调整相机的拍摄参数,如:曝光时间.光圈大小.ISO.曝光补偿等等,使得拍摄下来的照片本来的色彩.明暗就处于比较理想的状态,无需过度依赖后期处理.而手机端的拍摄则往往受限于硬件和机型,无法在前期如此"收放自如",我们

使用Mxnet基于skip-gram模型实现word2vect

1. 需求 使用skip-gram模式实现word2vect,然后在jaychou_lyrics.txt数据集上应用 jaychou_lyrics.txt数据集收录了周杰伦从第一张专辑到第十张专辑中的歌词,比如: 想要有直升机 想要和你飞到宇宙去 想要和你融化在一起 融化在宇宙里 我每天每天每天在想想想想著你 这样的甜蜜 让我开始乡相信命运 感谢地心引力 让我碰到你 漂亮的让我面红的可爱女人 温柔的让我心疼的可爱女人 透明的让我感动的可爱女人 坏坏的让我疯狂的可爱女人 2. 词向量介绍 2.1

httpcomponents-client-4.4.x

Chapter 1. Fundamentals Prev     Next Chapter 1. Fundamentals 1.1. Request execution The most essential function of HttpClient is to execute HTTP methods. Execution of an HTTP method involves one or several HTTP request / HTTP response exchanges, usu