我可以使用处理器上下文检查处理器API中的头部支持。我需要根据header来决定推送记录的流。我们如何在DSL中做同样的事情？
浏览 17提问于2019-02-26得票数 0
回答已采纳
在kafka Streams中，我尝试使用头部。Producer正在向BytesObject添加头部，并将数据推送到kafka。 例如，报头是特定dataType(customObject)。现在，基于标头，我想解析并反序列化在kafka流中接收的BytesObject，但我受到使用processorInterface的约束，其中我必须传递实际的反序列化器 有没有什么方法可以不事先指定反序列化
浏览 19提问于2019-02-16得票数 1
我正在使用Java1.6运行我的应用程序，并计划将一些方面与Kafka集成。
我正在探索是否应该使用Kafka Consumer (使用poll())或使用KafkaStreams API。
浏览 3提问于2018-12-20得票数 0
我一直在使用Kafka Streams，并获得了一些基本的功能，但我在理解Kafka Streams DSL中的process方法时遇到了一些问题。具体地说： 我知道有两种使用Kafka Streams的方法，低级处理API和高级Streams DSL。对于较低的级别，您可以更明确地定义拓扑，命名每个节点等，而流DSL则将大部分抽象出来。在低级处理API中，您将自己命名为processor Node，并且可以将Sin
浏览 9提问于2020-01-20得票数 0
回答已采纳
我们有以下依赖关系： libraryDependencies += "org.apache.kafka" %% "kafka-streams-scala" % kafkaVersionlibraryDependencies += "io.confluent" % "kafka-streams-avro-serde" % confluentVersion导入方面，我们要导入
浏览 22提问于2020-04-08得票数 2
回答已采纳
我想在kafka中做事件的用户行为分析。KSQL/Kafka Streams现在是否支持复杂事件处理？
浏览 1提问于2018-12-06得票数 1
1回答
事件计数的窗口聚合
、、、
我对我的kafka事件进行了分组： private static void createImportStream(final StreamsBuilder builder, final Collection
浏览 8提问于2020-03-31得票数 2
回答已采纳
我正在做一个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
它是用Scala编写的，它使用Kafka流DSL。我本来要使用新的kafka-streams-scala包，现在我正在使用Maven。我现在不能用SBT。当我添加依赖项时 <groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams-scala当我这样做时，我会得到以下错误object
浏览 0提问于2018-09-12得票数 0
回答已采纳
._import org.apache.kafka.clients.consumer.ConsumerConfigimport org.apache.kafka.common.serialization.word
浏览 1提问于2020-03-21得票数 1
回答已采纳
1回答
我最近正在尝试使用kafka streaming进行一些敏感数据处理。我希望实现的目标是，当敏感数据被加密时，微服务架构的能力不会受到影响，即，紧密耦合的服务和流数据处理。我的问题是，在kafka流中，有没有可能我用一个密钥解密传入的消息，然后用另一个密钥再次加密？我有一个计划，但由于我不熟悉kafka streaming，我不能证明kafka streaming有能力使用Streams DSL处理此功能。有没有人能帮我解决这个问题，最好告诉我Streams D
浏览 34提问于2020-01-14得票数 0
回答已采纳
是否可以在单个事务中生成Kafka主题并写入状态存储？而不是作为主题消费的一部分启动事务。
编辑:我这么做的原因是为了能够过滤掉重复的请求。
浏览 3提问于2019-03-01得票数 0
最近，在一次采访中，我被问到一个关于Kafka Streams的问题，更具体地说，面试官想知道为什么/什么时候你会使用Kafka Streams DSL而不是普通的Kafka Consumer API来读取和处理消息流
浏览 2提问于2020-09-13得票数 3
从kafka流应用程序的角度来看，这种类型违背了在创建avro serdes时支持多个urls的功能，因为DSL堆栈中出现的运行时异常将关闭stream Thread。(KafkaAvroSerializer.java:53)at org.apache.kafka.streams.processor.intern
浏览 0提问于2018-11-02得票数 2
回答已采纳
既适用于低级，也适用于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
回答已采纳
Kafka是很常见的。所以很多公司都在使用它。我完全理解Kafka和Spark是如何工作的，我对他们都很有经验。我不理解的是用例。为什么你要把Kafka和Spark一起使用，而不仅仅是Spark呢？在我看来，Kafka的主要用途是作为ETL管道中的中转区，用于实时(流)数据。
我假设有一个数据源集群，数据最初存储在其中。例如，它可以是Vertica、Cassandra、Hadoop等。然后是一个处理集群，它从数据源集群读取数据，并将其写入分布式Kafka日志，这基本上是一个登台数据集群。然后是另一个处理集
浏览 3提问于2019-06-17得票数 3
2回答
implementation (('org.apache.kafka:kafka-streams:2.3.0'), {无法为参数org.rocksdb:rocksdbjni:5.18.3在DefaultExternalModuleDependency{group='org.apache.kafka'，名称=‘kafka’
浏览 10提问于2020-07-13得票数 1
回答已采纳
我有多模块分级项目与kotlin dsl称为流数据处理.它在github 。build.gradle.kts文件是- base }
浏览 1提问于2019-04-09得票数 0
我目前正在使用Kafka流式DSL抑制功能的日期窗口。我们可能会遇到这样一种情况，一些事件可能会很晚才发生，超过了宽限期。
根据kafka流媒体文档，这样的事件将被丢弃，这不适合window。2)考虑到数百万事件流经系统，如何使用DSL- suppress将间歇性聚合数据保存在内存中？任何timeline kafka流媒体社区都将很快提供rockDB支持，以避免应用程序因内存不足而崩溃。
浏览 2提问于2019-05-15得票数 0
1回答
我正在开发一个java应用程序，从来源接收实时数据(Kafka/Kafka流)。在我的案例研究中，我需要过滤我列表中的名字。这份名单最初有1000万个名字。
浏览 2提问于2020-01-25得票数 0
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
