У меня есть 3 источника данных, которые предоставляют API для доступа к ним, каждый из них...
Вариант использования: 8 серверов по 300 php-fpm параллельных дочерних процессов каждый, создает...
В соответствии с моим требованием к аналитике в реальном времени, я должен вставить 10 миллионов...
Я пытаюсь отправить файлы csv в тему Kafka с помощью AvroProducer.s Я читаю файл csv и циклически...
Брокеры Kafka были перезапущены, и в результате приложение производителя потерпело крах.Сообщения...
Я читал о том, как Uber реализует логику повторов в Kafka: https://eng.uber
Я использовал kafka продуцента, версия которого 0.8.2.1, для записи брокеру kafka, версия 1.0.1...
У меня есть два кластера кафки.Мне нужно реализовать вид синхронизации между ними с помощью...
Это код на Python для написания простого производителя / потребителя: import json import logging...
У меня есть настройка kakfa на экземпляре ec2.Я назначил эластичный IP-адрес этому экземпляру.Я...
Я установил Apache Kafka на свой сервер Centos.Я просто пытаюсь написать сообщение в тему на другом...
Я хотел передать количество потоков, которые будут отправлять сообщение брокеру Kafka в качестве...
У нас есть бизнес-процесс / рабочий процесс, который запускается при получении исходного сообщения...
Я работаю с Kafka Consumer и замечаю, что он потребляет сообщения, которые должны были быть...
У меня есть файл размером 493 мегабайта, который я хочу отправить для отправки журналов от...
Я хочу транслировать сообщения журнала моего приложения на kafka с помощью log4j kafka appender....
Мне нужно отправить два события на кафку. Я могу нажать одно. Я получаю Арифметическое Исключение,...
Я понимаю, что если Acks = all и min ISR установлены на> = 2, это уменьшает вероятность потери...
Как зафиксировать транзакции Kafka и сохранить порядок транзакций? У меня есть транснациональная...
У меня есть случай использования, когда данное сообщение, которое генерируется внешним клиентом,...
Я использую Scala для публикации сообщений в Kafka. У меня есть список сообщений для публикации на...
У меня есть набор файлов в HDFS, эти файлы твиты. Мне нужно транслировать эти твиты через...
Я пытаюсь разработать приложение на основе IoT, в котором несколько устройств будут генерировать...
Я пытаюсь создать простого продюсера, который создает тему с некоторыми разделами, предоставленными...
Spring Cloud Stream Kafka с включенной транзакцией и динамическим пунктом назначения.У меня есть...