我应该在每个服务spring kafka中创建NewTopics吗？
在每个服务Spring Kafka中创建NewTopics是根据具体情况而定的。NewTopics是用于在Kafka中创建新主题的类，可以通过编程方式在应用程序中创建主题。以下是关于是否应该在每个服务Spring Kafka中创建NewTopics的一些考虑：
- 需要创建新主题：如果你的应用程序需要使用新的主题来存储消息，那么你可以考虑在每个服务Spring Kafka中创建NewTopics。这样可以确保在应用程序启动时自动创建所需的主题。
- 动态主题创建：如果你的应用程序需要动态地根据业务需求创建新主题，那么在每个服务Spring Kafka中创建NewTopics可能是一个好的选择。通过编程方式创建主题可以根据需要动态创建新的主题。
- 固定的主题列表：如果你的应用程序只需要使用固定的主题列表，并且这些主题已经在Kafka中提前创建好了，那么就不需要在每个服务Spring Kafka中创建NewTopics。
总的来说，是否应该在每个服务Spring Kafka中创建NewTopics取决于你的具体需求。如果你需要动态地创建新主题或者需要在应用程序启动时自动创建主题，那么可以考虑使用NewTopics来创建主题。但如果你的应用程序只需要使用固定的主题列表，则不需要创建NewTopics。
对于Spring Kafka的具体用法和推荐的腾讯云相关产品，你可以参考腾讯云官方文档中的Spring Kafka部分：https://cloud.tencent.com/document/product/301/32215
请注意，本回答没有提及任何具体的云计算品牌商，只提供了与问题相关的内容。
相关·内容
我使用Kafka在服务之间发送消息。我使用NewTopic bean来配置分区数量，例如： @Bean kafkaProperties.topics.schedulerCalculationTopic.partitions,
浏览 45提问于2021-08-16得票数 1
回答已采纳
我设想自己只提出一个请求，在一个繁忙的Kafka集群中创建15k个主题，在一个请求中，如下所示：final List<NewTopic> newTopicsOptional.empty(), Optional.empty()))final CreateTopicsResult ctr = admin.createTopics(newTopics不幸的是，由于
浏览 6提问于2022-06-22得票数 0
1回答
我正在开发一个使用高速公路的web应用程序，并希望利用最新的技术和体系结构，即kafka，microservices等--前端是响应的，并且正在调用后端微服务来检索数据。我当前的体系结构，由多个服务组成，作为后端的rest端点，如用户服务、帐户服务、公司服务等。所有这些服务都工作得很好，但是必须将kafka引入到混合中，当客户端为帐户->注册用户服务发布该事件时，我<
浏览 0提问于2021-02-16得票数 0
回答已采纳
以下是我迄今为止在Server上成功完成的工作
spring-cloud-dataflow-server-local-1.3.0.RELEASE.jar --spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream.kafka.b
浏览 2提问于2018-02-12得票数 0
回答已采纳
我有一个spring boot应用程序。我希望实现一个从Kafka主题消费的函数，对于每个消费的消息，它调用另一个方法对消息进行一些处理，然后将其存储在数据库中。源kafka主题有12个分区。我想在同一个消费群体下创建6到12个kafka消费者。所有的消费者都将消费来自Kafka的消息并调用该函数。我不能得到一个好的设计。有人能帮帮我吗？
浏览 1提问于2020-02-19得票数 1
为了表明我的意思我做了一个简单的项目。>这都是kafka代码中的配置：public class KafkaSerializationConfig implements SmartInitializingSingleton让我们想象一下，我们有两个服务:服务器和客户机。我的对象映射器不使用类型。我可以在我的控制台上看到它：
bin/<
浏览 6提问于2020-11-01得票数 1
回答已采纳
我遇到了一个问题与弹簧启动卡夫卡对接，尝试了所有提到的东西在下面的链接，但问题仍然存在。我在运行wrustmiester/kafka和wrustmiester/动物饲养员。如果我在本地运行spring引导应用程序，一切都会顺利运行。当我试图构建我的spring引导应用程序的映像并运行该映像时，就会出现这个问题。那么错误是代理可能是不可用的。spring:
浏览 2提问于2020-11-03得票数 4
我在服务器(12.255.123.789)中运行一个消费者服务。我的使用者属性是 spring.kafka.consumer.bootstrap-servers=XX.XXX.XXX.123:9092,XX.XXX.XXX.124:9092,XX.XXX.XXX.125spring.kafka.listener.concurrency: 6 我已经使用这个命令在kafka服务器(X
浏览 63提问于2020-09-21得票数 0
1回答
我正在创建一个与另一个服务对话的服务，以便识别要收听的kafka主题。kafka主题可能有不同的键和值类型。因此，我希望为每个配置(主题、键类型、值类型)动态创建不同的kafka使用者，其中配置仅在运行时已知。然而，在spring kafka中，我看不到动态传递所有这些参数的方法(至少我不知道)。我该怎么做呢？
浏览 41提问于2021-04-11得票数 0
0回答
我需要从配置文件中动态创建kafka流，配置文件包含源主题名称和每个流的配置。App需要有数十个kafka流，每个环境(例如stage、prod)的流都会有所不同。使用spring-kafka库可以做到这一点吗？使用spring-kafka也可以做到这一点吗？正如我所看到的，我们需要在代码中创建每个ka
浏览 21提问于2018-07-13得票数 2
回答已采纳
1回答
我有两个Kafka集群，它们是我从数据库中动态获取的I。我使用@KafkaListener来创建侦听器。现在，我想根据引导服务器属性(逗号分隔的值)在运行时创建多个Kafka侦听器，每个侦听器都侦听一个集群。你能建议我如何做到这一点吗？Spring-boot: 2.1.3. 2.1.3.RELEASE -2.0.1 Java-8
浏览 0提问于2019-03-23得票数 1
2回答
我已将我的生产者配置为：spring.cloud.stream.bindings.pc-abc-out=trueo.s.kafka.support.LoggingProducerListener - Exception thrown when sending错误消息中
浏览 8提问于2022-01-24得票数 2
回答已采纳
Spring Boot: 2.0.3版本 org.apache.kafka.kafka-streams: 1.0.0 Org.apache.kafka.kafka-客户端: 1.0.0 org.springframwork.kafka:spring-kafka-test:2.1.7.RELEASE 我有一个使用Kafka的Spring启动应用程序。我正在尝试使用https:
浏览 92提问于2019-04-30得票数 0
回答已采纳
我是apache kafka的新手，我正尝试在android studio上使用它，以便使用中的代码将数据生成到我pc上的服务器上apply plugin: 'com.android.application:kafka-clients:0.10.0.0'
这是
浏览 0提问于2019-09-03得票数 1
我刚接触apache camel和apache kafka，并为我的项目做了一个小POC。当我尝试使用Camel-kafka组件从kafka读取时，我得到了以下问题错误日志。(FetchResponse.scala:231) at kafka.network.Processor.run(SocketServer.scala:
浏览 0提问于2016-01-20得票数 0
我正在使用Springboot 2运行Kafka Stream应用程序。我想在host:8080/actuator/prometheus上以普罗米修斯格式提供我的卡夫卡数据流指标 我没办法拥有这个。我不确定我是否理解kafka流指标是如何导出的。actuator可以获得这些JMX指标吗？有没有办法获得这些指标并以普罗米修斯格式公开它们？ PS:也没有使用java jmx_prometheus_agent 有人有解决
浏览 46提问于2019-09-25得票数 7
3回答
在groovy脚本中，我可以将数组中的依赖项列表指定为"implementation libraries.frameworkLibs"，kotlin中是否存在类似的方法？目标是在数组中有一个依赖项列表，这样每个列表都可以在子项目中单独分配。', 'org.mybatis.spring</
浏览 15提问于2019-05-08得票数 0
回答已采纳
在我的项目中，我正在使用Spring 。我还没有开始使用功能流。我仍然在使用@StreamListener.使用数据，我还使用了批处理的数据。由于我以批处理的形式使用数据，所以必须给反序列化器。我有太多的输入主题，我必须创建新的反序列化类。
然而，有一点我注意到了。如果设置了JsonDeserializer，则不需要创建新的反序列化类，并且可以对任何数据使用spring.json.
浏览 9提问于2022-10-08得票数 2
回答已采纳
我理解Kafka集群可以有几个代理/节点/服务器。每个代理可以配置一个或多个主题。根据主题创建期间提供的分区，创建的主题可以位于一个或多个代理中。有任何方法可以告诉您应该在哪个代理/s中创建一个主题及其分区吗？
你好，洛凯什
浏览 1提问于2018-02-23得票数 4
我想通过java在Kafka (kafka_2.8.0-0.8.1.1)中创建一个主题。如果我在命令提示符中创建一个主题，如果我通过java推送消息，它就能正常工作。但是我想通过java创建一个主题。经过长时间的搜索，我发现了下面的代码，
ZkClient zkClient = new ZkClient("localhost:2181", 10000, 1000
浏览 14提问于2014-11-20得票数 46
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
