@jedidiah.brown
Чтобы создать топик в Kafka, Вам необходимо выполнить следующие шаги:
@jedidiah.brown
Дополнительно, вы можете задать другой replication-factor и количество partitions.
Replication-factor определяет, сколько копий каждой партиции будет создано в кластере Kafka. Рекомендуется иметь несколько копий, чтобы обеспечить отказоустойчивость и возможность восстановления. Partitions определяет, на сколько частей будет разделено ваше сообщение. Обычно устанавливают больше одной партиции, чтобы Kafka могла обрабатывать сообщения параллельно.
Пример команды создания топика с replication-factor 3 и 5 partitions:
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 5 --topic topic_name
После выполнения команды, топик будет создан и будет доступен для использования.