Установка Apache Kafka на Linux или Windows

 Шаги установки:

1. Установка Java:

   • Скачайте и установите JDK с официального сайта Oracle или OpenJDK.
   • Убедитесь, что переменная окружения JAVA_HOME настроена правильно, и команда java -version отображает установленную версию.

2. Скачивание Apache Kafka:

• Перейдите на официальный сайт Apache Kafka и скачайте последнюю стабильную версию.
• Распакуйте архив в удобное место на вашем компьютере.

3. Запуск ZooKeeper:

   • Ранее Kafka использовала ZooKeeper для управления кластером, но в последних версиях Kafka стремится избавиться от этой зависимости.
   • Тем не менее, для простоты установки можно использовать встроенный ZooKeeper.
   • Откройте терминал или командную строку и перейдите в директорию Kafka.
   • Запустите команду (Возможно потребуется прописать полный путь до папки config):

     bash
     bin/zookeeper-server-start.sh config/zookeeper.properties
     

     Для Windows:

     arduino
     bin\windows\zookeeper-server-start.bat config\zookeeper.properties
     

4. Запуск Kafka брокера:

   • В новом терминале перейдите в директорию Kafka.
   • Запустите команду:

     bash
     bin/kafka-server-start.sh config/server.properties
     

     Для Windows:

     arduino
     bin\windows\kafka-server-start.bat config\server.properties
     

5. Проверка установки:

   • Создайте тестовый топик:

     css
     bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
     

     Для Windows:

     css
     bin\windows\kafka-topics.bat --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
     

   • Запустите консюмер для прослушивания топика:

     css
     bin/kafka-console-consumer.sh --topic test-topic --bootstrap-server localhost:9092 --from-beginning
     

     Для Windows:

     css
     bin\windows\kafka-console-consumer.bat --topic test-topic --bootstrap-server localhost:9092 --from-beginning
     

   • В другом терминале отправьте сообщение в топик:

     css
     bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092
     

     Для Windows:

     css
     bin\windows\kafka-console-producer.bat --topic test-topic --bootstrap-server localhost:9092
     

     Введите сообщение и нажмите Enter. Оно должно отобразиться в консюмере.