Там есть файл журнала, который доставляет сообщение из FluentD в Kafka (FluentD -> Kafka)....

Функция утилиты bash для очистки темы kafka путем манипуляции с интервалом retention выглядит...

У меня есть сценарий, в котором мне нужно использовать одного производителя (фондовую биржу),...

Я использую StreamSets в качестве инструмента для загрузки записей из базы данных Oracle в разделы...

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

В поисках лучшего подхода к проектированию моего потребителя Kafka.В основном, я хотел бы...

Недавно я обновил зеркало kafka, и теперь он не может подключиться к исходным серверам zk -...

Есть ли способ получить общее время запроса от kafka.network:type=RequestMetrics,name=TotalTimeMs...

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

Я бы хотел настроить тестовую среду для проекта Scala. Кроме того, мне нужно запустить Kafka,...

Я использую ladoop / fast-data-dev и использую PostgresConnector от Debezium.Я настроил соединитель...

Я установил экземпляр AWS EC2, работающий под управлением Apache Kafka 0.8 через образ Bitnami AMI

я использую модуль "kafka-node" для взаимодействия с сервером kafka и не могу найти способ добавить...

Предположим, что потребитель Kafka должен потреблять 5 сообщений, и они будут обработаны в классе A...

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

Я занимаюсь тестированием и имею только 300 сообщений в теме кафки. При попытке показать, что...

У меня есть агент Flume с морфлиновым перехватчиком, который читает из источника Kafka сообщения,...

Мы используем kafka stream api для агрегации, в которой мы также используем group by.Мы также...

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

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

У меня есть отношение к базе данных (Mariadb) со столбцом, «измененным» как «bigint (10)», который...

Я получаю сообщение об ошибке для распределенной конфигурации для приемника разъема Кассандра. Я...

Я использую Kafka версии 2.0 и API-интерфейс пользователя java для получения сообщений из темы. Мы...

Я тестирую kafka на компьютере с Windows 10, zookeeper (v3.4.11) и kafka (v2.12-2.2.0). Я создал...

У меня есть кластер Kafka с 3 брокерами и 3 зоопарками. Основываясь на файле Kafka server.log, он...