2回答
如何在spring boot测试中禁用kafka连接？
spring-boot、spring-test、spring-kafka
我使用spring kafka消费来自kafka主题的消息，所以我有一个kafka消费者配置类： @Configuration // kafkaconsumer configurations
} 我有一些JUnit测试，会用mockMvc加载spring上下文来测试我的API，我不想测试与kafka消息相关的功能，我如何才能阻止kafka只为它总是失败，因为我
浏览 115提问于2019-08-29得票数 1
1回答
Spring Kafka - broker重新连接事件
java、spring、apache-kafka、spring-kafka
我正在我的应用程序中测试Kafka broker down场景。如果Kafka broker宕机，我的应用程序中会出现NonResponsiveConsumerEvent事件，如果我带回我的Kafka broker，是否有任何事件或任何东西可以用来通知用户它已成功重新连接
浏览 47提问于2019-10-16得票数 0
回答已采纳
1回答
卡夫卡码头与LEADER_NOT_AVAILABLE
docker、apache-kafka
<KAFKA_ADVERTISED_PORT>${kafka.port}/KAFKA_ADVERTISED_PORT> <KAFKA_MESSAGE_MAX_BYTES>15000000</KAFKA_MESSAGE_MAX_BYTES
浏览 0提问于2018-08-25得票数 2
1回答
如何解决spring kafka中的重平衡或重复记录问题
spring-kafka
我总是为卡夫卡担心1.重复2.遗失记录
我在spring Kafka 2.2.2版本中做了以下修改来解决上面的问题。有人能确认一下这是不是正确的。
浏览 1提问于2019-11-18得票数 0
1回答
不是向所有订阅者播放有关单个主题的Kafka刷新事件。
spring-boot、apache-kafka、spring-cloud-config
我得到了一个意外的场景，一个Kafka主题的所有订阅者( Spring应用程序)都没有得到Spring配置更改刷新通知。只有一个拥有Kafka分区的订阅者获得刷新通知。没有为其他订阅者分配Kafka分区，也没有获得刷新事件。
浏览 3提问于2022-03-21得票数 0
2回答
将消息从Kafka路由到连接到应用服务器集群的web套接字客户端
websocket、apache-kafka、spring-kafka
我想找出将消息从Kafka路由到连接到负载均衡应用服务器集群的web套接字客户端的最佳方法。我理解spring为使用和发布到kafka主题的消息提供了便利，但是在负载平衡的应用服务器场景中，当连接到分布式kafka主题时，这是如何工作的。但我不知道在负载平衡的应用服务器场景中，在每个应用服务器上都有消费者组成了kafka
浏览 4提问于2019-10-15得票数 5
回答已采纳
2回答
Kafka流并发？
apache-kafka、apache-kafka-streams
我有一些基本的Kafka流代码，可以从一个主题读取记录，进行一些处理，并将记录输出到另一个主题。如果它是多线程的，我需要了解它是如何工作的，以及如何处理资源，比如SQL数据库连接应该在不同的处理线程中共享。相对于其他选项(Spark、Akka、Samza、Storm等)，Kafka内置的</
浏览 1提问于2016-10-12得票数 27
回答已采纳
1回答
带加密的IBM AS400
ibm-midrange、cdc、ibm
我想确认是否有可能将加密的数据从AS400传输到目标，就像云上的Apache Kafka一样。据我所知，IBM Series-i没有这样的选项，但在Linux和Windows上可用。因此，不能使用以下命令配置IBM数据复制(CDC)：MQ w/o加密的安全性是一个很大的问题。即使有安全的隧道，但不允许有未加密的<
浏览 17提问于2020-02-19得票数 2
回答已采纳
1回答
连续地听一个主题，获取数据，执行一些基本清理。
apache-kafka、kafka-consumer-api、apache-kafka-streams
我将构建一个基于Java的Kafka流应用程序，它将连续地侦听一个主题X，获取数据，执行一些基本的清理，并写入Oracle数据库。kafka集群不在我的域中，无法在其中部署任何代码或配置。设计这样一个解决方案的最佳方法是什么？我遇到了Kafka流，但对于它是否可以用于“Topic> Process >Topic”场景感到困惑吗？
浏览 0提问于2018-11-27得票数 0
回答已采纳
2回答
Kafka流:如何确保在完成处理后提交偏移量
apache-kafka、apache-kafka-streams
我想使用卡夫卡流来处理卡夫卡主题中的信息。有谁能给我建
浏览 6提问于2019-11-12得票数 6
回答已采纳
1回答
用于kafka生产者python api部署的Azure应用程序服务
python、azure、apache-kafka
场景:我想通过管道在Azure上部署一个kafka python生产者api。我有一个工件，这是一个生产者python代码，需要部署在azure应用程序服务上。问:在azure应用程序服务上部署此代码真的值得推荐吗？(知道这不是webapp，只是内部应用程序的kafka生成器)。什么服务可以用来在azure上运行这样的python代码？
浏览 15提问于2020-06-16得票数 0
回答已采纳
1回答
如何可靠地跨微服务同步数据
caching、apache-kafka、microservices
我正在构建一个由微服务组成的系统，其中一些微服务需要“缓存”其他微服务拥有的数据--这是一种经典的数据去规范化方案。拥有数据的microservice将状态更改事件发布到Kafka主题，以便其他微服务可以使用以保持其缓存的更新。然而，这种方法存在一些挑战，例如: Kafka主题中的数据保存时间有限(7天)，几周后部署的新消费微服务仍然需要一种从头构建缓存的方法。我已经研究过解决这个问题的不同方法，包括使用Transa
浏览 7提问于2022-04-18得票数 0
1回答
我可以在三台不同的机器上安装生产者、经纪人和消费者吗？
apache-kafka、kafka-producer-api
我有以下架构：我很困惑
1) whetherI can run kafka producer, broker and consumer on sepa
浏览 6提问于2015-11-02得票数 0
回答已采纳
2回答
修改Java Springboot应用程序的优势？
docker、apache-kafka、apache-kafka-streams、apache-kafka-connect
我们的工作环境是一个被篡改的卡夫卡。我想知道在这种场景中部署kafka连接器和kafka流应用程序的最佳实践。目前，我们正在将每个连接器和流部署为springboot应用程序，并作为systemctl微服务启动。我不认为在对接每个卡夫卡连接器和流明显的优势。请给我提供同样的见解。
浏览 1提问于2018-02-20得票数 4
回答已采纳
5回答
卡夫卡对卡夫卡流
scala、akka-stream、apache-kafka-streams、typesafe、stream-processing
我知道，基于Akka的方法实现了反作用规范，并处理了kafka流似乎缺乏的背压和功能。
卡夫卡流比卡夫卡流有什么优势？
浏览 6提问于2017-08-11得票数 49
回答已采纳
2回答
春云中的动物园管理员数据流保持断开
apache-kafka、apache-zookeeper、spring-cloud-dataflow
它很好地启动，但是当尝试部署任何流时，我会在应用程序日志中得到以下错误spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream.kafka.binder.zkNodes=15
浏览 4提问于2017-03-09得票数 1
回答已采纳
1回答
卡夫卡流中的流和表的二重性细节
apache-kafka、apache-kafka-streams
汇合文档状态
Kafka在许多方面利用了这种二重性:例如，使应用程序具有弹性，支持容错状态处理，或者针对应用程序的最新处理结果运行Kafka Streams交互式查询。想知道在这些场景中如何使用流/表的二重性是否有更多的细节。寻找一些简单的解释而不是一些冗长的设计文档
浏览 3提问于2020-06-26得票数 0
1回答
Spark -获取Kafka的最早和最新偏移量，无需打开流
scala、apache-spark、apache-kafka
我目前正在使用spark-streaming-kafka-0-10_2.11将我的spark应用程序与kafka队列连接起来。对于Streams来说，一切都很好。然而，对于特定的场景，我只需要一次kafka队列的全部内容-为此，我得到了更好地使用KafkaUtils.createRDD ()的建议。然而，对于spark-streaming-kafka-0-10_2.11，我不知道如何为我的K
浏览 5提问于2017-06-26得票数 5
1回答
中断行为-在使用新数据之前耗尽全部缓冲区
java、asynchronous、apache-kafka、disruptor-pattern、lmax
我有以下场景。 我们在K8s的云中对我们的应用程序进行了负载测试。我们的入站消息是通过Kafka发送的，我们正在给Kafka回信。我们的架构是这样的: Kafka线程将消息推送到disruptor (阻塞等待策略，512大小)，业务线程将消息从disruptor中取出进行处理。为了模拟负载，我们在Kafka主题(4个分区)中设置了应用程序未运行时的</em
浏览 35提问于2020-07-21得票数 0
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号