1回答
我有一个流函数KStream<K, V>[] branch(final Predicate<? super K, ? super V>... predicates)。我想动态创建一个谓词列表。private List<org.apache.kafka.streams.kstream.Predicate<Long, AccountMigrationEvent>> getStrategies()for (MigrationStrategy strategy : strategies) {
浏览 5提问于2019-04-29得票数 2
回答已采纳
3回答
我正在尝试使用DynamoDB Streams和AWS Lambda创建一个DynamoDB触发器。我研究了很多，但我找不到任何方法来读取和处理Java8中的DynamoDB流事件。我对这两种技术都是完全陌生的，所以不知道如何使用它。你们中的任何一个人能给我推荐一个用Java处理这个用例的代码
浏览 1提问于2015-07-23得票数 3
1回答
我有一个收集的溪流，我试图把ZIP合并成一个流。我正在使用番石榴Streams.zip方法来压缩流。当集合中的流数低于8000时，它工作得很好，超过8000时，它开始抛出堆栈溢出异常。在本地调试时，我发现堆栈溢出发生在zip方法中。它成功地压缩到8000流，然后开始抛出异常。我无法找到解决这个问题的办法，也无法解释为什么会发生这种情况。在这附近需要帮助才能找到。将我所有的lambda调用转换为vanllafor循环，所以为了确认我们没有调用任何由zip
浏览 4提问于2022-11-10得票数 0
回答已采纳
1回答
但是，如果您取消注释Stream.concat行，那么您将看到这两个流都是初始化的，即使没有实际使用(没有应用终端操作)。
这是java bug对吧？什么是解决办法？
浏览 6提问于2017-05-28得票数 1
回答已采纳
我上次使用Java已经有一段时间了，所以如果这个问题很愚蠢，请原谅我。在Ruby语言中，我经常使用.map。在Java中有没有类似的东西，或者我必须迭代数组？在Ruby中，而不是input.each do |elem|endoutput = input.map
浏览 1提问于2014-08-13得票数 2
我正在为spring kafka streams应用程序的定制而苦苦挣扎。我一直在尝试在我的KStreams中配置处理未捕获(运行时异常)。:42) at org.apache.kafka.str
浏览 65提问于2021-01-14得票数 0
我希望通过一个lambda函数通过侦听DocumentDB更改流来填充SQS队列。我知道使用DynamoDB可以做到这一点。有没有办法通过DocumentDB来实现这一点呢？
浏览 7提问于2020-01-31得票数 4
1回答
有很多java第三方库可以在Java集合中提供高性能的服务。根据这个DZONE ，有一些遵循OSGI模型并在Java中提供高性能的本地库，或者执行其他一些操作。现在，在Java 8中，启动Streams是为了在集合库中提供良好的性能，我们还使用Streams执行一些并行操作。以下是我的问题：
与第三方库(如Trove、Javolution等)相比，Ja
浏览 0提问于2014-05-08得票数 4
我已经将导致错误的部分封装在一个try-catch块中，假设该错误将被catch块捕获。com.techopact.kafkastreamspoc.topology.Topology.lambda$KStreamsTopology$1(Topology.java:28)
at org.apache.kafka.streams.kstream.internals.AbstractStream.lambdaat org.apache.kafka.streams.pr
浏览 12提问于2022-08-11得票数 0
回答已采纳
我有一个输入主题和一个输出主题，我试图使用KStream函数为输入主题应用KStream.map键值转换操作。如果转换为null的值，则函数抛出IllegalArgumentException1:例外的原因？尽管文档中写着：“忽略带有空键或空值的输入记录”
2:处理无状态/有状态操作中的异常的最佳实践？是否应该围绕整个处理计划进行一次尝试/捕捉就足够了？或者，我应该在每个转换<em
浏览 8提问于2019-10-21得票数 0
回答已采纳
<init>(EnrichedMessage.java:51) at org.apache.kafka.streams.processor.internals.ProcessorNode.lambda$process$2(ProcessorNode.java(SourceNode.java</e
浏览 9提问于2020-08-03得票数 0
回答已采纳
1回答
我试图为每个绑定设置valueSerde，但是只考虑默认的值。(KStreamJoinWindow.java:55) at org.apache.kafka.streams.processor.internals.StreamTask.lambda$process$3org.
浏览 3提问于2020-12-03得票数 0
回答已采纳
我正在尝试建立一个Kafka Streams单元测试拓扑，就像Confluent博客中描述的一样。当我写到主题时，我得到了下面的错误。at org.apache.kafka.streams.processor.internals.StreamTask.lambda$process$1(StreamTask.java:703))
at org.apache.kafka.streams.TopologyTestDriv
浏览 7提问于2021-05-19得票数 1
2回答
我发现使用lambda的另一个优势是，我不必编写代码来管理多处理(或多线程)，而且我的数据处理将不依赖于我选择的硬件--我也可以通过选择一个低级硬件来节省成本，它的唯一工作将是充当第一个生产者，但我仍然会为aws lambda付费。如果我使用并以相同的方式使用Java流是否类似于使用AWS？我可以在Java中使用节流吗？
如果我使用Java流，是否有一种简单的方法来管理多处理(线程)。除了节流和
浏览 1提问于2018-05-01得票数 0
2回答
拓扑结构和代码运行在单元测试类本身中。1000 * 60);
public void teardown() { }我的错误越来越少:45)
> at org.apache.kafka.streams.state.internals.MeteredWindowStore.lambda$setFlushListener$4(MeteredWindowStore.java:130
浏览 2提问于2022-06-14得票数 0
回答已采纳
我正在创建一个Kafka Streams应用程序，我的主题数据来自Protobuf。我们可以为此创建Java代码绑定。但是，我正在努力使用正确的serde来使用topic中的数据。处理器的输入类型是否与反序列化的类型匹配？检查串口设置并更改StreamConfig中的默认串口或通过方法参数提供正确的串口。请注意，尽管错误的Serde是导致错误的常见原因，但强制转换
浏览 37提问于2021-01-08得票数 1
org.apache.kafka.common.errors.SerializationException.主题(流主题)发送消息时，应用程序将使用sensorValues关闭查看堆栈跟踪，我发现由于SensorMetaData中的模式更改反序列化方法中的断点显示，它试图从主题"app-KSTREAM-TOTABLE-STATE-STORE-0000000002-changelog".反序列化数据 at org.apache.kafka.
浏览 2提问于2020-06-06得票数 0
回答已采纳
2回答
我们是否可以创建一个Lambda函数，当我们将记录写入Dynamo DB表时可以执行该函数&该记录被写入Kinesis流?？我们基本上可以使用Lambda函数写入Kinesis流吗？？如果是，请分享that..Also示例代码，我想知道work.....Thank是如何实现的
浏览 0提问于2015-11-20得票数 7
1回答
(a, b);(Streams.from(Iterable)从可迭代的地方创建一个流-因为Iterable#stream()不存在)Exception) at java.util.stream.Streams$ConcatSpliterator
浏览 1提问于2015-08-18得票数 0
回答已采纳
应用使用kafka版本为2.7.0Exception in thread "Average-3ded0155-d697-492b(RocksDBStore.java:185)
at org.apach
浏览 1提问于2021-02-07得票数 0
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
