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

Я пытаюсь создать панель мониторинга в реальном времени в kibana для мониторинга тестов jmeter без...

У меня есть приложение kafka streams (Kafka v1.1.0) с несколькими (24) темами.Четыре из этих тем...

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

Я пытаюсь понять поведение RocksDB в API процессора потоков Кафки. Я настраиваю постоянный...

Мой код в настоящее время использует InMemoryKeyValueStore, что позволяет избежать сохранения на...

Я знаю, что мы можем интегрировать spark с kafka и записать кадр данных в формате ключа и значения...

В моем приложении почти все значения входящих записей обнуляются (засыпаны гробницей) в течение...

Я выполнял простую потоковую передачу Kafka-Spark с использованием Direct Stream, как это было...

Допустим, у меня есть A-Event KStream, агрегированный в A-Snapshot KTable, и B-Event KStream,...

Я хочу отправить данные Metribeat Кафке. И от кафки до Logstash. Вот мой metricbeat.yml. metricbeat

Я пытаюсь записать некоторые данные Avro в Kafka и использовать их в качестве смещения для чтения...

У меня есть следующий сценарий: Таблица A и таблица B объединены с помощью FK. Транзакционная...

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

У меня есть потребитель kafka, который выглядит следующим образом: import akka.actor.ActorSystem...

В настоящее время я использую драйвер Phoenix для HBASE, используя искру от Kafka Я пишу в соленый...

У меня 3 брокера, 3 раздела.Каждый брокер является лидером для одного раздела и ISR для всех

Я использую https://doc.akka.io/docs/alpakka-kafka/current/consumer.html для получения данных из...

Я хочу проверить значение позиции потока Кафки, если равное значение имеет, например, "2", затем...

Я хочу материализовать KTable из KStream и хочу, чтобы KeyValueStore сортировался по Key. Я...

Я использую пакет confluent_kafka для работы с Kafka. Я создаю тему таким образом: from...

Я пытаюсь использовать выходной плагин infxdb v-5.0.5 с logstash v-6.2.3.Я получаю синтаксический...

Я занимаюсь разработкой простого Java с потоковой передачей. Я настроил коннектор kafka jdbc...

Я использую Spring-Cloud-Starter-Stream-Kafka - 1.3.3 и Spring-Cloud-Stream с Spring Boot для...

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