Я использую kafka_2.12 версия 2.3.0 , где я публикую данные в теме kafka, используя раздел и ключ....
Что означает кластер? В документе написано The Kafka cluster *stores* streams of records in...
У нас есть контейнер док-станции kafka следующим образом (в Linux redhat 7.5) Мы создали сервис...
Мы используем одноузловое базовое развертывание в Docker, которое включает следующие службы kafka...
Я бы хотел использовать kafka-console-producer.sh для запуска нескольких сообщений JSON с...
У меня работает раковина Kafka Connect. Я хотел бы контролировать отставание для этого. Я могу...
мы тестируем масштабирование в среде с 3 узлами kafka, каждый из которых имеет службу брокера и...
Привет, ребята, нам нужно иметь статус о KIP-500: замените ZooKeeper на Квадрат метаданных с...
У меня 4 потребителя, 3 из которых находятся на версии 0.10.0.0 kafka-клиента, но один перешел на...
Я не хочу подключаться к теме кафки с помощью SSL, используя smallrye-kafka в quarkus. Мой код...
После выдачи кафке в журнале происходит исключение Uncaught. Но успешно производим корм для кафки....
Я пишу для NodeJS Kafka производителя с KafkaJS и испытываю затруднения с пониманием, как получить...
Когда я использую кластер Kafka с 3 узлами и версию API Kafka = 1 Я получаю следующий код ошибки =...
Я получаю такие ошибки в журнале авторизации kafka: [2019-11-05 09:19:27,050] INFO Principal =...
Мы начинаем новый проект, где мы оцениваем технологический стек для асинхронной связи между...
Прежде чем задать свой вопрос, я хотел бы отметить, что подобный вопрос был задан здесь , но на...
У меня настроен исходный соединитель, который извлекается из DB2 и использует режим отметки времени
Я пытаюсь опубликовать некоторые сообщения вместе с несколькими пользовательскими заголовками для...
Я добавил JDBC Source Connector, используя Kafka Connect, который извлекает данные из таблицы MySQL
Я создаю сообщение json и пытаюсь сделать его совместимым с avro. Вот пример сообщения, которое я...
Я хочу передать значение от издателя WSO2 к подписчику, где, как если значение жестко задано для...
Я использую FlinkKafkaConsumer, чтобы использовать kafka и включить контрольную точку. Теперь я...
В качестве требования в моем проекте использовать одну запись за раз и обрабатывать каждую запись...
«Квадратные скобки» отсутствуют в данных JSON, когда я пытаюсь отправить из программы COBOL на...
У нас есть 3-узловое кластерное развертывание Kafka с 5 темами и 6 разделами на тему. мы настроили...