Я использую Kafka v2.2, сейчас я подключаюсь к Consumer с моего сервера aiohttp, используя...

У нас был сбой брокера Kafka (слишком много открытых файлов, глупо), и теперь разделы на этом...

Я пытаюсь запустить команду python на сервере Ubuntu с помощью команды ($ python3 es7.py). Но...

Я получаю предупреждение ksql ПРЕДУПРЕЖДЕНИЕ: время окончания окна было усечено до Long.MAX в...

У меня есть потребительский метод kafka, аннотированный @kafkalistener. Я установил шаблон...

Я пытаюсь отправить данные ( input_data ) в python, который выглядит примерно так, как показано...

У меня запущена настройка Kafka с соединителем Elasticsearch, и я успешно индексирую новые...

У меня есть проект, который запускает очень простой kafka-потребитель. Все работает отлично и...

Я пытаюсь создать CEP-код с использованием flink SQL, я хотел бы начать с этого. Было бы здорово,...

Уже есть тема кафки с именем: x.y.z Можно ли создать новую тему с именем x.y? Пожалуйста, помогите

У меня есть приложение kafka, которое использует тему и пишет в другую тему. Регистрация ведется с...

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

Мы используем kafka connect в HDP 2.6.4, сливной соединитель и реестр схем hortonwork. kafka...

В моем mongodb есть эти данные mongo01:PRIMARY> db.col.find({"_id" :...

У меня есть тема с 32 разделами, в которой все они содержат данные. Но когда я начинаю использовать...

У меня есть шина kafka, которая получает данные с датчиков iot. Количество сообщений, получаемых в...

В моей машине работает потребитель. Когда я останавливаю брокера Kafka, я получаю предупреждение в...

Я следую инструкциям в этом руководстве. Snowflake Connector для Kafka Получаемое сообщение об...

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

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

Цель: Подсчитать все успехи и неудачи производителя Kafka при отправке async . Проблема: Иногда...

Kafka предоставляет полезный инструмент командной строки kafka.tools.GetOffsetShell, но мне нужна...

Во-первых, обратите внимание, что использование потребительского API java не вариант. Почему это не...

У меня есть два источника данных для моих журналов. Один - это ритм, а другой - Кафка, и я хочу...

Мне нужно написать потребителя kafka на Python, чтобы получить данные, произведенные Java Produced....