对于Java/Kotlin Spring启动应用程序，如果我想向Kafka发送消息或使用来自Kafka的消息。你会推荐使用Spring Kafka库还是只使用Kafka Java API。不太确定Spring提供了更多的好处，还是仅仅是一个包装器？对于Spring，它们提供了很多注释，当出现一些运行时错误时，这些注释看起来更神奇。
想听听你的</
浏览 5提问于2018-07-28得票数 1
回答已采纳
我们最近开始使用Kafka，我正在使用Kafka Java原生消费者API编写一个Kafka消费者应用程序。 });
}
我只是在寻找一种更好的方法，使用原生
浏览 0提问于2019-06-05得票数 0
1回答
我们有一些使用编写的应用程序，并且有兴趣将后端从Kafka交换到Pulsar。Spring目前没有任何对Kafka的原生支持，但是pulsar似乎提供了使用Kafka API直接与pulsar通信()的能力。我想知道是否有人尝试在Spring cloud消息传递的上下文中使用这个Kafka-clients库的替代品。当然，另一种有效的</
浏览 12提问于2019-11-23得票数 3
我有一个gradle项目，它被用作其他项目中的库。库项目指定了一个依赖项： compile('org.apache.kafka:kafka-clients') { }
} 然而，当构建另一个使用这个库的项目时，版本被降级到'2.3.1‘。我发现这是因为该项目还使用了Spring Boot gradle插件，而Sprin
浏览 112提问于2021-08-03得票数 0
我的生产代码运行得很好，但是我的集成测试抛出了SecurityProtocol的ClassNotFoundException。我使用的是spring-boot-parent 1.5.10.RELEASE。pom时，我得到了一个不同的错误： <groupId>org.springframework.kafka</groupId>
<artifactId>spring
浏览 0提问于2018-02-16得票数 6
回答已采纳
如何仅打印json文件中的属性行{ "items" : [ "href" : "
浏览 0提问于2018-05-27得票数 10
回答已采纳
一个在Spring-boot 2.2.6.RELEASE和Spring-kafka 2.4.1.RELEASE上运行我们的测试套件的项目在升级到Spring-boot 2.3.1.RELEASE和Spring-kafka它似乎找不到kafka.utils.TestUtils。
我已经尝试将spring-kafka版本留空，以便允许spring-boot提取一个兼容的</em
浏览 0提问于2020-07-15得票数 0
我的理解是，创建是为了与Kafka客户端API交互，后来创建项目是为了“构建与共享消息传递系统相连接的高度可伸缩的事件驱动的微服务”，该项目包括两个绑定程序，其中一个是允许与Kafka交互的绑定器。spring-cloud-stream-binder-kafka-streams
因此，我很清楚，如果我想与Kafka交互，我将使用sprin
浏览 3提问于2021-11-10得票数 0
回答已采纳
java.lang.NoClassDefFoundError: org/apache/kafka/common/security/auth/SecurityProtocol
下面是pom文件中的依赖项。<gr
浏览 2提问于2018-06-06得票数 3
回答已采纳
有谁有使用kafka stream和spring boot将消息作为流读取的hello world示例。 我的kafka集群是受SASL_安全保护的。那么我如何将我的spring boot kafka流应用程序与。在application.properties文件中写什么。 我不想用春天的云溪。server.port=8084 server.servle
浏览 21提问于2020-07-10得票数 0
1回答
Kafka JDBC connect兼容Spring-Kafka库吗？
我确实关注了，但仍然有一些困惑。
浏览 4提问于2020-07-04得票数 0
我用以下程序制作卡夫卡的唱片：import java.security.SecureRandom;
WITH (TIMESTAMP='lastconnectedtime', TIMESTAMP_FORMAT='yyyy-MM-dd HH:mm:ss', KAFKA</
浏览 3提问于2020-06-02得票数 0
回答已采纳
2回答
我想使用spring支持与kafka集成。服务器版本为0.8.2.2，但我找到的所有spring项目都使用了更新的kafka。即使是spring-kafka-1.0.0也使用kafka 0.9.0.1。我读到卡夫卡的客户不是向后兼容的。所以问题是:是否有春天的支持，更早的卡夫卡版本，或我必须找到正式的卡夫卡客户，并做它自己？
浏览 0提问于2016-11-22得票数 0
回答已采纳
如何在lvl属性中手动添加kafka属性autoStartUp false？我的意思是，例如，我可以这样做： @KafkaListener(autoStartUp = "false") 但我想在ConsumerProperties中，在自己的BeanPostProcessor中完成例如，我在ConsumerProperties中找不到此属性： Map props =新的HashMap<>()； props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CO
浏览 216提问于2020-11-05得票数 0
回答已采纳
1回答
我有一个新的SpringBoot2.6.3Java 11应用程序，它依赖于Spring (用生成)。$ mvn dependency:resolve | grep kafka
[INFOmodule name: '2' is not a Java iden
浏览 9提问于2022-01-28得票数 0
回答已采纳
11回答
在库更新之前的Spring / Kafka应用程序中，我使用以下类org.telegram.telegrambots.api.objects.Update将消息发送到Kafka主题。现在我使用以下org.telegram.telegrambots.meta.api.objects.Update。如你所见-他们有不同的包裹。' is not in the trusted packages: [java.util, java</
浏览 2提问于2018-08-04得票数 36
回答已采纳
:spring-integration-core'} 这解决了在2.12中使用spring-kafka$7
at kafka.api.ApiVersion.compare(ApiVe
浏览 37提问于2020-11-04得票数 4
回答已采纳
在我的代码上，甚至在示例代码上，我总是会遇到相同的错误：
java.lang.IllegalStateException: Error retrieving state store: prod-id-count-store$0(InteractiveQueryService.java:115) ~[spring-cloud-stream-binder-kafka-streams-3.2.5.jar:3.2.5](InteractiveQueryService.java
浏览 18提问于2022-10-13得票数 0
回答已采纳
我使用的是1.0.0的Kafka-client版本和2.0.2的Spring-cloud-stream版本。现在我想知道Spring-cloud-stream-binder-kafka的版本，以便将事件流式传输到kafka。(KafkaTopicProvisioner.java:259) ~spring-cloud-stream-binder-kafka-core-2.0.0.RE
浏览 73提问于2019-01-08得票数 1
6回答
更新前的json示例 "href" : "http://master02:8080/api/v1/clusters/HDP/configurations?\nexport JAVA_HOME={{java64_home}}\nexport PATH=$PATH:$JAVA_HOME/bin\nexport PID_DIR={{kafka_pid_dir}(更新后的
浏览 0提问于2018-05-25得票数 0
回答已采纳
云服务器
ICP备案
即时通信 IM
对象存储
云直播
腾讯云开发者
