Kafka: створити вручну Kafka Topic для Strimzi Kafka Operator

У випадку, якщо у Вас відключено автоматичне створення топіків, можна створити необхідний топік за допомогою утіліти kafka-topics.sh

Так як ми використовуємо Strimzi Operator для Kafka, то спочатку, потрібіно зайти на pod з брокером:

kubectl exec -ti -n kafka kafka-0 -- bash

Далі виконуємо наступну команду:

./bin/kafka-topics.sh --create --topic <TOPIC_NAME> --bootstrap-server <KAFKA_BROKER>:9092 --replication-factor 5 --config segment.ms=604800000 --config cleanup.policy=compact --if-not-exists

де:

<TOPIC_NAME> – імʼя нашого топіку

<KAFKA_BROKER> – ендпоінт брокеру

Інші параметри вказуємо самі, такі як конфігурація для топіку, кількість реплік