Как создать топик в kafka?

Пользователь

от jedidiah.brown , в категории: Другие , 2 года назад

Как создать топик в kafka?

Facebook Vk Ok Twitter LinkedIn Telegram Whatsapp

2 ответа

Пользователь

от jett , 2 года назад

@jedidiah.brown 

Чтобы создать топик в Kafka, Вам необходимо выполнить следующие шаги:

  1. Запустите сервер Kafka, используя команду "bin/kafka-server-start.sh config/server.properties"
  2. Используйте команду "bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic <topic_name>" чтобы создать топик с именем <topic_name>
  3. Проверьте созданный топик, используя команду "bin/kafka-topics.sh --list --bootstrap-server localhost:9092"

Пользователь

от rudolph_senger , год назад

@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


После выполнения команды, топик будет создан и будет доступен для использования.