Я пытаюсь написать потребителя, использующего Kafka-Python, обеспечивающего семантику ровно один...

Я читал о том, как Uber реализует логику повторов в Kafka: https://eng.uber

У меня есть 2 топологии кафкасторма, в которых топология кафки-производителя считывает данные из...

Вопрос: Как я могу случайно выбрать старый кусок сообщений с заданным диапазоном определения...

Первые N вызовов на опрос ничего не возвращают, когда я регистрирую потребителя с новым...

Я пытаюсь интегрировать MongoDB и Storm-Kafka, Kafka Producer производит данные из MongoDB, но не...

Я рассматриваю Kafka как одну из нескольких технологий, служащих в качестве посредника сообщений...

Как видно из названия, есть ли способ получить список потребителей по определенной теме в Java?До...

Мой коннектор приемника kafka читает из нескольких тем (настроенных на 10 задач) и обрабатывает...

Мой проект настроен с использованием Spring Boot и Spring Kafka, и есть три потребителя.Проверяя...

У меня есть приложение kafka-streams, в котором полезная нагрузка проходит через несколько тем,...

Мы работаем с 5-узловым кластером Flink (1.6.3) над kubernetes с источником раздела Kafka из 5...

Я новый человек на Apache Kafka.Когда я прохожу инструкции по быстрому запуску через http://kafka

Чтобы использовать данные из Kafka, у нас может быть несколько потребителей по теме, полностью...

У меня есть два кластера кафки.Мне нужно реализовать вид синхронизации между ними с помощью...

Я использую <dependency> <groupId>org.apache.kafka</groupId>...

Это код на Python для написания простого производителя / потребителя: import json import logging...

Как подключить производитель Kafka, работающий в другом регионе, в aws, и функцию лямбда,...

У меня есть настройка kakfa на экземпляре ec2.Я назначил эластичный IP-адрес этому экземпляру.Я...

Мы предлагаем арку, чтобы использовать kafka в качестве слоя для связи микросервисов с нашим...

Я пытаюсь подтвердить, что конфиг Kafka Consumer работает правильно.Я устанавливаю некоторые...

Я читал документацию по Альпакке. Читая пользовательский API Kafka, я наткнулся на...

Сначала все брокеры в кластере могут нормально запускаться и работать, но иногда один из брокеров...

Хотелось бы знать, если существует свойство для потребителя, когда сервер kafka недоступен, чтобы...

У меня был этот старый стек kafka в производстве с ubuntu 14 на версии 0.10.1.0 kafka ,, я только...