我正在使用spring与kafka producer API集成。当我得到一些MessageException或ProducerException时，我想停止我的生产者API。在消费者(普通的spring-kafka)中，我使用ConsumerAwareListenerErrorHandler很容易地停止我<e
浏览 17提问于2019-05-27得票数 1
我得到了错误：import java.util.Properties;
impo
浏览 17提问于2020-09-02得票数 19
回答已采纳
将卡夫卡生产商和消费者整合到tomcat网络应用程序中的最佳策略是什么？谢谢
在Spring中使用相同的代码时，我无法生成消息。但是，在独立的Java程序中使用它是有效的。定义了两个资源，一个是使用Kafka本地Java，它正在工作。其他资源正在使用spring集成，而且它不起作用。/kafka/
浏览 1提问于2015-03-05得票数 1
回答已采纳
2回答
目前，我有几个运行良好的集成测试，但是我正在使用注释@QuarkusTestResource在夸克启动之前通过测试容器启动容器，并通过重写扩展QuarkusTestResourceLifecycleManager的容器类的开始方法来调整属性以适应随机测试容器端口。为了进行一些优化，例如，我希望重用启动kafka的容器，因为启动它
浏览 9提问于2022-03-30得票数 2
回答已采纳
我正在使用spring -cloud-stream:1.3.0开发spring启动应用程序。messages，spring-cloud-stream-binder-kafka:1.3.0.RELEASE.我使用spring集成dsl来拆分文件中的行，并使用beanio将行转换为json，要求将成功的下面是application.yml中的配置。当我在我</
浏览 2提问于2017-10-19得票数 1
我是Spring集成的新手；如果我没理解错的话，spring集成有3个关键角色；2个订阅者我能理解使用DB/文件系统作为队列的发布者和订阅者框架。spring集成队列驻留在哪里？如果发布者和订阅者本身是单独进程，它们如何共享通道？通道是否可供发布者进程和订阅者进程访问，因为它们运行在相同的JVM中？这是否意味着，如果publis
浏览 0提问于2017-03-10得票数 1
我使用bitnami/kafka docker模板创建了一个kafka设置。在多次重新创建容器(我无法连接到9092上的Kafka )之后，我终于启动并运行了我的集群。我认为这些问题是由于Docker安装在Windows上而不是Linux上的事实造成的。我目前的问题是，我无法使用kafka</
浏览 48提问于2020-01-19得票数 2
1回答
我有一个卡夫卡生产集群，有5个节点和大约500个主题。我需要扩展我的集群以添加2个新节点，而且由于Kafka不提供自动数据重新分区，所以我希望运行随Kafka发行版一起附带的kafka-reassign-partitions.sh，以重新平衡集群中全部7个节点中的所有主题由于集群中已经有大量的生产数据，
运行此脚本会阻止对我的</em
浏览 1提问于2016-09-12得票数 6
回答已采纳
我刚接触docker，在Docker容器中运行Kafka代理时遇到了问题。我和kafka开发了spring boot应用程序，生产者和消费者在同一个应用程序中。应用程序在没有docker的情况下成功运行，但当我尝试通过主机上的docker容器运行它时，会出现以下错误：
org.apache.kafka.clients.NetworkClient : [Pro
浏览 237提问于2021-02-21得票数 0
我有一个基于Reactor的Spring Boot Kafka流处理应用程序，我正在为它编写集成测试。我使用的是Spring的@EmbeddedKafka代理。我使用的是Confluent的KafkaAvroSerializer和KafkaAvroDeserializer类，只是在我的Spring应用程序配置<
浏览 38提问于2020-12-17得票数 0
在我工作的公司，我们使用Spring for Kafka而不进行身份验证，最近我们做了一些实验来设置Kafka的安全性，并且我们启用了身份验证，这使我们的微服务中的所有消费者/生产商都崩溃了！微型服务机构一直没睡)Authorization Exception and no authorizationExceptionRetryInterval set
org.apache.kafka.co
浏览 23提问于2021-03-07得票数 1
回答已采纳
1回答
春云流多主题事务管理
、、、
我正试图在Java中创建一个PoC应用程序，以便了解在使用Kafka进行消息发布时如何在中进行事务管理。我试图模拟的用例是一个接收消息的处理器。然后，它进行一些处理，并生成两个发送给两个不同主题的新消息。我希望能够将这两条消息作为单个事务处理。因此，如果发布第二条消息失败，我希望滚动(而不是提交)第一条消息。支持这样的用例吗？但是，当我试图通过MessageChannel.send()方法发布消息时
浏览 0提问于2019-08-06得票数 2
回答已采纳
我是第一次接触kafka和kafka streams。我有一个与kafka生产者、消费者、KStream和KTable一起工作的基本Spring服务。现在，我想检查一下我的KTable记录，所以为了达到这个目的，我尝试使用Kafka Query API。Spring的InteractiveQueryService来查询..但是<
浏览 1提问于2019-11-19得票数 1
1回答
我正在尝试将生产者配置添加到我的项目中，使用Spring Integration和下面的Kafka。既然我找不到地方放它，我想我应该把它添加到我的application.properties中，放在下面：s
浏览 4提问于2019-02-18得票数 0
我使用的是spring-cloud-stream-kafka，我不明白如何在使用事务时更改key.serializer属性。这是我的配置： spring: stream: accountSource: destination: account
浏览 13提问于2019-06-18得票数 0
回答已采纳
2回答
我正在编写一个基于Java的Kafka消费者应用程序。我正在使用Kafka -客户端，Spring和Spring作为我的应用程序.虽然Spring允许我轻松地编写Kafka消费者(而不是真正地编写ConcurrentKafkaListenerContainerFactory但是，我无法找到一种使用Spring引导来实现它的简单方
浏览 1提问于2018-05-10得票数 4
回答已采纳
我使用一个单例测试容器来运行多个集成测试： public abstract class BaseIT::getPassword); }
浏览 6提问于2022-05-31得票数 4
1回答
我把这个放在我的船坞里 app: context: .environment: KAFKA_ADVERTISED_LISTENERS: INSIDE://kafka: INSIDE
KAFKA_ZOOKEEPER_CONNECT
浏览 2提问于2022-04-15得票数 0
1回答
我一直在寻找春天测试卡夫卡的最佳方法。据我所知，@EmbeddedKafka更适合于单元测试，但是在真正的工作环境中为Kafka编写集成测试不是更好吗？我到底在用什么测试卡夫卡的单元测试呢？一个真正工作的生产者和消费者应该比嘲笑卡夫卡更有意义。你有什么建议？
浏览 5提问于2022-03-20得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号