我尝试使用嵌入式kafka进行测试，我使用spring boot和junit5，如下所示 @SpringBootTestpublic class MyTest {public void myTestCase() {
} 但是，我的No resolvable bootstrap urls given in bootstrap servers测试失败了 我也在使用一个测试配置文件，在yml文件中我已经 boo
浏览 22提问于2020-01-30得票数 2
我所拥有的：然后，我检查它是否被创建，只是为了确保并得到以下内容：
接下来，我想打开机器，用"SELECT * FROM RawData“检查我的数据，原因: org.apache.flink.kafka.shaded.org.apache.kafka.common.confi
浏览 0提问于2020-06-14得票数 1
我试过的是：
@SpringBootTest(properties = ["application.kafka.bootstrap=localhost:2345"])Use 通过指定引导配置在每个测试中使用不同的引导服务器地址，例如，通过@SpringBootTest覆盖主题配置，从而在每个测试中使用不同的主题名称，就像在前面的项目点将@DirtiesContext添加到每个测试类中的引导
浏览 3提问于2020-01-26得票数 1
回答已采纳
我尝试使用“夸克-快速启动”/“kafka-快速启动”提供的代码，并得到以下错误信息：
用于类。我很好奇，因为代码是由夸克传递的，所以我希望它能正常工作，不会有任何错误。
浏览 4提问于2022-03-10得票数 -1
回答已采纳
为了通过Junit理解Springboot Kafka单元测试，我正在尝试从github中编写已经实现的示例。我是测试新手。当我尝试作为Junit运行它时，我使用了这个代码Github ，然后它给出了下面提到的错误： 2021-06-16 18:14:15.907 INFO 9864 --- [ main--- [ main] kafka.server.KafkaRequestHandlerPool : [data-plane Kafka
浏览 100提问于2021-06-16得票数 0
回答已采纳
我很确定bootstrap.servers是正确的。Maven中有什么冲突吗?或者Kafka有什么问题？？Properties props = new Properties(); props);
获
浏览 1提问于2016-11-16得票数 21
回答已采纳
我正在使用camel-spring-boot-starter中的camel- kafka ，在spring引导项目中将一条消息从一个卡夫卡主题路由到另一个。在某些主题上，我当前的应用程序，它只使用、camel-kafka、和(没有弹簧云流)。
在骆驼中，我们使用urls提供..
浏览 2提问于2018-06-20得票数 0
1回答
我试图发送10条信息给卡夫卡，然后我立即尝试阅读卡夫卡的信息，但不知为什么KafkaConsumer会返回0条记录，我很难理解为什么消费者不能阅读之前发送的信息？import lombok.extern.slf4j.Slf4j;import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.c
浏览 3提问于2021-08-11得票数 0
我有一个Spring Boot (2.3.3)服务，它使用spring-kafka来访问专用的Kafka/Zookeeper配置。我一直在使用服务器设置spring.kafka.bootstrap- application.properties =localhost:9092来访问我的开发/测试Apache Kafka服务。然而，在生产中，我们在Zookeeper中配置了一个<e
浏览 25提问于2020-09-15得票数 1
我想在Spring引导应用程序中使用嵌入式Kafka。我可以使用嵌入式卡夫卡进行Junit测试，但是当我尝试在主要应用程序中使用时，嵌入式Kafka对象还没有被识别出来。当试图加载Spring引导应用程序时，嵌入的kafka对象不是自动加载的。这是用于非测试流的。public static void main(String[] args) throws Exception {
Sys
浏览 3提问于2020-01-16得票数 0
我正在尝试启动标准的DirectKafkaWordCount示例(随Spark2安装提供)，以测试星火流如何与卡夫卡一起工作。-0-10_2.11-2.3.1.jar和kafka-客户端-0.10.0.1.jar放到/usr/hdp/3.0.0.0-1634/spark 2/jars/目录(这让我有点吃惊，因为我认为安装所提供的所有标准示例都必须是开箱即用的添加这些jars之后，我尝试读取主题测试中的<
浏览 1提问于2018-09-26得票数 0
1回答
我正在尝试配置Traefik后面的Kafka集群，但是我的生产商和客户端(在kubernetes之外)没有连接到引导服务器。他们不停地说：
{ "kind
浏览 0提问于2018-10-13得票数 1
1回答
我正面临着一个问题，我的Kafka ProducerConfig获取了一个无效的bootstrap.servers值，因为我的单元测试@PropertySource没有解析spring.embedded.kafka.brokers当我将我的生产者配置转储到日志中时，我得到了以下信息：batch.size = 10000
bootstrap.servers = [${spr
浏览 5提问于2019-03-06得票数 0
我遇到了一个问题与弹簧启动卡夫卡对接，尝试了所有提到的东西在下面的链接，但问题仍然存在。我在运行wrustmiester/kafka和wrustmiester/动物饲养员。如果我在本地运行spring引导应用程序，一切都会顺利运行。当我试图构建我的spring引导应用程序的映像并运行该映像时，就会出现这个问题。那么错误是代理可能是不可用的。
如果有人能引导我。添加我的applic
浏览 2提问于2020-11-03得票数 4
我们目前正在使用HDF (Hortonworks ) 3.3.1，它捆绑了Kafka 2.0.0，并试图在分布式模式下使用Kafka启动Google Sink连接器。我们正计划将一些元数据发送回Kafka主题，并需要将Kafka生成器集成到Sink任务java代码的flush()函数中。会对卡夫卡连接向卡夫卡提交补偿的过程产生负面影响(因为我们将增加运行卡夫卡生产者的开销)。
同样，卡夫卡连接在连接器属性中没有为接收
浏览 3提问于2020-02-12得票数 0
回答已采纳
1回答
我正在运行spring引导，KafkaListener作为我的客户。问题是我们如何从失败的kafka配置中恢复，并避免应用程序停止使用Process finished with exit code 0。一个不正确的配置示例将例如一个不正确的端点url。如果无法访问Kafka服务器，也会出现同样的情况。因此，在任何情况下，KafkaListner进程都不应该关闭服务器。'；
浏览 0提问于2021-07-14得票数 0
回答已采纳
1回答
在单弹簧引导应用程序中，可以配置Kafka来处理两个单独的集群吗？用例：I有两个带有副本+动物园管理员的集群：
引导服务器：server1.example.com,server2.example.com,server3.example.comCluster #2引导服务器-服务器：target-server1.example.com,target-server2.example.com,target-server3.
浏览 1提问于2020-01-10得票数 0
回答已采纳
我有一个使用Spring创建的web应用程序，我正在使用Spring (STS)来开发它。如果我的理解是正确的，tomcat是内置在STS中的，我可以在Application.java的帮助下从STS运行/调试应用程序。现在我的疑问是，当我们以'Spring‘运行java类来运行应用程序时
究竟在哪里部署
浏览 8提问于2017-03-23得票数 0
回答已采纳
我们的Kafka安装在服务器A上，来自不同服务器的生产者使用Java代码添加数据，现在我试图通过服务器B通过PHP来使用数据。我需要传递用户名和密码来访问数据，但是在中，我没有任何方法传递用户名、密码和引导服务器。Java团队使用以下详细信息在kafka中添加数据
spring.kafka.bootstrap-servers=<value-
浏览 13提问于2022-04-26得票数 0
2回答
我试图进行设置，以便当我部署一个新环境时，spring发件人使用的zipkin Kafka主题将有一个较低的保留期，因为它将被其他东西处理，或者被忽略(在开发人员机器上)。String.valueOf(Duration.ofMinutes(2).getSeconds() * 1000)) .replicas(1)}kafka-configs --bootstrap-server $_<e
浏览 12提问于2022-02-19得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
