Logstash Kafka -错误:负长度-给定62
Logstash是一个开源的数据处理工具，用于收集、处理和转发数据。它可以从多个来源（例如日志文件、数据库、消息队列等）收集数据，并对数据进行过滤、转换和聚合，最后将数据发送到目标系统。Logstash采用插件化架构，使得用户可以方便地扩展其功能。
Kafka是一个分布式流处理平台，它能够高效地处理大规模的实时数据流。作为一个分布式消息队列系统，Kafka通过将数据分布到多个服务器上，实现高吞吐量和可扩展性。它使用发布-订阅模型来处理数据流，可以处理数百万级别的消息。
错误:负长度-给定62是指在使用Logstash和Kafka进行数据传输时出现的一个错误。这个错误通常是由于数据格式问题导致的，例如尝试将非法或不兼容的数据发送给Kafka。为了解决这个错误，可以检查数据的格式和内容，确保其符合Kafka所要求的格式规范。
在云计算领域中，Logstash和Kafka常常被用于构建实时数据处理和分析系统。Logstash负责收集和处理数据，并将数据发送到Kafka中，而Kafka则负责将数据传递给其他系统进行进一步处理和分析。
推荐的腾讯云产品和产品介绍链接地址如下：
- 腾讯云LogListener：腾讯云的日志服务平台，提供了日志收集、存储、查询和分析的功能。可以方便地与Logstash集成，将日志数据发送到Kafka中。详细信息请参考：https://cloud.tencent.com/product/lv
- 腾讯云CKafka：腾讯云的消息队列服务，提供高可靠、高可扩展的消息传递机制。可以用于存储和传输Logstash处理的数据。详细信息请参考：https://cloud.tencent.com/product/ckafka
通过使用上述腾讯云产品，可以实现Logstash和Kafka之间的数据传输，并构建强大的实时数据处理和分析系统。
相关·内容
我面临着与本文类似的问题：https://discuss.elastic.co/t/argumenterror-when-using-kafka-input-avro-codec/116975 Logstash/myschema.avsc" } stdout{
} 错误日志： [2018-01-25T11:54:37,060][FATAL`decode'",
"
浏览 19提问于2020-09-28得票数 2
回答已采纳
我正在尝试使用LogStash发送csv数据到kafka，实现我自己的配置脚本test.conf。我在解析的时候遇到了这个错误。/share/logstash/logstash-core/lib/logstash/settings.rb:290:in `validate_value'", "/usr/share/logstash/share&
浏览 238提问于2021-05-24得票数 0
我们在和卡夫卡，Elasticsearch和Logstash一起玩。为了进行试验，我们希望建立一个小型服务：
input {
浏览 1提问于2015-11-23得票数 1
当我在输入文件上运行运行logstash过滤器的test.sh时，这是logstash --debug中的错误 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?_8_dot_2_dot_1.lib.logstash.
浏览 1提问于2019-01-23得票数 0
回答已采纳
我们使用Elastic的Logstash Docker镜像(docker.elastic.co/logstash/logstash-oss:6.1.2)作为我们自己的Logstash Docker镜像构建的基础这个文件是不是丢失了，或者我们看到的是安装镜像的错误命令？这是我们的Dockerfile，它在构建时没有将给定的插件包含到新的镜像中：
FROM docker.elastic.co/logstash/logstash
浏览 20提问于2018-01-30得票数 6
回答已采纳
我很好奇为什么我会得到这个运行时错误，而从我的角度来看，我不应该在下面的代码部分：
public static void SendMesg此方法从给定的源数组将字节传输到此缓冲区。如果从数组复制的字节比在这个缓冲区中保留的要多，也就是说，如果长度> remain ()，则不传输字节并引发BufferOverflowException。否则，此方法将从给定数组中的长度字节复制到此缓冲区中，从数组中的给
浏览 2提问于2011-05-12得票数 0
回答已采纳
1回答
文件 kafka { topics => ["payments-nginx"]无法解析client_ip字段，我的地理位置也失败了，logtash日志没有显示错误，但仍然无法解析、任何解决方案或原因。] Event after json filter {:event=>#<LogStash::Event:0x651bef38>}
[2021-01-19T2
浏览 0提问于2021-01-19得票数 0
回答已采纳
当然，数组的长度不应该小于0。这是我养成的习惯，以确保我的程序运行“以防有什么奇怪的事情发生”。是否有任何理由不使用<=运算符而改用=== 0？
浏览 6提问于2020-03-10得票数 0
回答已采纳
但是当我在Jenkins中运行TestSuite时，我看到的是编译器错误。我不得不删除一些过载的方法。但是现在我面对的是非重载方法的错误。错误编译错误: INFO /apps/jenkins/workspace/qa-tax-svc-automation/src/test/java/addressVerificationService/OverriddenAddressVerificationServiceTest.java:
浏览 3提问于2014-11-25得票数 1
回答已采纳
1回答
当我尝试使用我各自的模式对数据运行时，它返回错误"AvroRuntimeException:格式错误的数据。长度为负：-40“。我看到其他人也遇到过类似的问题：、和。我还引用了这个，它们都很有帮助，但是到目前为止对这个错误没有任何帮助。，null)；
我已经尝试了其他解码器，并打印出了avro变量的内容，我相信你会期望序列化的byteArrayInputStream数据看起来是什么样子(在消息中，我可以看到模式和一些数据以及一些格式错误的数据我很难理解为什么会发生这个错
浏览 0提问于2016-03-16得票数 11
回答已采纳
我正在尝试使用最新的Kafka CLI工具来重置消费者偏移量。kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group my-group --reset-offsets --to-earliestFirstTopic 0 0但是再次运行命令：
kafka-consumer-groups.ba
浏览 2提问于2017-08-14得票数 47
回答已采纳
1回答
我有一些来自kafka提供商的Avro消息，这些消息看起来是这样开始的：该ef bf bd 24 I预期为模式的长度，为2332字节。我很难确定锯齿字形的字形(为什么长度不可能是负的，是曲折的呢？)是正确的价值。这看起来像是被错误编码了吗？
浏览 5提问于2017-06-08得票数 1
回答已采纳
2回答
我正在解决以下问题，其中我必须创建上述方法：
int[] runLength(int[] a)，它接受一个数组，该数组由一系列元素值组成，后面跟着这些元素的游程长度，并在交替的位置列出。此方法创建并返回一个包含这些元素的新数组，每个元素重复其游程长度给定的次数。例如，当使用数组{3，8，1，-7，0，42，4，-3} (大声读出为“三个八，一个负七，零四十二和四个负三”)调用时，您的方法将创建并返回数组{8，8，8，-7，-3，-3，-3，-3}。同样，请确保您的方法返回的数组具有正确的长度</e
浏览 2提问于2017-11-02得票数 0
对于来自汇合平台的Kafka rest代理，我们一直面临着开发团队和环境支持团队之间的一些麻烦和不同的理解。{ { "off
浏览 0提问于2018-04-30得票数 0
回答已采纳
rep的帮助页表示参数times：
给定(非负)次数的整数向量，用于重复每个元素的长度(X)，或者重复整个向量(如果长度为1 )。第二个data.table创建与x不同长度的times，从而引发错误。
浏览 1提问于2015-07-07得票数 3
回答已采纳
2回答
我试图编写一个方法的递归实现，该方法接受一个非负参数，并返回其数字的平方和。例如，sumSquareDigits( 10 )应该返回1，而sumSquareDigits(103)应该返回10。(int n) { return (((n % 10)^2) + sumSquareDigits(n/10));例如，对于给定的整数625，如下所示：
(625 % 10)^2 + (62,5 % 10)^2 + (6,25)^2 = 5^2 + 2^2 +
浏览 5提问于2014-11-18得票数 0
回答已采纳
我读过贝尔曼·福特最短路径算法，它可以检测负权重循环。
该算法运行(顶点-1)次，以避免无限循环，并成功地检测到负权重循环。这很好，但是，我的疑问是，检测负权重循环的必要性是什么？
浏览 2提问于2019-08-19得票数 0
自从我最后一次用Ruby编写代码(Ruby 2是新的，哇，它已经是3了)已经有很长时间了，所以我觉得自己像个白痴。hellocontent = File.read("test_file_str.txt","w")当我运行它时，我得到：我以前从未遇到过这种情况，但我已经很久没有编写代码了，所以PEBKAC非常清楚。
然而，当我
浏览 12提问于2021-12-15得票数 0
回答已采纳
未提供用于拍摄视频的摄像机的信息，该项目还声明如下：
我很少或根本没有计算机视觉方面的经验，我从来没有遇到过两个视场正在使用。
浏览 0提问于2019-05-08得票数 1
回答已采纳
1回答
给定两个随机变量X和Y，其中X=(x1，.，xn)和Y=(y1，.A中，所以A=[X Y]，我需要执行下一个操作：我试图用中值而不是均值来获得协方差矩阵的估计量，对于nxt矩阵，t表示随机变量的数目，n表示数据集的长度*(A(:,j)-a2(ones(t,1),:)))); end
然而，理论上，我必须得到一个半定(正或负)对称矩阵，然而，这不是这个代码的情况。我在代码制定上有什么错误吗？
浏览 3提问于2020-04-27得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
