У меня есть пример потокового WordCount примера, написанного на Flink (Scala). В нем я хочу...
Я тестировал потоковое приложение Kafka. Возможно, что в какой-то момент приложение могло нечисто...
Я использую Ambari для управления моим кластером Kafka. Я хочу создать другой кластер, который...
Я пытаюсь написать потребителя, использующего Kafka-Python, обеспечивающего семантику ровно один...
В соответствии с моим требованием к аналитике в реальном времени, я должен вставить 10 миллионов...
Я хочу написать модульный тест для Kafka Appender, используя log4j2 xml. Я использую встроенный...
Я новичок в Nifi и в моем случае должен использовать тему JSON от Kafka и хотел бы преобразовать...
Из официальной документации Kafka https://kafka.apache.org/documentation/#gettingStarted есть...
Я использую тему kafka, используя kafka connect для загрузки данных в splunk.Я не хочу, чтобы...
Я хочу создать архитектуру CQRS и Event Sourcing , которая будет очень дешевой, очень гибкой и...
Я пишу приложение Spring Boot (2.1.4), пытающееся использовать Spring Cloud Streams для Kafka. Я...
Документация здесь https://docs.confluent.io/current/schema-registry/index.html упоминает о...
Исключение при запуске кода Python в Windows 10. Я использую Apache Kafka и PySpark. Фрагмент кода...
Я реализовал Logger Bolt в шторм, вход кортежа исходит от темы Кафки.Я использую Kafka Connect для...
Почему слитый репликатор реплицирует уже использованные сообщения? Существует много вариантов...
У меня есть существующий фреймворк, написанный на Java с Hadoop.Я буду отправлять файлы из системы...
В kafka есть пакетная тема (Json content), которую нужно использовать через NiFi(version 1.8).Я...
Если мы записали в данные темы Kafka с помощью SourceTask, в котором мы определили схему для...
Брокеры Kafka были перезапущены, и в результате приложение производителя потерпело крах.Сообщения...
Я пытаюсь сделать это руководство потребителя kafka для сервера объекта области: https://realm
Могу ли я удалить элемент из моей схемы AVRO, смотрите перечисление ниже, могу ли я удалить его
У нас работает коннектор приемника kafka hdfs (версия 5.2.1), и необходимо, чтобы данные HDFS были...
Изменения потока от Postgres с использованием дебезия настройка, которая сделана: Настройка Docker....
Я создал схему данных для druid. Затем я включил использование druid kafka с помощью этой команды...
Постановка задачи: Мы получим запросы на обработку элемента, принадлежащего к любым группам,...