我有一个Spring引导项目，它具有使用kafka进行日志记录的依赖项。我无法摆脱这种依赖关系，因为我的逻辑需要依赖关系中的代码 我想在不运行kafka的情况下在本地启动该应用程序，这样我就可以测试我的简单数据库查找代码。return factory;
} 但是很明显，这个设置已经是false了，因为我的应用程序可以正常运行，只是tomcat不想打开侦听端口 我遇到的所有其他解决方
浏览 37提问于2020-04-15得票数 2
我已经构建了一个Springboot应用程序，其中一个依赖项是gRPC服务器。在运行集成测试时，我可以使用TestContainers使用embedded Kafka、embedded MySQL等，但是如何在运行集成测试套件的同时创建嵌入式gRPC服务器？我会使用Wiremock来模拟对gRPC服务器的请求和响应，但是我还不能启动嵌入式gRPC服务器。
如果我能在这里找到一些帮助，那就太好了。想想
浏览 0提问于2020-02-26得票数 1
我在我的项目中使用了Kafka和Springboot，现在我有了外部Kafka集群和SpringBoot微服务项目。使用yml文件，我成功地创建了Kafka生产者和消费者，然后应用程序和kafka就可以很好地通信了。 in-memory: true
non-blocking-redelivery: true
浏览 5提问于2019-01-18得票数 1
我已经在我的centos服务器上安装了Apache。我只是想把一条消息写到另一台服务器上的一个主题上。因此，安装之后，我没有启动动物园管理员或Kafka服务器，而只是输入以下命令：我能够从我的服务器平xxx.yyy.com。当我<
浏览 1提问于2019-04-23得票数 0
回答已采纳
我是Spring和Kafka的新手。我正在做一个使用SpringBoot-kafka的用例，允许用户在运行时创建kafka主题。spring应用程序期望在运行时以编程方式订阅这些主题。到目前为止，我所知道的是，Kafka listener是设计时，因此在启动之前需要指定主题。有没有办法在SpringBoot-Kafka集成中动态订阅kafka主题
浏览 0提问于2017-01-08得票数 11
我使用SpringBoot1.5.6 Kerberos 来使用Kerberos身份验证连接到Kafka 0.11。这些是我为Kafka使用的依赖关系： <groupId>org.springframework.integration</groupId</artifactId>
<version>2.1.1.RELEASE</version>
浏览 4提问于2019-02-20得票数 3
回答已采纳
如何在关闭kafka服务器之前获取kafka服务器的所有详细信息，如kafka主题名称、分区、组等。并使用这些信息来准备新的kafka服务器？ 此类型的备份是否有任何选项？
浏览 25提问于2019-01-30得票数 1
回答已采纳
我想用配置好的Kafka服务器运行“独立”Docker容器。我在卡夫卡网站()上了解了如何运行卡夫卡主题：)但是当我按照指示做所有事情时，我需要运行三个终端： ./bin/zookeeper-server-start.sh config/zookeeper.properties.--topic test
问题是:在
浏览 1提问于2019-12-29得票数 0
回答已采纳
我有一个动物园管理员运行在端口2181 (默认)和卡夫卡服务器监听端口9090在我的本地机器。这就产生了错误这是有意义的
浏览 3提问于2018-12-10得票数 1
我有一个应用程序，它使用2.10.0版本中的SpringBoot 2.10.0 version和kafka。这个应用程序有一个简单的生产者和消费者:发送者使用KafkaTemplate，消费者使用KafkaListener。我试图实现的目标是即使KafkaServer没有运行，也能够启动SpringBoot应用程序。目前，如果没有正在运行的KafkaBroker，应用程序将无法启动，并显示以下错误消
浏览 216提问于2019-01-25得票数 2
2回答
我试图为Kafka配置SSL (2.11-2.1.0)。keystore.jkslisteners.https.ssl.key.password=mypassword
没有因为我知道keystore中的密码是绝对正确的，所以我钻研了源代码，并开始调试。最后，我发现无论是普通的ssl.*还是前缀的listeners.https.ssl.*配置都没有被考虑在内，这使得目前
浏览 1提问于2019-03-18得票数 2
我的SpringBoot应用程序正在本地主机上运行，但我希望它与远程服务器下载的Kafka连接，例如123.45.6.789。我能够从mobaxTerm终端生成和使用消息，但由于这个错误，我的springboot应用程序无法与kafka连接。我的application.properties文件kafka</e
浏览 1提问于2022-09-22得票数 1
回答已采纳
我想用kafka压缩消息。因此，我在生产者端启用了压缩类型为gzip，并且没有在server.propeties上做任何更改。config.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "gzip"); 这是我在生产者配置中添加的代码，但当我向主题发送消息时，当我在消费者端读取消息时，有没有人能建议一下在kafka中如何在生产者端做消息压缩？我使用的是JAVA和Springboot。 提前谢
浏览 85提问于2020-11-23得票数 0
有没有可能在SpringBoot上为每个卡夫卡主题的消费者设置不同的投票率？我希望有一个主题是轮询与较长的间隔(如5分钟)。我希望使用它来实现对来自kafka的消息的失败处理的重试。
浏览 106提问于2020-08-20得票数 0
回答已采纳
我发现了几个主题相似但上下文不同的问题:我可以连接来创建主题，但我不能列出主题，因为我得到了下面提到的错误(据我所见，人们面临着基本连接的问题，而我只能列出主题列表)。如果重要的话，下面是我的docker-compose.ymlservices: image: wurstmeister/zookeeper:2181"bash-4.4# kafka-topics
浏览 1提问于2020-01-23得票数 11
回答已采纳
在我的Kafka侦听器中，我抛出一个运行时异常，如下所示： new DeadLetterPublishingRecoverer(template)));
}@KafkaLis
浏览 1提问于2020-04-05得票数 1
回答已采纳
当将项目从Springboot 2.0升级到2.1时，我们还将spring-kafka-integration从3.0.1升级到3.2.1。: Timeout expired while fetching topic metadata
我们的构建机器没有在本地运行卡夫卡，使用EmbeddedKafkaBroker的测试使用了一个自定义JUnit5在新版本中，上下文无法完全启动(自定义扩展甚至没有机会运行)。看看这些属性，我唯一能看到的
浏览 0提问于2019-05-03得票数 4
回答已采纳
提供您正在运行的安装程序的详细信息让我们知道您正在运行的KSQL的版本、操作系统等，KSQL版本: confluent-ksql-5.3.1-1。概述你的问题，问你问题！KSQL无法连接到kafka，导致超时异常。ksql.security.protocol=ssl
ksql.ssl.keystore.location=/root/.kafka/kafka.server.keystore
浏览 52提问于2019-11-13得票数 2
我有一个用例，我想先建立一个Kafka集群，一开始我有一个Kafka代理(A)和一个动物园管理员节点。因此，以下是我的质询：
不让我们想当然地假设这件事！我的数据分布在两个经纪人身上。现在，由于一些维护问题，我想要删除服务器B。如何在运行时增加代理的复
浏览 0提问于2018-12-07得票数 0
我的kafka版本是kafka 2.11-0.0.0[2017-01-31 09:15:55,216] FATAL (kafka.Kafka$)
org.apache.kafka.common.config.ConfigException: Missing required configuration(Kafka.
浏览 35提问于2017-01-31得票数 8
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
