首页 \ 问答 \ 风暴卡夫卡鲸鱼嘴不发出信息(Storm Kafka spout not emitting messages)

风暴卡夫卡鲸鱼嘴不发出信息(Storm Kafka spout not emitting messages)

 在我的风暴拓扑结构中（有2个喷口和1个螺栓），其中一个kafka-spout消费者的偏移正在推进，但msgs不会通过kafka spout发送到螺栓。 我可以在暴风雨中看到，对于特定的喷口，消息发出和传输的消息为0.所以，我的问题是消费者如何前进，我可以看到消费者与动物园管理员客户端的偏移逐渐增加。 

In my storm topology(with 2 spouts and 1 bolt) the offset for one of the the kafka-spout consumer is advancing but the msgs are not sent via kafka spout to the bolt. I can see in the storm ui that for that particular spout the msgs emitted and transferred is 0. So, my question is how come the consumer is advancing, i can see the gradual increase in the offset of the consumer from the zookeeper client.

原文：https://stackoverflow.com/questions/40041925

更新时间：2022-02-26 07:02

最满意答案

 这似乎得到了预期的结果：  
file_fullpath = file_fullpath.force_encoding('UTF-16LE').encode!('UTF-8')
 
 好像我首先需要“说服”Ruby，该字符串是UTF-16LE，然后才转换为UTF-8。 

This seems to get the desired result: 
file_fullpath = file_fullpath.force_encoding('UTF-16LE').encode!('UTF-8')
 
Seems like I first need to "convince" Ruby that the string is UTF-16LE, and only then convert to UTF-8.

相关问答

如何将DUT中的UTF-8字符串转换为字节数组？(How do I convert a UTF-8 String into an array of bytes in Dart?)[2022-05-14]

您需要导入dart：utf并使用其encodeUtf8函数。实际上现在有一个现有的Dart Redis客户端，它使用这些功能。 You need to import dart:utf and use its encodeUtf8 function. There is actually a existing redis client for Dart here which makes use of these functions.
将UTF-8转换为base64字符串(Convert UTF-8 to base64 string)[2022-05-02]

告诉您要实现什么有点困难，但假设您尝试获取一个Base64字符串，当解码为abcdef== ，以下内容应该有效： byte[] bytes = Encoding.UTF8.GetBytes("abcdef=="); string base64 = Convert.ToBase64String(bytes); Console.WriteLine(base64); 这将输出： YWJjZGVmPT0=这是abcdef==编码在Base64中。编辑：要解码一个Base64字符串，只需使用Convert.Fr ...
UTF-8字节[]到字符串(UTF-8 byte[] to String)[2024-01-30]

看看String的构造函数 String str = new String(bytes, StandardCharsets.UTF_8); 如果你感觉很懒，可以使用Apache Commons IO库将InputStream直接转换成String： String str = IOUtils.toString(inputStream, StandardCharsets.UTF_8); Look at the constructor for String String str = new String(by ...
在.NET中3个字节的UTF-8字符串替换（将3字节的UTF-8转换为字符串或字符）(3 byte UTF-8 String replacement in .NET (Convert 3-byte UTF-8 to String or Char))[2023-01-11]

您正在使用UTF-8编码混合代码点。在内部，所有.NET字符串都使用UTF-16，因此您只需指定Unicode代码点，而不是 UTF-8字节数据： Const FigureSpaceChar As Char = ChrW(&H2007) 来自www.fileformats.info的Codepoint 。 You're mixing code points with UTF-8 encoding. Internally, all .NET strings use UTF-16 so you just ...
在Java中将ANSI字符转换为UTF-8(Convert ANSI characters to UTF-8 in Java)[2022-04-28]

此错误不是由字符编码引起的。这意味着UTF数据的长度是错误的。编辑：只是意识到这是一个写错误，不读错误。 UTF长度只有2个字节，所以它只能容纳64K UTF-8字节。你正在努力写100K，它不会工作。这个限制是硬编码的，无法解决这个问题， if (utflen > 65535) throw new UTFDataFormatException( "encoded string too long: " + utflen + " bytes"); This error ...
从ASCII转换为utf-16LE会产生问题(conversion from ASCII to utf-16LE giving issues)[2022-11-16]

将“Hello”转换为UTF-16LE时，最终会得到这个字节序列（以十六进制显示）： 48 00 65 00 6C 00 6C 00 6F 00 00 00 printf调用表示打印字符串，好像它是一个常规的以零结尾的字符串。它看到48并打印一个H ，然后它看到00并认为它已经完成。您需要一个可以将字符串解释为UTF-16LE的打印功能。 C中没有标准的。 When you convert "Hello" to UTF-16LE, you end up with this byte sequence ...
PHP中UTF-8字符串的字节数组？(Array of bytes to UTF-8 string in PHP? [closed])[2022-04-03]

字符串只不过是一个字节数组。因此，UTF-8字符串与字节数组完全相同，除此之外您还知道字节数组所代表的内容。因此，您的输入字节数组还需要一个附加信息：字符集（字符编码）。如果您知道输入字符集，则可以将字节数组转换为另一个表示UTF-8字符串的字节数组。执行此操作的PHP方法称为mb_convert_encoding() 。 PHP本身不知道字符集（字符编码）。所以字符串实际上只不过是一个字节数组。应用程序必须知道如何处理它。因此，如果您有一个字节数组并希望将其转换为PHP字符串以便使用mb_c ...
用iconv（）将UTF-16LE转换为UTF-8(convert UTF-16LE to UTF-8 with iconv())[2023-01-29]

这是问题所在： size_t readBytes = sizeof(inBuf); size_t writeBytes = sizeof(outBuf); 将数组传递给函数时，它们会衰减到指向第一个元素的指针。你的来电 fn2Utf8(inBuf, outBuf); 等于 fn2Utf8(&inBuf[0], &outBuf[0]); 这意味着在函数中，参数不是数组，而是指针。当你在指针上执行sizeof ，你会得到指针的大小，而不是它指向的大小。有两种解决方案：第一种是将数组的长度作为函数的 ...
如何在Ruby中将UTF-16LE字符的字节数组正确转换为utf-8字符串(How to properly convert byte array of UTF-16LE chars to utf-8 string in Ruby)[2023-09-11]

这似乎得到了预期的结果： file_fullpath = file_fullpath.force_encoding('UTF-16LE').encode!('UTF-8') 好像我首先需要“说服”Ruby，该字符串是UTF-16LE，然后才转换为UTF-8。 This seems to get the desired result: file_fullpath = file_fullpath.force_encoding('UTF-16LE').encode!('UTF-8') Seems like I ...
我如何在Ruby中使用UTF-16LE源代码？(How do I work with UTF-16LE source code in Ruby?)[2021-07-29]

用UTF-16编写程序以处理UTF-16文件听起来像是用俄语命名变量以创建俄语网站。 :) Ruby 1.9支持字符串编码，James Grey在这个主题上有一系列优秀的文章 - 我认为它们是Ruby编码的参考指南。简而言之，您可以在打开它们时指定输入文件的编码： s = '' File.open('utf16le.txt', 'rb:UTF-16LE') do |f| # here you set the encoding s = f.read end p s.encoding #=> #

Storm-源码分析- spout (backtype.storm.spout)

kafka

Flume+Kafka+Strom基于分布式环境的结合使用

Kafka学习三：Flumeng+Kafka+Storm

storm-kafka-0.8-plus 源码解析

kafka+storm初探

Storm中Spout使用注意事项小结

Storm-kafka【接口实现】4 - KafkaSpout

快速了解Kafka

Kafka介绍

风暴卡夫卡鲸鱼嘴不发出信息(Storm Kafka spout not emitting messages)

最满意答案

相关问答

如何将DUT中的UTF-8字符串转换为字节数组？(How do I convert a UTF-8 String into an array of bytes in Dart?)[2022-05-14]

将UTF-8转换为base64字符串(Convert UTF-8 to base64 string)[2022-05-02]

UTF-8字节[]到字符串(UTF-8 byte[] to String)[2024-01-30]

在.NET中3个字节的UTF-8字符串替换（将3字节的UTF-8转换为字符串或字符）(3 byte UTF-8 String replacement in .NET (Convert 3-byte UTF-8 to String or Char))[2023-01-11]

在Java中将ANSI字符转换为UTF-8(Convert ANSI characters to UTF-8 in Java)[2022-04-28]

从ASCII转换为utf-16LE会产生问题(conversion from ASCII to utf-16LE giving issues)[2022-11-16]

PHP中UTF-8字符串的字节数组？(Array of bytes to UTF-8 string in PHP? [closed])[2022-04-03]

用iconv（）将UTF-16LE转换为UTF-8(convert UTF-16LE to UTF-8 with iconv())[2023-01-29]

如何在Ruby中将UTF-16LE字符的字节数组正确转换为utf-8字符串(How to properly convert byte array of UTF-16LE chars to utf-8 string in Ruby)[2023-09-11]

我如何在Ruby中使用UTF-16LE源代码？(How do I work with UTF-16LE source code in Ruby?)[2021-07-29]

相关文章

最新问答