腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用
Java
Streams
API
更新
实体
java-8
、
java-stream
我正在
使用
streams
API
基于userid对user对象执行
更新
操作。下面是我写的代码。有没有更好的方法来重构代码,因为我需要再次获取
更新
后的用户并发送。
浏览 20
提问于2021-09-24
得票数 0
回答已采纳
1
回答
api
-platform:用于GraphQL查询的自动合并订阅
graphql
、
api-platform.com
、
mercure
api
在
更新
标记为mercure=true的资源时,会自动将事件发送给合并集线器,并在相应的GET端点中发布要侦听的主题。好的。是否已经有一个选项可以在生成的GraphQL端点中
使用
?合并文档说:应该与任何GraphQL
API
“非常好地”集成,只要它“返回相应的主题URL”。但是afaik由
API
生成的GraphQL
api
没有().我错过了什么吗?这是要来的吗?在前面
使用
阿波罗-vue。 为了解决这个问题,我可以
使用
前端的专用EventSource
浏览 1
提问于2019-03-24
得票数 2
1
回答
Kafka流:由于在恢复过程中更改日志状态而导致重新平衡失败
apache-kafka-streams
我用低级别处理器
API
实现了Kafka流。对于从Kafka接收到的每一次
更新
,都会将其合并并
更新
到keystore,从而维护状态。最初,我们只运行了一个消费者,过了一段时间,我们尝试提出第二个消费者。我假设,当重新平衡发生时,第一个
使用
者收到了一些
更新
,因此
更新
被推送到相应的更改日志中。请帮帮忙。还共享相同的示例代码。我
使用
的是Kafka 2_11 0.10.2.1,主题有72个分区 Exception in thread "StreamThre
浏览 2
提问于2017-08-30
得票数 1
回答已采纳
1
回答
Kafka-在消费时抛出NullPointerException
groovy
、
kafka-consumer-api
、
apache-kafka-streams
我有这个问题:at org.apache.kafka.
streams
.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.
java
(ProcessorNode.
java</em
浏览 3
提问于2017-02-01
得票数 1
回答已采纳
1
回答
在Play + Scala中构建websockets时出现“无法解决重载方法actorRef”错误
scala
、
playframework
、
akka
但是,当尝试
使用
以下代码时,我会得到一个错误: package controllers import akka.actor._import play.libs.
streams
.ActorFlow
浏览 2
提问于2022-04-09
得票数 0
回答已采纳
2
回答
使用
Java
8
Streams
API
实现二进制搜索
java
、
java-8
、
binary-search
我想知道是否可以
使用
Java
8
Streams
API
实现二进制搜索?二进制搜索在搜索之前递归地拆分数组。我们可以
使用
Java
8
Streams
API
来做同样的事情吗?
浏览 0
提问于2018-12-15
得票数 1
9
回答
使用
Java
8
Streams
API
混洗整数列表
java
、
scala
、
java-stream
我尝试
使用
Streams
API
将以下Scala代码行转换为
Java
8:util.Random.shuffle((1 to 24).toList)IntStream.range(1, 25)collect( Supplier<R> supplier, ObjIntConsumer
浏览 114
提问于2013-11-19
得票数 35
回答已采纳
1
回答
Java
Spring-boot:如何返回一个列表而不是单个结果?
java
、
mysql
、
spring
、
spring-boot
、
mapstruct
我刚接触
Java
并
使用
Spring-Boot框架。我已经实现了一个小方法,它给出了一个transactionId,它提供了具有该transactionId的所有对象的列表。
浏览 22
提问于2020-10-25
得票数 0
回答已采纳
1
回答
如何将akka.stream.javadsl.Source转换为
java
.util.concurrent.Flow.Publisher
akka-stream
、
java.util.concurrent
、
reactive-streams
我正在试验reactive
Streams
的Test Compatability Kit (tck),并且我自己测试了几个Publisher,我想测试一个akka Source。但为了做到这一点,我需要将源(或源+处理器)转换为
java
.util.concurrent.Flow.Publisher。} ... 我不知道该怎么做。
浏览 1
提问于2019-07-11
得票数 0
1
回答
Kotlin -过载解模糊。所有这些功能都匹配。
kotlin
、
apache-kafka
、
apache-kafka-streams
VALUE_JSON_DE, "processor_name",kotlin("jvm")版本"1.7.10“kotlin("plugin.spring")版本"1.7.10” implementation("org.apache.kafka:kafka
浏览 2
提问于2022-10-17
得票数 0
回答已采纳
2
回答
Kafka
Streams
-
java
版本依赖关系
apache-kafka-streams
我正在
使用
Java
1.6运行我的应用程序,并计划将一些方面与Kafka集成。 我正在探索是否应该
使用
Kafka Consumer (
使用
poll())或
使用
KafkaStreams
API
。我们需要
Java
1.7 / 1.8来
使用
Stream
API
吗?
浏览 3
提问于2018-12-20
得票数 0
1
回答
运行自定义构建的Kafka流DSL应用程序返回
java
.lang.ClassNotFoundException
java
、
apache-kafka
、
apache-kafka-streams
我试图从一个包含json数据的kafka主题中阅读,并根据字段“
实体
”的值写入一个新的主题。
使用
Netbeans,我
使用
依赖项构建jar文件,并将jar文件放在/home/kafka路径中,并尝试将其作为类路径运行,并指定我创建的类(
使用
命令
java
-cp mavenproject.jar: org.apache.kafka.
streams
.processor.TopologyBuilder at
java
.net.URLClassLoad
浏览 3
提问于2017-03-19
得票数 0
回答已采纳
1
回答
如何为Kafka + Spring配置`spring.json.trusted.packages`?
java
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
我
使用
以下配置:@EnableKafkapublic class KafkaStreamsConfig { 但是,当我将发布到Kafka中的
实体
的包更改时,我会收到以下异常: Caused by:
java
.lang.IllegalArgumentException: The class 'com.mypackage.
streams
.entity.kafka.raw.Entity' is not in t
浏览 10
提问于2022-03-25
得票数 0
回答已采纳
2
回答
Java
3.0: AndroidStudio 8流未编译(调用需要
API
24级)
android-studio-3.0
Java
8,我安装了新的Android Studio 3.0。.sorted()但是我得到了编译错误: Call requires
API
level 24 (current min is 15)
java
.util.stream.Collection
浏览 0
提问于2017-11-01
得票数 5
1
回答
Akka:
Java
中流的等价物是什么
java
、
scala
、
akka
、
akka-stream
scala中的Akka
streams
提供了流概念。
Java
中的等价物是什么?但在
Java
语言中,Source.take(n)返回的是源,而不是流
浏览 10
提问于2020-02-09
得票数 0
1
回答
Kafka
Streams
| RocksDB异常
apache-kafka
、
apache-kafka-streams
、
rocksdb
应用
使用
kafka版本为2.7.0Exception in thread "Average-3ded0155-d697-492b(RocksDBStore.
java
:185) at org.apache.kafka.
stream
浏览 1
提问于2021-02-07
得票数 0
1
回答
Firebase数据:去正规化和复制
javascript
、
firebase
、
firebase-realtime-database
、
denormalization
、
nosql
所以这里我有了w1,一个只
使用
练习1的锻炼:首先你做12次练习1,然后休息60秒,然后6次练习2,休息30秒。 最后,我有了一个计划/计划。一个项目由你可以遵循的多项锻炼组成。
浏览 0
提问于2017-09-01
得票数 1
1
回答
Apache Kafka 1.0.0
Streams
API
多个多级分组方式
java
、
apache-kafka
、
apache-kafka-streams
如何在Kafka
Streams
API
中
使用
带多个约束的.groupby。与下面的
Java
8
Streams
API
示例相同 final Map<String
浏览 1
提问于2018-02-22
得票数 7
2
回答
在Akka
Streams
Custom Graph Stage中包装Pub-Sub
Java
API
scala
、
akka
、
akka-stream
我正在
使用
一家提供实时流的数据供应商的
Java
API
。我想
使用
Akka
streams
来处理这个流。
Java
API
有一个pub sub设计,其工作原理大致如下: Subscription sub = createSubscription(); sub.addListener(new Listener谁能指导我
使用
Akka与这个
API
交互的最佳方式?Akka
Streams
是这里最好的工具吗?
浏览 32
提问于2021-09-28
得票数 1
回答已采纳
1
回答
MockSchemaRegistryClient未注册avro模式:无法从模式注册表获取模式
apache-kafka
、
apache-kafka-streams
、
confluent-platform
、
confluent-schema-registry
我正在
使用
spring 2.6.3 EmbeddedKafka和Junit 5编写一个spring引导集成测试,用于
使用
avro消息的拓扑结构。在测试中我
使用
的是MockSchemaReigstryClient at org.apache.kafka.
streams
.processor.internals.Stre
浏览 9
提问于2021-01-10
得票数 3
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
使用Java Streams查询数据库
流式处理:使用 Apache Kafka的Streams API 实现 Rabobank 的实时财务告警
Java开发中新时间api的使用
使用 Stream API 高逼格 优化 Java 代码!
OpenJDK Java 20 正式发布:更新 Vector API、作用域值等
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券