应用程序启动后，当iam向org.apache.kafka.common.errors.SerializationException.主题(流主题)发送消息时，应用程序将使用sensorValues关闭查看堆栈跟踪，我发现由于SensorMetaData中的模式更改，它在执行联接时未能反序列化SensorMetaData。反序列化方法中的断点显示，它试图从主题"app-KSTREAM-TOTABLE-STATE-STORE-0000000002-changelog".反序列化数据
所以问题是为什么应用程序要关闭<
浏览 2提问于2020-06-06得票数 0
回答已采纳
在某个时候，serde尝试在1 url上注册模式时超时，但是由于它向流应用程序抛出IO异常，流线程关闭了。从kafka流应用程序的角度来看，这种类型违背了在创建avro serdes时支持多个urls的功能，因为DSL堆栈中出现的运行时异常将关闭stream Thread。我们是否需要在应用程序逻辑中执行重试(当您简单地将主题具体化到商店中时，这可能是很棘手的)？当物化到本地rocksDB商店时，是否添加了
值以在注册表中注册架构，还是应该将auto.
浏览 0提问于2018-11-02得票数 2
回答已采纳
我使用以下代码来关闭连接到服务器的InputStream和OutputStream： if (mInputStream !mOutputStream = null; } catch (IOException e) { }我做错了什么？
浏览 0提问于2010-11-06得票数 7
回答已采纳
在测试中我使用的是MockSchemaReigstryClient at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:551) ~[kafka-str
浏览 9提问于2021-01-10得票数 3
因此，它是一个java.io流。
当我们使用streams时，我们应该打开和关闭它。此外，我们还应该捕获许多异常。当我们使用System.in和System.out时，我们避免了这些活动。以及何时(在什么条件下？)streams是否打开/关闭？
浏览 3提问于2014-09-03得票数 2
卡夫卡版本- 0.11.0.0
无法完成org.apache.kafka.clients.consumer.CommitFailedException:提交您可以通过增加会话超时或减少max.poll.records在轮询()中返回的批处理的最大大小来解决这一问题。在org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.sendOffsetCommitRequest(ConsumerC
浏览 4提问于2017-08-09得票数 6
FileInputStream(someFile.getPath());如果我打电话给in.close()，它也会关闭我的代码给出了GC异常如下：
java.lang.OutOfMemoryError: GC开销限制超过
浏览 6提问于2012-12-26得票数 10
回答已采纳
，然后在流中不进行处理。(StreamThread.java:660) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.<e
浏览 17提问于2017-02-22得票数 7
回答已采纳
我在一个Docker容器中运行了一个KStreams应用程序，它使用一个持久的键值存储。我的运行时环境是RHEL 7上的Docker 1.13.1。因此，当启动我的Docker容器时，我看到有一个包含分区号的文件夹，比如0_1、0_2....0_288在/mnt/storage/kafka-streams/myapp/下面
浏览 9提问于2022-06-01得票数 0
定义了一个自定义存储，在自定义Transformer中使用(参考如下)。不确定，为什么内部主题"test_01-HOUSE-changelog“是用单个分区和单个复制创建的，而不是源分区"test”中的2个分区。这里遗漏了什么？(AbstractTask.java:81) Topic: test_01-HOUSE-changelog Partitio
浏览 2提问于2018-05-15得票数 0
09-03 16:31:50.108: W/System.err(16727): at java.util.zip.GZIPInputStream.read(GZIPInputStream.java:158)
09-03 16:31:50.108: W/System.err(16727): at libcore.io.Streams.readSingleByte(Streams.java:41-03 16:31:50.108: W/System.err(16727
浏览 2提问于2013-09-03得票数 0
回答已采纳
我试图使用kafka流来执行加窗口的聚合，并且只有在某个会话窗口关闭后才会发出结果。为了实现这一点，我使用了抑制函数。$000(CachingSessionStore.java:37) at org.apache.kafka.streams.state.internals.NamedCache.flush
浏览 0提问于2019-03-15得票数 1
回答已采纳
1回答
在一个简单的Kafka流程序中，当我使用下面的代码时，它不会引发任何错误：
KTable<String, Long> result= source.mapValues(textLine:异常中的异常。(Segments.java:89)在org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore.put(RocksDBSegmentedBytesStore.java(KS
浏览 0提问于2019-03-25得票数 1
应用使用kafka版本为2.7.0Exception in thread "Average-3ded0155-d697-492b(RocksDBStore.java:185)
at org.apache.kafka.<
浏览 1提问于2021-02-07得票数 0
2回答
path, String... files) throws IOException { Stream<String>[] streamsfor (int i = 0; i < files.length; i++) { streams.onClose(() -> System.out.println("Closed &quo
浏览 1提问于2015-05-07得票数 6
回答已采纳
在自定义Transformer中，我们尝试在init(..)方法中创建和转发一些记录。根据Kafka Streams JavaDoc的说法，这应该是可能的。(ProcessorNode.java:95)at org.apache.kafka.streams.
浏览 7提问于2019-03-16得票数 0
回答已采纳
使用kafka-streams 0.10.0.0，在转发消息时，我会周期性地在StreamTask中看到一个空指针异常。它在10%到50%的调用之间变化。NPE发生在这种方法中： ProcessorNode thisNode = currNode;childNode.process(key, value); } finally {
currNode = thisNode;
浏览 1提问于2016-08-21得票数 3
回答已采纳
google chrome中启动时，我得到了以下输出：在发生异常之前是否进行了3次迭代关闭流在发生异常之前是否进行了4次迭代关闭流d
浏览 3提问于2011-03-13得票数 1
5回答
我有一个ifstream和一个ofstream，它们在运行时可能会打开或不会打开(取决于用户在命令行中输入的内容)。我无论如何都会声明变量，并且我有一个方法可以在需要时打开流。我的问题是在程序结束时，我不知道是否需要关闭它们。 static
浏览 0提问于2010-09-17得票数 1
回答已采纳
2回答
我们在kotlin中有一个org.apache.kafka:kafka-streams:3.2.3应用程序，并从org.apache.kafka:kafka-streams:3.3.1切换到KStreams<init>(KafkaStreams.java:894) ~[kafka-streams-3.3.1.jar:?]<init>(KafkaStreams.java:856) ~[kafka-streams-3.3.1.jar:?]<in
浏览 21提问于2022-10-14得票数 5
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号