Мы работаем над приложением, в котором мы используем kafka. Компоненты приложения следующие: У нас...

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

У меня есть сценарий обработки сообщений kafka, где я получаю 3 типа загрузок: category_create...

Я хочу прочитать все сообщения, начиная с определенного времени в кафке. Скажем, я хочу прочитать...

В настоящее время я работаю с apache kafka и все еще учусь.Тем не менее, мы сталкиваемся с...

У меня есть приложение Java Spring Boot, развернутое в Google App Engine. Сначала я пытался связать...

Я пытаюсь создать конвейер в реальном времени от Kafka до HBase, используя Pyspark, используя блог:...

Я новичок в Кафке. Я только что настроил один автономный разъем Kafka, ссылаясь на шаги из слияния...

Кафка удалил параметр --num-threads из option of org.apache.kafka.tools.ProducerPerformance из...

У меня есть такой шаблон для тестирования некоторых сущностей @Component public class...

Я просто использовал rancher для развертывания кластера kubernetes и развернул kafka с помощью...

Моя тестовая зависимость связана с kafka, как показано ниже: | +--- org.apache.kafka:kafka_2.11:2.0

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

Использование Kafka / Java со следующей конфигурацией props.put(ConsumerConfig

Например, скажем, есть расхождение в offsets.retention.minutes, какой параметр вступает в силу, от...

Я могу создать сообщение для Кафки с маршрутизатора Camel, но не могу получить созданное сообщение....

Я заметил, что отставание потребителя кафки внезапно начинает увеличиваться после нескольких часов...

Какое рекомендуемое количество потребителей на группу в Кафке? По сути, у меня есть 400 тем,...

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

Установлено: kafka_2.11-2.1.0 and zookeeper-3.4.13 Пробег: bin/zookeeper-server-start.sh...

Как я могу перейти к следующей позиции смещения, игнорируя текущую позицию.В настоящее время я...

У меня есть следующая конфигурация docker-compose.yml для моего коннектора Debezium: version:...

У нас проблема с параллелизмом задач внутри одной топологии. Нам не удается получить хорошую,...

Я выполняю синхронизацию таблицы сервера sql с Snowflake. Я мог бы использовать kafka для этого и...

Я новичок в Apache Kafka.У меня есть несколько вопросов?если вы создаете тему с использованием...