Описание тега kafka-rest
Предоставляет интерфейс RESTful для кластера Kafka, поэтому вы можете создавать и использовать сообщения, а также выполнять административные действия через любой клиент REST.
1
ответ
JSONParseException - чтение данных с помощью API отдыха Kafka
ТЕМА КАФКА (test3) $ kafka-console-consumer --bootstrap-server broker:9092 --topic test3 --from-beginning "Can we write to a topic that does not exist?" "Can we write to a topic that does not exist?" {"foo":"bar"} ["foo","bar"] confluent confluent c…
31 дек '18 в 02:11
2
ответа
Ingest Streaming Data в Кафку через http
Я очень новичок в Kafka и Streaming Data в целом. То, что я пытаюсь сделать, - это принять данные, которые должны быть отправлены через http на kafka. Мои исследования привели меня к слиянию REST-прокси, но я не могу заставить его работать. В настоя…
14 янв '19 в 15:06
1
ответ
Вызывается: java.lang.ClassNotFoundException: io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor
Попытка опубликовать сообщение в теме kafka с помощью rest proxy на платформе Confluent с помощью этой команды и выдает сообщение об ошибке, как указано ниже Запрос: $ curl -X POST -H "Content-Type: application/vnd.kafka.avro.v2+json" \ -H "Accept: …
06 авг '18 в 07:51
1
ответ
Могу ли я отправить заголовок сообщения при использовании прокси-сервера kafka-rest?
Я хочу отправить заголовок сообщения для kafka сообщения, используя kafka-rest proxy api. https://docs.confluent.io/current/kafka-rest/docs/api.html Как я могу это сделать?
24 дек '18 в 10:51
0
ответов
Как настроить липкость балансировки нагрузки для Confluent Rest-Proxy
У меня есть настройка 3 экземпляров Rest-Proxy(Kafka-rest) в Kubernetes. https://docs.confluent.io/current/kafka-rest/docs/index.html https://github.com/confluentinc/kafka-rest Я добавил NetScaler Ingress поверх развертывания. В документах Citrix Ne…
07 янв '19 в 22:54
2
ответа
Кафка - как превратить сообщение сервиса Rest для включения в тему кафки?
Я новичок в сообществе кафки и сталкиваюсь со сложным вопросом. У меня есть два приложения, которые общаются друг с другом через веб-сервис Rest, а тело - это сообщение json. Как я могу использовать kafka, чтобы быть промежуточным ПО между этими дву…
25 янв '19 в 14:09
2
ответа
Как ограничить количество записей в Кафке-потребителе
Я использую слитный продукт Kafka-rest, чтобы использовать записи из темы. Мое намерение состоит в том, чтобы потреблять только первые 100 записей из темы. Я использую следующий API REST для получения записей GET /consumers/testgroup/instances/my_co…
03 дек '18 в 11:52
0
ответов
Установленный confluent-5.0.0 (OSS), сервис kafka-rest выходит из строя после некоторого простоя
Я установил confluent-5.0.0 (OSS) на Ubuntu VM. Все службы работают нормально. Но служба кафки-отдыха выходит из строя после некоторого простоя. Это должно работать вечно.
30 ноя '18 в 05:58
1
ответ
Публикация avro сериализованных данных с использованием прокси kafka-rest
Я пытаюсь опубликовать некоторые данные по теме kafka, для которой схема avro данных содержит типы объединения. Я использую прокси-компонент kafka-rest на Android для создания сообщений. Учитывая, что данные содержат тип объединения, кажется, что ни…
08 фев '19 в 11:27
2
ответа
Сбой соединения Zookeeper cp-rest-proxy с изображением spotify kafka
Я использовал образ kafka, предоставленный spotify, для локального запуска kafka. В настоящее время я пытаюсь использовать его с cp-kafka-rest а также schema-registry изображений. Мне нужна помощь в решении этой проблемы: ОШИБКА (Log Group: kafka_re…
28 дек '18 в 04:33
0
ответов
CORS проблема с Confluent кафка остальных прокси
Я сталкиваюсь с некоторой проблемой в моей собственной установке Kafka(слияния). Пожалуйста, найдите ниже вопрос Проблема CORS:- Ответ на запрос предварительной проверки не проходит проверку контроля доступа: На запрошенном ресурсе отсутствует загол…
26 ноя '18 в 13:43
1
ответ
Не удалось разрешить хост: rest-proxy, когда я добавляю нового потребителя avro
Зная, что мой kafka_cluster работает нормально, и я использую docker-compose, я помещаю его в контейнер: схема регистрации curl -X POST -H "Content-Type: application/vnd.kafka.v1+json" \ --data '{"name": "my_consumer_instance", "format": "avro", "au…
04 июл '18 в 16:47
1
ответ
Как мне отправить данные JSON на kafka, используя REST-прокси в Confluent?
Для моей диссертации бакалавра я пытаюсь отправить машинные данные (в данном случае исторические данные, отправленные с помощью сценария Python), используя http-соединение с kafka. Я использую платформу Confluent, работающую в Docker в системе Windo…
08 фев '19 в 10:54
1
ответ
Я пытался отправить данные из мобильных приложений (Android/IOS) в брокер kafka?
Я пытаюсь отправить данные мобильных приложений в брокер Кафки. Я прочитал много постов и блогов, узнал, что есть Rest Proxy, который может передавать данные по HTTP брокеру Kafak. Я следовал за https://docs.confluent.io/current/kafka-rest/docs/quic…
05 дек '18 в 12:11
0
ответов
Потеря сообщений при использовании Kafa Rest и Python
У меня есть приложение Python, которое запускает функцию, основанную на выражении cron. Функция должна получать сообщения из кластера Kafka по определенной теме, используя компонент Kafka Rest, обрабатывать само сообщение и возвращать. Я ожидал, что…
19 дек '18 в 15:39
0
ответов
Confluent-Kafka Ошибка "Не найден экземпляр получателя", даже если время ожидания экземпляра не истекло
Я наблюдаю, что экземпляр Потребителя не обнаружил ошибку во время регистрации потребителя, даже если для экземпляра потребителя не истекло время ожидания. Использование Confluent API. Ниже приведены шаги, предпринятые для этого негативного тестиров…
28 авг '18 в 09:23
0
ответов
Тестирование производительности Confluent Kafka-rest
Я развернул kafka-rest-proxy в vm openstack со следующими ресурсами и включил SSL между брокерами kafka-rest-proxy и kafka: 16vCPUs , 44GB RAM, 341GB harddisk, Kafka-rest-proxy работает просто отлично, я могу создать потребителя, подписаться на тему…
24 янв '19 в 12:31
1
ответ
Как запустить два экземпляра Кафки отдыха
Я пытаюсь запустить второй экземпляр для Kafka Rest. Вот файл свойств для первого: id=kafka-rest-test-server-1 schema.registry.url=http://localhost:8081,http://localhost:9081 zookeeper.connect=localhost:2181,localhost:2182,localhost:2183 bootstrap.s…
28 июн '18 в 06:57
1
ответ
Не удалось найти артефакт io.confluent:kafka-rest-parent:pom:5.4.0-SNAPSHOT и точки parent.relativePath в ни одной локальной точке
Я использую Maven 3 для запуска приложения, но получаю следующую ошибку: [ERROR] [ERROR] Some problems were encountered while processing the POMs: [FATAL] Non-resolvable parent POM for io.confluent:kafka-rest:[unknown-version]: Could not find artifa…
31 май '19 в 04:27
0
ответов
Как настроить почтовый веб-крючок из BitBucket в Kafka REST Proxy?
Я пытаюсь опубликовать данные (полезную нагрузку) из BitBucket на мой экземпляр Kafka в случае каких-либо событий BitBucket (например, Pushed, Forked, PR creating, Addition / Modification / Deletion пиар-комментарии и т. д.) Итак, я настроил rest-пр…
26 май '19 в 15:03