1回答
我有一个弹簧引导应用程序，使用卡夫卡消费者和生产者。卡夫卡的所有配置都在application.yml上 kafka: enable-auto-commit: true:9092,kafka-1.kafka-headless.dev-streams.svc.cluster.local:9092,kafka-2.kafka</e
浏览 1提问于2020-11-23得票数 1
我正在学习O‘’Reiley的KafkaStreams课程，但是在Java中运行KafkaStreams v2.0.0有问题；我的代码和属性配置如下：
KafkaStreams streams =，但奇怪的是，我收到关于消费者客户端尝试连接到不存在<em
浏览 10提问于2019-08-15得票数 0
回答已采纳
我在读关于Kafka Stream - Elastic Scaling特性的文章。但是没有这样的细节给出重新平衡是如何工作的？是和Consumer Group的工作原理一样，还是因为Kafka Stream实例并不完全是consumer Group中的Consume
浏览 0提问于2019-11-14得票数 0
我正在使用Java1.6运行我的应用程序，并计划将一些方面与Kafka集成。
我正在探索是否应该使用Kafka Consumer (使用poll())或使用KafkaStreams API。我们需要Java 1.7 / 1.8来使用Stream API吗？
浏览 3提问于2018-12-20得票数 0
我们正在使用低级处理器API开发一个Kafka Streams应用程序。 根据Kafka上的文档，所有的线程和并行性都是由Stream线程和流任务处理的。使用主题上的分区，并行性也是可扩展的。这意味着使用Kafka Streams API主要用于消费主题中的数据，而不是用于实际处理。实际处理将在Kafka流线程
浏览 15提问于2019-05-29得票数 2
我正在使用Kafka Streams处理器API构造一个Kafka Streams应用程序，以便从Kafka主题检索消息。我有两个使用相同Kafka Streams配置的消费者应用程序。第一个有2000个字符(3KB)的消息，第二个有34000个字符(60KB)的消息。现在，在我的第二个消费者
浏览 22提问于2019-03-22得票数 2
回答已采纳
每隔一次，容器就会被部署到改进中，这样就可以随机地将消费者应用程序的实例删除。升级的终止过程是SIGKILL，同时创建运行实例的副本。当实例离开组&加入组时，这会导致重新平衡。我想知道是否应该为消费者应用程序的每个实例设置唯一的group.instance.id (appname-inst-1，appname-instnace-2等)。或者它应该是消费者组特有的(类似于消费者组id (即整个消费者</
浏览 5提问于2021-05-26得票数 1
我做过一些Kafka流应用程序和Kafka消费者应用程序。归根结底，Kafka流只是消费者，它消费来自Kafka的实时事件。所以我不知道什么时候使用Kafka streams，或者为什么我们应该使用Kafka streams，因为我们可以在消费者端执行所有的转换。我想了解Kafka stream和Kafka c
浏览 4提问于2019-12-04得票数 4
我正在做一个POC来演示一些Spring Cloud Kafka功能。我使用的是带有SpringBoot 2.4.1的Java11。我的build.gradle具有以下库 implementation 'org.springframework.cloud:spring-cloud-stream'
浏览 0提问于2021-01-30得票数 0
我使用的是Kafka Stream API。当我启动我的应用程序时，有时会有一个间隙，我想从一个特定的偏移量开始消费。最早或最晚的不是我想要的。streamProperties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); 我正在寻找的是一个场景，比如我在配置文件中设置了偏移量或以毫秒为单位的
浏览 25提问于2020-05-02得票数 2
回答已采纳
我是第一次接触kafka和kafka streams。我有一个与kafka生产者、消费者、KStream和KTable一起工作的基本Spring服务。现在，我想检查一下我的KTable记录，所以为了达到这个目的，我尝试使用Kafka Query API。来查询..但是我在Spring boot中遇到了一些相关的问题。在Spring中使用kafka
浏览 1提问于2019-11-19得票数 1
我正在与NodeJs MS合作，到目前为止，他们通过Kafka消费者/制片人进行通信。现在我需要安装一个Loggger MS，它必须记录所有消息并进行一些处理(解析并保存到db)，但我不确定是否可以使用Kafka Stream改进当前的方法，或者是否应该继续使用使用者
浏览 4提问于2020-02-11得票数 0
回答已采纳
我想在我的spring boot项目中使用Kafka Streams实时处理。所以我需要Kafka Streams配置，或者我想使用KStreams或KTable，但我在互联网上找不到示例。我做了生产者和消费者，现在我想要实时流媒体。
浏览 1提问于2018-08-08得票数 17
回答已采纳
我有一个使用处理器api的拓扑，它更新了一个状态存储，配置了复制因子3，acks=ALL Topologies: Source: products-sourceproducts-source <-- products-processor 我的监控显示，源主题(< 100条记录)的延迟很小，但是支持存储
浏览 25提问于2020-11-28得票数 3
回答已采纳
我有一个Kafka Streams应用程序，它正在从一个Store Changelog中读取，它偶尔会抛出这个错误： at org.apache.kafka.streams.processor
浏览 1提问于2018-06-26得票数 1
回答已采纳
我试图将目前用Java代码编写的spring应用程序的配置具体化。到目前为止，看来我应该把我所有的配置都放到KafkaStreamsConfiguration类型的bean中，以便配置我的kafka-streams应用程序。当我将此配置具体化时，从ProducerConfig和ConsumerConfig在application.properties文件中设置的属
浏览 1提问于2019-06-13得票数 3
回答已采纳
需要一些帮助，找出我收到的一个卡夫卡流消费者的例外。
我用低级别处理器API实现了Kafka流。对于从Kafka接收到的每一次更新，都会将其合并并更新到keystore，从而维护状态。最初，我们只运行了一个消费者，过了一段时间，我们尝试提出第二个消费者。但第二个消费者在再平衡期间抛出了一个例外，称其未能实现再平衡。这是因为更改日志的状态发生了更改(下面的异常共享)。我假设，当重新平衡发生时，第一个<
浏览 2提问于2017-08-30得票数 1
回答已采纳
我正在使用Kafka创建一个销售线索和活动管理系统。问题是我们得到了许多虚假的线索(广告)。我们的系统中也有很多消费者。在投放给消费者之前，有没有过滤广告的方法？我的解决方案是将所有内容写入第一个主题，然后由筛选器使用者读取它，然后将其写回第二个主题或对其进行筛选。但我不确定它是否有效。有什么想法吗？
浏览 33提问于2015-06-18得票数 14
回答已采纳
我刚接触Apache Kafka和它的与API相关的流服务，但想知道是否有任何正式的文档来获取摄取所需的初始原始数据？从本质上讲，我想尝试构建一个初级的密码交易机器人，但我的印象是http API可能比与Kafka Streams集成的API具有更多的延迟。例如，我知道RapidAPI有一个可以访问的http库，可以帮助提取数据
浏览 0提问于2021-06-05得票数 0
我试图创建一个简单的应用程序，将我网站上每个网页的页面查看情况写入Cassandra。我想从一个逻辑小时开始每5分钟写一次累积页面浏览量。我的代码如下所示： .groupByKey我现在的问题有两个：
考虑到我有自己的Cassandra驱动程序，我如何编写聚合到Cassandra的5分钟中间结果？试
浏览 2提问于2017-09-07得票数 0
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号