У меня есть настройка Kubernetes на 3 узла. 3 брокера Kafka успешно работают на кластере. За...

Это встроенная функция производителя kafka для создания производителя. Какая польза от сообщения,...

Есть ли какая-либо полностью готовая к работе поддержка Kafka в экосистеме Spring Boot? Под...

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

У меня есть сценарий использования, когда мне нужно «объединить» несколько тем Kafka на основе...

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

Я пишу это потоковое приложение Kafka, которое принимает показания датчиков, которые регистрируются...

У меня есть тема customer_proposal и я создал поток из нее; CREATE STREAM s_customer_proposal (...

Я получаю события от Кафки, обогащаю / фильтрую / трансформирую их в Spark и затем сохраняю их в ES

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

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

Я настраиваю Kafka и попал в стену относительно одного потребителя, подписавшегося на несколько тем

Я пытаюсь построить конвейер больших данных в реальном времени с помощью Lambda-Architecture.До сих...

Требуемая функциональность: для данного ключа, key123, многочисленные службы работают параллельно и...

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

Я недавно начал работать над потоковым приложением Kafka с использованием ядра .NET. Я следовал за...

У меня есть простой кусок кода, который читает в файле JSON, используя fs.Я использую функцию...

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

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

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

Я импортирую БД, которая содержит некоторую таблицу ссылок, представляющую отношения «многие ко...

Я использую библиотеку C (librdkafka), чтобы написать потребителя Kafka. Мне нужно знать последнее...

Кафка стрим / Ksql на самом деле как-то изначально поддерживает json?Какие другие форматы...

Я пытался посчитать событие из KStream в период времени: KStream<String, VehicleEventTO>...

Я собираю данные с Packetbeat , Metricbeat и Filebeat и отправляю их на Logstash через Kafka а...