当前位置: 首页 > 知识库问答 >
问题:

如何配置Spring Cloud Stream(Kafka)应用程序来自动创建融合云中的主题?

缑永年
2023-03-14

有没有办法允许(Spring Cloud Stream)应用程序在融合云中自动创建所需的主题?

到目前为止,我不得不手动创建它们,当您考虑还必须设置变更日志主题时,这很容易出错。

共有1个答案

牧宁
2023-03-14

默认情况下,“活页夹”属性“自动创建主题”为true。因此,应该自动创建主题(除非代理权限不允许,但我希望在这种情况下会在日志中看到错误)。

还有另一个属性autoAdd分区默认为false。

 类似资料:
  • 您的帮助应该是值得赞赏的,如果需要,我将提供代码示例。

  • 我用< code>Python和< code>Django开发了一个web应用程序,需要每天备份数据。目前,< code>Postgres被用作DBMS。 为了执行备份,我发现了<code>django dbbackup</code>模块,但要使用它,我需要运行命令<code>python manage。py dbbackup。 如何在每天的特定时间自动备份?

  • 其中一个Kafka流应用程序在Kafka代理和消费者端产生了大量未知生产者ID错误。 流配置如下: 消费者方面的错误: 这背后的原因是什么?

  • 问题内容: 我需要在创建过程中配置特定主题的保留策略。我试图寻找解决方案,我只能找到如下所示的命令级别alter命令 ./bin/kafka-topics.sh –zookeeper本地主机:2181-更改–topic我的主题–config保留.ms = 1680000 有人可以让我知道一种在创建过程中进行配置的方法,例如spring-mvc中的xml或属性文件配置。 问题答案: Spring K

  • 我们正在使用关系数据库开发很多“传统”web应用程序。它们都是内部软件,为有限的用户提供服务。现在,我们正在构建一个web应用程序,并将其作为云(如SaaS)进行业务。然而,我们在云计算方面没有经验。我们非常感谢所有建议,以便我们可以开始挖掘,因为目前我们不知道从哪里挖掘:) 我们的web应用程序摘要:我们有两个主要部分 第1部分: 对于授权用户 第2部分: 对于公共用户 一种CMS,授权用户创建

  • 问题内容: 有没有人对Python / SQLAlchemy应用进行性能分析?找到瓶颈和设计缺陷的最佳方法是什么? 我们有一个Python应用程序,其中数据库层由SQLAlchemy处理。该应用程序使用批处理设计,因此许多数据库请求是在有限的时间内顺序执行的。当前运行时间太长,因此需要一些优化。我们不使用ORM功能,数据库是PostgreSQL。 问题答案: 有时,仅是普通的SQL日志记录(通过p