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

В моей теме кафки всего 10 записей / сообщений и 2 раздела по 5 сообщений в каждой. В моей группе...

Мне любопытно, как вы должны выразить, что хотите, чтобы сообщение было доставлено в тему Кафки в...

Я создал два очень простых веб-компонента. У обоих есть слушатель службы SSE, встроенной в ServerJ....

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

У нас есть кластер Kafka со следующими сведениями 3 машины kafka 3 сервера zookeeper У нас также...

у нас есть кластер hadoop с 3 кафками машин и 3 zookeeper серверами версия hadoop - 2.6.4...

При чтении документации по этому разъему об этой характеристике нет упоминания. Итак, этот...

Я использую конфликтующий клиент C # для соединения с Kafka и пытаюсь создать API, который мог бы...

Я пытаюсь интегрировать базу данных Ingres с Kafka.Что я ищу, так это, как только запись будет...

Используя Kafka, я пытаюсь передать данные из твиттера в Java, но когда я запускаю программу, я...

Есть ли способ, как Кафка может рассчитывать на одного потребителя с несколькими темами? Вот мой...

мы увидели, что ReplicationFactor: 1 вместо ReplicationFactor: 3...

Я пишу Java API для создания kafka продюсер У меня ошибка: Исключение в потоке "main" java.lang

2 производители создают сообщения подобного типа в однораздельной теме. Сообщения похожи по размеру...

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

Вот файл yml, который используется для вызова докер-контейнеров в экземпляре AWS для kafka и...

У меня есть сценарий использования для создания централизованного инструмента агрегирования...

Я изучаю способы разработки сканера в масштабе Google и, следовательно, изучаю возможное решение с...

У меня есть класс продюсеров Кафки, который отлично работает. Производитель заполняет тему Кафки....

Я создаю новое приложение, в состав которого входит Apache Kafka. Внешний интерфейс Я планирую...

Я читал, что Kafka многое добавил для поддержки семантики "точно один раз".Такие вещи, как...

Я пытался удалить сообщения из моей темы kafka, используя метод удаления записей API администратора...

Я создал соединитель REST для отправки ответа службы NodeJS на Kafka, но теперь я хочу написать или...

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