Ребят, добрый день! Новичек в работе с кафкой, поэтому нужна помощь) Есть

такой конфиг докера
version: '3.7'
networks:
analytic:
driver: bridge
services:
zookeeper:
image: bitnami/zookeeper:3.6.2
env_file: zookeeper/.env
networks:
- analytic
ports:
- 2181:2181
kafka:
image: bitnami/kafka:2.6.0
ports:
- 9092:9092
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
ALLOW_PLAINTEXT_LISTENER: 1
depends_on:
- zookeeper
networks:
- analytic

При попытке отправить сообщение ничего не выходит
kafkacat -L -b 127.0.0.1:9092
Metadata for all topics (from broker -1: 127.0.0.1:9092/bootstrap):
1 brokers:
broker 1010 at bcd7d80f3442:9092 (controller)
2 topics:
topic "events" with 1 partitions:
partition 0, leader -1, replicas: 1005, isrs: 1005, Broker: Leader not available
topic "__consumer_offsets" with 50 partitions:
partition 0, leader -1, replicas: 1001, isrs: 1001, Broker: Leader not available
....


echo '{"action": "read","event": "sdfsdf","service_name": "profile","session": "c3f94c52-6e05-4cfd-b974-14850a1335ba","user": "254c966d-f361-4f38-862d-4ee9717d8224"}' | kafkacat -P -b 127.0.0.1:9092 -t events

Что я делаю не так ?)

1 ответов

11 просмотров

А чего бы не взять нормальный рабочий композ из любого Кафка туториала? https://kafka-tutorials.confluent.io/kafka-console-consumer-producer-basics/kafka.html#get-confluent-platform

Похожие вопросы

Обсуждают сегодня

Привет, коллеги! Возникла задача ограничить максимальный размер вложений для определённых расширений, например, чтобы для изображений лимит был 10 МБ, а для видео — 100 МБ. Ог...
Andro
1
Всем здравствуйте, Я использую LibUsbDotNet, пытаясь написать библиотека (под linux/Mac OS) для взаимодействия с usb-устройством, который отправляет текст на дисплей покупат...
Асылбек Анарбай
2
Народ, есть у кого идеи или примеры как привязать softDelete трейт к модели файла или были случаи пропажи фоток? На проекте рандомным образом, со слов клиента, пропали фотки у...
XAKFULL XAKEROVICH
3
Это переведённый текст с английского. Я не говорю на русском, но могу использовать переводчик Телеграм. Приветствую! Я начинающий веб-разработчик и все еще учусь. В настояще...
𐩱𐩪𐩣𐩱𐩲𐩺𐩡
3
Ребята, всем привет. Подскажите, пожалуйста, можно ли как-то через бота понять, что этого бота добавили в группу\канал и выдали ему права администратора?
Artem Stormageddon
9
А не хотим ли мы развлечься? 😉 Но так чтобы с пользой для наших профессиональных навыков?? 👨‍🎓👩‍🎓 Предлагаю на октябрь запланировать тестовый запуск новой командной игры "Игр...
Andrii Kurdiumov
2
Парни, в 3 версии октября кто сталкивался с тем что System\Models\SettingModel не сохраняет данные настроек в админке?
Эд
5
или как тут карму плюсануть?
XAKFULL XAKEROVICH
3
ребят, кто использовал telegraph для создания ботов? если ли там функция отложенного постинга как в самом тг? то есть просто запланировать сообщение вместо его отправки
Dororo Steeeve
1
всем привет. кто то использовал https://octobercms.com/plugin/inherent-campus ?
Юрий Татаркин
2
Карта сайта