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

Я пытаюсь подключиться к разъему Flink kafka 0.11, но он продолжает выдавать мне эту ошибку при...

Я использую kafka-продюсер и отправляю данные в тему 'test-topic', которая состоит из фактора...

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

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

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

Я уже некоторое время изучаю Apache Kafka. Давайте рассмотрим следующий пример. Предположим, у меня...

Я хочу использовать потребление Kafka в Nifi, чтобы использовать тему.Исходя из этого, я хочу взять...

У меня есть файл, содержащий данные в формате AVRO, которые необходимо опубликовать непосредственно...

Я пытаюсь понять, что хранит схема-реестр для каждой схемы.Куда мне обратиться или какой инструмент...

У меня есть сценарий использования "XML-файл ==> Тема Kafka ==> Построить REST API для запроса"...

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

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

Я установил Kafka 1.1.0 с Zookeeper 3.4.12 в подсистеме Windows для Linux на моем ноутбуке с...

У нас есть 3 узла кластера и 7 брокеров. Теперь мы должны создать тему и создать разделы для этой...

У меня есть 2 сервера, один из которых является сервером пользовательского интерфейса, а другой -...

Хотелось бы узнать сжатый размер сообщения в кафке. Я использую kafka 1.1.0 и java kafka-connect 1

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

Я получаю данные JSON из файла в мой файл JavaScript. Теперь я хочу отправить эти данные из этого...

Или, может быть, даже способ задержать сообщение, полученное потребителем. Мне нужно делать вызов...

Я использую vertx-kafka-client 3.5.1 и не могу найти способ создать KafkaProducerRecord с...

Я хочу создать сообщение в тему кафки. Это сообщение должно иметь следующий шаблон:...

У меня есть полезная нагрузка json, которую я хочу отправить в качестве заголовка в Api...

Amazon S3 можно использовать в качестве приемника в кластере Kafka. Я хочу проверить, можно ли...

В кластере Kafka, содержащем N брокеров, для Темы T относительно раздела производители публикуют...