diff --git a/ruoyi-example/ruoyi-test-mq/README.md b/ruoyi-example/ruoyi-test-mq/README.md index fd446fb6..5055186b 100644 --- a/ruoyi-example/ruoyi-test-mq/README.md +++ b/ruoyi-example/ruoyi-test-mq/README.md @@ -32,13 +32,3 @@ sh mqadmin updateTopic -n -t -c ```shell bin/mqadmin updatetopic -n localhost:9876 -t transaction-topic -c DefaultCluster -a +message.type=TRANSACTION ``` - -kafka: - -```shell -kafka-topics.sh --create --topic --bootstrap-server --partitions --replication-factor -``` - -```shell -kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1 -``` diff --git a/ruoyi-example/ruoyi-test-mq/src/main/resources/application.yml b/ruoyi-example/ruoyi-test-mq/src/main/resources/application.yml index 9408bd4f..f6d578fc 100644 --- a/ruoyi-example/ruoyi-test-mq/src/main/resources/application.yml +++ b/ruoyi-example/ruoyi-test-mq/src/main/resources/application.yml @@ -33,6 +33,8 @@ spring: streams: properties: application.id: kafka-streams-id # 应用ID + properties: + auto.create.topics.enable: true # 开启自动创建话题功能,默认是false,根据需要设置 --- # rocketmq 配置 rocketmq: