向flume发送消息出现 Client sent event exceeding the maximum length

flume source端是监听端口数据，在模拟前端发送数据时候出现这个问题

模拟发送数据时出现的问题，json数据太长，flume默认长度太短

Client sent event exceeding the maximum length

解决办法也很简单，参考官方参数说明，配置max-line-length到适当值即可（默认是512字节），示例：

a1.sources.r1.max-line-length = 102400

向flume发送消息出现Client sent event exceeding the maximum length相关推荐

Kafka发送超过broker限定大小的消息时Client和Broker端各自会有什么异常？
欢迎支持笔者新作:<深入理解Kafka:核心设计与实践原理>和<RabbitMQ实战指南>,同时欢迎关注笔者的微信公众号:朱小厮的博客. 欢迎跳转到本文的原文链接:https: ...
netty心跳过程中发送消息失败_netty心跳机制和断线重连(四)
心跳是为了保证客户端和服务端的通信可用.因为各种原因客户端和服务端不能及时响应和接收信息.比如网络断开,停电或者是客户端/服务端高负载. 所以每隔一段时间客户端发送心跳包到客户端服务端做出心 ...
局域网服务器发送消息,Java实现简单局域网聊天室
本文实例为大家分享了Java实现简单局域网聊天室的具体代码,供大家参考,具体内容如下 Java 的Socket编程: 1.TCP协议是面向连接的.可靠的.有序的.以字节流的方式发送数据,通过三次握手方 ...
ibm linux mq 发送消息_RabbitMq、ActiveMq、Kafka和Redis做Mq对比
一.RabbitMq RabbitMQ是一个Advanced Message Queuing Protocol(AMQP)的开源实现,由以高性能.可伸缩性出名的Erlang写成.RabbitMQ Se ...
服务器发消息给所有人,我需要服务器向所有客户端（Python、sockets）发送消息...
如果需要向所有客户端发送消息,则需要以某种方式保存所有客户端的集合.例如:clients = set() clients_lock = threading.Lock() def listener(cl ...
【Android WebSocket】Android 端 WebSocket 基本用法 ( 添加依赖和权限 | 创建 WebSocketClient 客户端类 | 建立连接并发送消息 )
文章目录一.添加依赖和权限二.创建 WebSocketClient 客户端类三.建立连接并发送消息使用 https://github.com/TooTallNate/Java-WebSocke ...
Qt Remote Object（QtRO)给指定的客户端发送消息
概述前面写了两篇文章介绍QtRO的使用方法,在这里: Qt Remote Object(QtRO)实现进程间通信 Qt Remote Object(QtRO)动态Replica实现进程间通信然后会 ...
Redis源码解析：21sentinel(二)定期发送消息、检测主观下线
六:定时发送消息哨兵每隔一段时间,会向其所监控的所有实例发送一些命令,用于获取这些实例的状态.这些命令包括:"PING"."INFO"和"PUBLI ...
企业微信加密消息体_用企业微信小程序发送消息
在企业开发中,经常会碰到一些消息要及时推送到企业员工的手中.so 下面来说怎么向企业微信中的员工发消息. 本人只是记录下开发过程,详细参考https://work.weixin.qq.com/api/ ...
mqtt 发送消息过多_阿里云MQTT服务端注解式消息处理分发与同步调用实践小结
一.前言前段时间公司预研了设备app端与服务端的交互方案,出于多方面考量最终选用了阿里云的微服务队列MQTT方案,基于此方案,本人主要实践有: 1. 封装了RocketMQ实现MQTT订阅与发布的实 ...

向flume发送消息出现Client sent event exceeding the maximum length

向flume发送消息出现 Client sent event exceeding the maximum length

向flume发送消息出现Client sent event exceeding the maximum length相关推荐

最新文章

热门文章