У меня есть проект весенней загрузки с использованием Kafka. Я настроил его с помощью автоматической настройки Spring Cloud Stream Kafka. Я хочу создавать свои темы автоматически с 3 репликами и сроком хранения 1 день. Для этого я добавил коэффициент репликации и retention.ms в свой application.yml, как показано ниже:
spring:
cloud:
stream:
kafka:
binder:
replicationFactor: 3
default:
consumer:
topic:
properties:
retention.ms: 86400000
producer:
topic:
properties:
retention.ms: 86400000
На самом деле у меня это работает нормально, темы создаются как 3 реплики с 1-дневным хранением, но когда я удаляю тему во время работы приложения, эта тема создается автоматически без реплик и хранения. Кто-нибудь знает причину этого? Что мне делать, чтобы создавать темы с 3 репликами и сроком хранения 1 день во время выполнения?
