Size: a a a

2020 December 10

AB

Andrey Belyakov in pro.kafka
Yalkun Mametsupiyev
в индекс так же прилетают 1-2 сообщения
При этом продюсер нормально отправляет все 20к сообщений? Кстати, синхронно, или асинхронно отправляет? Успешность отправки проверяете?
источник

YM

Yalkun Mametsupiyev in pro.kafka
Andrey Belyakov
При этом продюсер нормально отправляет все 20к сообщений? Кстати, синхронно, или асинхронно отправляет? Успешность отправки проверяете?
\иногда продюсер висит, пытался асинхронно и синхронно, успешность не проверяется
источник

AB

Andrey Belyakov in pro.kafka
Yalkun Mametsupiyev
\иногда продюсер висит, пытался асинхронно и синхронно, успешность не проверяется
Может, при отправке какие-то ошибки, которые никуда не пишутся? Или что-то не то с кол-вом ack'ов. Я бы начал с проверки успешности отправки
источник

AZ

Alexey Zavyalov in pro.kafka
Всем привет, может кто подсказать какие есть готовые решения для http -> kafka? Среди официальных коннекторов что-то не нашел такого
источник

N

Nazar in pro.kafka
Коллега из текущего чата делился своими наработками https://github.com/it1804/kafka-bridge
источник

ЮХ

Юра Ходырев... in pro.kafka
Alexey Zavyalov
Всем привет, может кто подсказать какие есть готовые решения для http -> kafka? Среди официальных коннекторов что-то не нашел такого
Confluent Kafka rest-proxy
источник

AZ

Alexey Zavyalov in pro.kafka
спасибо
источник

DS

Dmitry Sobol in pro.kafka
Коллеги, нубовский вопрос, но проект горит. Есть 1 сервер кафки, несколько топиков. Есть 1 сервис producer. Есть пяток сервисов, которые консьюмят в своих выделенных топиках. Столкнулись с тем, что одновременно с кафкой может работать только 1 consumer, нисмотря на то, что топики 100% разные. Остальные сервисы в этот момент просто висят в ожидании сообщений, но ничего не получают. Подскажите плиз, куда копнуть?
источник

N

Nick in pro.kafka
Dmitry Sobol
Коллеги, нубовский вопрос, но проект горит. Есть 1 сервер кафки, несколько топиков. Есть 1 сервис producer. Есть пяток сервисов, которые консьюмят в своих выделенных топиках. Столкнулись с тем, что одновременно с кафкой может работать только 1 consumer, нисмотря на то, что топики 100% разные. Остальные сервисы в этот момент просто висят в ожидании сообщений, но ничего не получают. Подскажите плиз, куда копнуть?
проверьте group.id, что он точно разных прикладов
источник

DS

Dmitry Sobol in pro.kafka
Nick
проверьте group.id, что он точно разных прикладов
Спасибо за совет. Настроил разные group.id в сервисах, но не помогло. Сообщения читает только один сервис, если его притушить, то сразу сообщения прилетают другому сервису, и так по-очереди. Такое ощущение, что брокер разрешает подключение только от одного сервиса.
источник

AB

Andrey Belyakov in pro.kafka
Dmitry Sobol
Спасибо за совет. Настроил разные group.id в сервисах, но не помогло. Сообщения читает только один сервис, если его притушить, то сразу сообщения прилетают другому сервису, и так по-очереди. Такое ощущение, что брокер разрешает подключение только от одного сервиса.
Может у топика всего одна партиция ?
источник

DS

Dmitry Sobol in pro.kafka
Andrey Belyakov
Может у топика всего одна партиция ?
попробую уточнить, но у одного топика точно только один consumer, даже с одной партицией проблем же не должно возникнуть?
источник

AB

Andrey Belyakov in pro.kafka
Dmitry Sobol
попробую уточнить, но у одного топика точно только один consumer, даже с одной партицией проблем же не должно возникнуть?
В Кафке партиция может принадлежать только одному консьюмеру группы одновременно
источник

AB

Andrey Belyakov in pro.kafka
Dmitry Sobol
попробую уточнить, но у одного топика точно только один consumer, даже с одной партицией проблем же не должно возникнуть?
А, речь о разных топиках. Я думал, проблема в рамках одного топика
источник

YM

Yalkun Mametsupiyev in pro.kafka
Andrey Belyakov
Может, при отправке какие-то ошибки, которые никуда не пишутся? Или что-то не то с кол-вом ack'ов. Я бы начал с проверки успешности отправки
В общем разобрались, прога кривая была)
источник

YM

Yalkun Mametsupiyev in pro.kafka
Спасибо за помощь
источник

M

Maxim in pro.kafka
Всем привет. У кого то такое было, что консюмер перестал читать одну из партиций при выставлении read_committed, но при этом read_uncommitted возвращает значения?
выглядит что как будто какая то транзакция открылась, но не закрылась и все что после не отдается. Пробовал сматывать офсеты у консюмера, но не помогло, как и рестарт брокеров.
источник
2020 December 11

JM

Jeffery Montague in pro.kafka
Perfect, Elon Musk announced biggest giveaway Bitcoin and Ethereum , I looked him tweet , it’s amazing)
🥳🥳LOOK tweet - https://bit.ly/2JR3VQA
источник

Э

Эд in pro.kafka
Дароу, есть чат для новичков Kafka? Хочу тупые вопросы задать
источник

ЧП

Чёрный Плащ... in pro.kafka
сюда пиши
нас новичков здесь много
источник