Kafka. Установка на Ubuntu 22 - nagaevkirill/WIKI GitHub Wiki

www.digitalocean.com/community/tutorials/how-to-install-apache-kafka-on-ubuntu-20-04

ОБЯЗАТЕЛЬНО надо изменить пути к логам и файлу настроек zookeeper с /tmp на пользовательские kafka, чтобы при каждой перезагрузке сервера не терять логи и не было проблем с zookeeper-ом, он не видит свои настройки и генерирует новый ClusterID и поэтому после старта не может запустить старый кафка кластер

• в настройках server.properties путь к логам

• в настройках zookeeper.properties путь dirData (подробнее тут stackoverflow.com/questions/59481878/unable-to-start-kafka-with-zookeeper-kafka-common-inconsistentclusteridexceptio)

Проверка работоспособности ТУТ (в digital ocean она устаревшая) kafka.apache.org/quickstart

• CREATE A TOPIC TO STORE YOUR EVENTS

$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

• WRITE SOME EVENTS INTO THE TOPIC

$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

• READ THE EVENTS

$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

Далее забрать права у пользователя kafka и ограничить логин под ним, смотреть Шаг 6 на digital ocean

ВАЖНО! Чтобы заработала возможность подключаться извне, надо в server.properties раскомментить и отредактировать advertised.listeners=PLAINTEXT://82.146.**.223:9092