Если нужно с GUI, то Offset explorer (ex. Kafka Tool), который бесплатен для персонального использования.

kafkacat

чем не устраивают стандартные kafka-console-consumer и kafka-console-producer?

этоже для консоль нидзя, не каждый умеет

Добрый день, ловлю в логах вот такой вывод: error sending fetch request org.apache.kafka.common.errors.disconnectexception nullerror sending fetch request org.apache.kafka.common.errors.disconnectexception null с уровнем INFO, думаю что это не критично раз info, но возникает вопрос: можно ли эту проблему устранить или как избавиться от этого вывода, так как гадит весь лог

разбираться надо и удобство пользования. Лучше GUI.
Всем большое спасибо за наводки!

а они умеют работать с заголовками сообщений (headers)? Вроде из консольных только kafkacat научилась

А если надо полностью бесплатный gui - kafka.esque.at

Коллеги, подскажите, можно как-то просто в кафке дать доступ только на консумера или только на продьюсера?
По портам развести или еще как

Можно прикрутить авторизацию (хватит и SASL_PLAINTEXT) и по правам (ACL) разграничить доступ

Всем, привет! Хочу поделиться бесплатным опенсорс-продуктом от своей команды UI for Apache Kafka - простой веб-интерфейс для Apache Kafka. Он будет полезен всем, кто хочет удобно мониторить все свои кластеры из одной панели и поддерживать оптимальную производительность. Помогает разработчикам сократить время на обнаружение и дебаггинг проблем на любом уровне кластера, визуализируя данные.
Есть:
- Управление схемами данных - просмотр версий схем и реестра схемы
- Управление Kafka Connect - просмотр данных о статусе выполнения задач
- Мониторинг Consumer Groups - читают ли группы из Кафки вовремя, если с лагами - какой инстанс отстает, на сколько сообщений, из какой партиции читает  

Пожалуйста, ставьте и пробуйте UI for Apache Kafka, пишите в Issues и присоединитесь в качестве контрибьютора.
Будем рады ответить на любые вопросы. Увидимся в репе!
https://github.com/provectus/kafka-ui/issues

Это внешним тулом подключается?

Нет, просто включаешь режим SASL_PLAINTEXT (или любой другой) на брокерах Kafka (придётся чуток поморочится). Отдаёшь приложению креды, предварительно на брокерах прописав этому пользователю права в ACL. Про то как это настроить у Confluent хорошая документация: https://docs.confluent.io/3.0.0/kafka/sasl.html

Класс, спасибо!

Пожалуйста)

🤔интересно, спс

А отправку сообщений будет?

Да, это уже мы пилим. Скоро выкатим)

Реквестирую отправку proto сообщений 🙂

Да, Avro, Proto, JSON и примитивы