腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(1429)
视频
沙龙
1
回答
Kafka
Streams
DSL
折叠
分层
数据
apache-kafka
、
apache-kafka-streams
使用
Kafka
Streams
DSL
,这是我想要做的: 输入消息序列:键和值键的Avro键:具有字段L1、L2、L3的记录V值:具有值V的记录(在本例中为int) 我想要做的是以这样一种方式来
折叠
这个层级结构v3 + v4L1 Va2 v2 有没有办法让
Streams
DSL
允许这样做?虽然可能有使用处理器API或basic
Kaf
浏览 11
提问于2020-07-06
得票数 0
回答已采纳
1
回答
Kafka
Streams
DSL
进程方法是如何工作的?
apache-kafka
、
apache-kafka-streams
我一直在使用
Kafka
Streams
,并获得了一些基本的功能,但我在理解
Kafka
Streams
DSL
中的process方法时遇到了一些问题。具体地说: 我知道有两种使用
Kafka
Streams
的方法,低级处理API和高级
Streams
DSL
。对于较低的级别,您可以更明确地定义拓扑,命名每个节点等,而流
DSL
则将大部分抽象出来。所以我的问题是,处理过的
数据
-Processor的void f
浏览 9
提问于2020-01-20
得票数 0
回答已采纳
2
回答
Kafka
Streams
- java版本依赖关系
apache-kafka-streams
我正在使用Java1.6运行我的应用程序,并计划将一些方面与
Kafka
集成。 我正在探索是否应该使用
Kafka
Consumer (使用poll())或使用KafkaStreams API。
浏览 3
提问于2018-12-20
得票数 0
1
回答
获取
Kafka
Stream in process()方法
java
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
我正在做一个POC来演示一些Spring Cloud
Kafka
功能。我使用的是带有SpringBoot 2.4.1的Java11。我的build.gradle具有以下库 implementation 'org.springframework.cloud:spring-cloud-stream' implementation 'org.springfram
浏览 0
提问于2021-01-30
得票数 0
3
回答
为什么我会得到这样的编译错误:“找不到kstream.Consumed的隐含值”,我如何修复它?
scala
、
apache-kafka
、
avro
、
apache-kafka-streams
、
jsonschema
我们有以下依赖关系: libraryDependencies += "org.apache.
kafka
" %% "
kafka
-
streams
-scala" % kafkaVersionlibraryDependencies += "io.confluent" % "
kafka
-
streams
-avro-serde" % confluentVersion导入方面,我们要导入
浏览 22
提问于2020-04-08
得票数 2
回答已采纳
1
回答
kafka
流媒体中的消息加密
apache-kafka
、
microservices
、
apache-kafka-streams
我最近正在尝试使用
kafka
streaming进行一些敏感
数据
处理。我希望实现的目标是,当敏感
数据
被加密时,微服务架构的能力不会受到影响,即,紧密耦合的服务和流
数据
处理。我的问题是,在
kafka
流中,有没有可能我用一个密钥解密传入的消息,然后用另一个密钥再次加密?我有一个计划,但由于我不熟悉
kafka
streaming,我不能证明
kafka
streaming有能力使用
Streams
DSL
处理此功能。有没有人能帮我解决这个问题,
浏览 34
提问于2020-01-14
得票数 0
回答已采纳
1
回答
KSQL/
Kafka
Streams
是否支持复杂事件处理?
apache-kafka
、
apache-kafka-streams
、
complex-event-processing
、
ksqldb
我想在
kafka
中做事件的用户行为分析。KSQL/
Kafka
Streams
现在是否支持复杂事件处理?
浏览 1
提问于2018-12-06
得票数 1
1
回答
在分级多模块kotlin
DSL
中添加的subprojects.forEach中的依赖项对于子项目是不可见的。
gradle
、
build.gradle
、
gradle-kotlin-dsl
我有多模块分级项目与kotlin
dsl
称为流
数据
处理.它在github 。build.gradle.kts文件是- base } testImplementation("junit:junit:4.1
浏览 1
提问于2019-04-09
得票数 0
1
回答
Kafka
处理的生产者-消费者处理模式
apache-kafka
-> processor1 ---> *K-topic2* ---> processor2 --> K主题组件表示
Kafka
对于处理器组件,其目的是读取/使用主题中的
数据
,对其执行一些处理/ETL,并将结果持久化到链中的下一个主题以及持久存储,如S3。 我有一个关于设计方法的问题。
浏览 1
提问于2019-01-03
得票数 0
1
回答
scala不使用
kafka
-
streams
-scala和maven
java
、
scala
、
maven
、
build
、
apache-kafka
它是用Scala编写的,它使用
Kafka
流
DSL
。我本来要使用新的
kafka
-
streams
-scala包,现在我正在使用Maven。我现在不能用SBT。当我添加依赖项时 <groupId>org.apache.
kafka
</groupId> <artifactId>
kafka
-
streams
-scala当我这样做时,我会得到以下错误object
浏览 0
提问于2018-09-12
得票数 0
回答已采纳
1
回答
事件计数的窗口聚合
java
、
apache-kafka
、
kafka-consumer-api
、
apache-kafka-streams
我对我的
kafka
事件进行了分组: private static void createImportStream(final StreamsBuilder builder, final Collection
浏览 8
提问于2020-03-31
得票数 2
回答已采纳
1
回答
Kafka
streams
DSL
报头支持
apache-kafka-streams
我们如何在
DSL
中做同样的事情?
浏览 17
提问于2019-02-26
得票数 0
回答已采纳
2
回答
如何修改卡夫卡单词计数程序中的KStream键和值?
scala
、
apache-kafka
、
apache-kafka-streams
._import org.apache.
kafka
.clients.consumer.ConsumerConfigimport org.apache.
kafka
.common.serialization.word
浏览 1
提问于2020-03-21
得票数 1
回答已采纳
2
回答
Kafka
Streams
DSL
over
Kafka
Consumer API
apache-kafka
、
kafka-consumer-api
、
apache-kafka-streams
最近,在一次采访中,我被问到一个关于
Kafka
Streams
的问题,更具体地说,面试官想知道为什么/什么时候你会使用
Kafka
Streams
DSL
而不是普通的
Kafka
Consumer API来读取和处理消息流
浏览 2
提问于2020-09-13
得票数 3
1
回答
有多个主题分区的
Kafka
流无法重新均衡错误
apache-kafka
、
apache-kafka-streams
既适用于低级,也适用于
DSL
API。有什么建议吗?可能会遗漏什么?org.apache.
kafka
.
streams
.errors.StreamsException: stream-thread [StreamThread-1] Failed to rebalanceat org.apache.
kafka
.
streams
.processor.internals.StreamThread.run(StreamThread.java:242) Caused by: org.apache.
kafka<
浏览 3
提问于2017-02-19
得票数 6
回答已采纳
1
回答
使用带有Spark的
Kafka
比仅使用Spark的优点
apache-spark
、
apache-kafka
、
stream-processing
Kafka
是很常见的。所以很多公司都在使用它。我完全理解
Kafka
和Spark是如何工作的,我对他们都很有经验。我不理解的是用例。为什么你要把
Kafka
和Spark一起使用,而不仅仅是Spark呢?在我看来,
Kafka
的主要用途是作为ETL管道中的中转区,用于实时(流)
数据
。 我假设有一个
数据
源集群,
数据
最初存储在其中。例如,它可以是Vertica、Cassandra、Hadoop等。然后是一个处理集群,它从
数据
源集群读取
数据
,并将其
浏览 3
提问于2019-06-17
得票数 3
1
回答
如何避免在
Kafka
streams
中创建changelogs?
apache-kafka
、
apache-kafka-streams
我试图避免使用inMemoryWindowStore在
Kafka
streams
中创建changelog主题(我使用的是
Kafka
2.3.0和
Streams
DSL
),我也在调用withLoggingDisabled(),但不知何故,当应用程序启动时,changelog主题会被创建,也会使用,因为我可以看到其中的
数据
。
浏览 15
提问于2019-07-09
得票数 1
回答已采纳
2
回答
KStream加入重试/延迟的KStream
apache-kafka
我们正在尝试实现下面描述的用例,我们有我们希望克服的实现问题,我们正在尝试通过匹配两个流的消息中存在的关键字(JSON)来在两个
Kafka
主题之间进行KStream连接。
浏览 2
提问于2019-05-08
得票数 2
6
回答
Kafka
Streams
:流式计算、
Kafka
Streams
的特点和架构是什么?
api
Kafka
在0.10版本推出了Stream API,提供了对存储在
Kafka
内的
数据
进行流式处理和分析的能力。小白一名,各位大佬能给我解释一下流式计算、
Kafka
Streams
的特点和架构吗?谢谢!
浏览 2081
提问于2018-09-14
0
回答
KafkaStreams - InconsistentGroupProtocolException
apache-kafka
、
apache-kafka-streams
我有一个
Kafka
Streams
应用程序,它使用
Kafka
Streams
DSL
连接到我们的
Kafka
集群,如下所示:consumer.poll(500L);consumer.close(); 我这样做的原因是为了在有条件地启动应用程序的其他部分(包括
Kafka
<
浏览 5
提问于2017-01-12
得票数 8
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
初探Kafka Streams
Kafka streams概览
Kafka 1.0.1案例详解之Kafka Streams
Kafka 2.0正式发布,带来众多改进
Apache Kafka 2.0.0 正式发布,分布式消息发布订阅系统
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券