в пакете tools с использованием таких конструкций:
@ExtendWith(value = ClusterTestExtensions.class)
...
@ClusterTest(clusterType = Type.ZK, brokers = 1)
Когда запускаю, в брокере оказывается топик __consumer_offsets с 5 партициями. Делаю его удаление и создание заново с нужным мне количеством партиций, но их всё равно 5, хотя если просто его удалить, он больше не появляется. Подскажите, пожалуйста, где это число устанавливается в таком окружении и как его можно обойти?
https://kafka.apache.org/documentation/#brokerconfigs_offsets.topic.segment.bytes
Обсуждают сегодня