У нас есть Oracle Source, оттуда нужно получить данные, с ошибкой в формате Avro и Json. Файл...
Я пишу производителя kafka в NodeJS, используя библиотеку kafkaJS. Ниже приведен мой пример кода....
Я хочу установить Flink на кластере Mesos для управления ресурсами. Фактически у меня был кластер...
это мой logstash conf input { kafka { bootstrap_servers => "127.0.0.1:9092" topics...
В моем текущем проекте я использую SSL-соединение для Kafka, и ниже указаны мои текущие настройки...
У меня есть метрические данные из collectD, постоянно записываемые в тему Kafka в формате json. Я...
У меня есть автономный брокер kafka, для которого я пытаюсь настроить SASL. Конфигурации ниже. Я...
Как объединить неравное количество потоков, содержащих разделы в KSQL, кроме увеличения раздела?...
Пытается понять потребительскую группу Behavioral в Кафке. Пример 4 разделов доступны. В...
Я пытаюсь установить Multi-Broker System в Windows на одном узле. Я успешно установил систему...
Я выполняю задания Gobblin как в кластерах AWS EMR, так и на серверах EC2. Рабочие места Гобблина...
Есть ли недостатки при использовании одного и того же кода производителя и потребителя для всех...
Когда я пытаюсь создать соединитель kafka с именем, которое уже используется через rest rest, я...
Я узнал о Event Sourcing and CQRS и нашел хороший сериал на Youtube. Серия имеет хранилище кодов,...
Я пытаюсь настроить метрики kafka на стекдрайвере. Я выполнил все шаги, упомянутые в https://cloud
У меня Kafka v1.0.1 работает на одном узле, и я могу отправить сообщения в тему, но каким-то...
У меня проблема с окружающей средой. Я хочу использовать zookeeper и Kafka для решения моей...
Я хочу создать тему, используя Java. Вот мои коды. String s = "--topic pt8 --create...
Я использую Кафку 0.11.0.3 У меня есть брокер Kafka и удаленный кластер Zookeeper. Я запускаю...
Необходимо написать приложение Kafka на Java, которое читает сообщение JSON, например:...
Работая над созданием новой темы Кафки для некоторой информации, которой вы можете поделиться, не...
Я только изменил пути к журналам и данным zookeeper в конфигах. Запуск зоопарка:...
Я исследую Kafka, чтобы оценить его пригодность для нашего варианта использования. Не могли бы вы...
Каковы возможные варианты того, что данные Kafka из тем могут быть переданы, использованы и...
Я установил kafka и определил имя пользователя и пароль как протокол SASL_PLAINTEXT, я сделал...