2
ответа

Отправка списка производителю Kafka с использованием python

У меня есть несколько списков, которые я хочу отправить через продюсера Kafka. listA [1,2,3] listB ["cat", "dog", "fish"] производитель отправляет сообщения в байтах, поэтому я не уверен, как правильно настроить ...
вопрос задан: 19 March 2019 00:23
1
ответ

Кафка в режиме реального времени потоковое против микро сервисов

Существует ли минимальная скорость сообщения в Гбит / с, необходимая для выбора Кафки для потоковой передачи в реальном времени? Можем ли мы справиться с очень низким уровнем сообщений в Кафке?
вопрос задан: 1 April 2019 22:49
1
ответ

WSO2 SP - источник Кафки с атрибутами JSON

Я пытаюсь прочитать данные JSON из Kafka, используя следующий код: @source (type = 'kafka', bootstrap.servers = 'localhost: 9092', topic.list = 'TestTopic', group.id = 'test', threading.option = 'одиночный ....
вопрос задан: 27 March 2019 12:20
1
ответ

API производителя Kafka - onCompletion

Попытка понять API производителя Java. Что означает завершение? Помоги мне понять за то же самое. Ссылка: https: //kafka.apache.org/0110/javadoc/index.html? Org / apache / kafka / clients / ...
вопрос задан: 19 January 2019 23:55
1
ответ

Интеграция производителя Kafka Python с веб-приложением django

У меня есть вопрос о том, как мы можем интегрировать производителя kafka с веб-приложением. получить данные за каждую минуту или секунду. Может ли веб-приложение каждый раз передавать объект JSON работающему производителю ...
вопрос задан: 18 January 2019 20:33
0
ответов

Подтверждение производителя Kafka на основе batch.size (микропакет)

Продюсер Кафки имеет возможность выполнять микропакеты для операции отправки на основе batch.size и linger.ms для повышения производительности производителя. Однако даже если сообщения ...
вопрос задан: 31 March 2019 02:40
0
ответов

Как позвонить использовать Кафку транзакционный производитель из микросервиса

Я строю планировщик корпоративных событий на основе потоков Kafka. Запланированные события собираются или генерируются из микросервисов в облаке. Каждый микросервис будет иметь около 200 рабочих ...
вопрос задан: 20 January 2019 00:21
0
ответов

производитель кафки занимает гораздо больше времени при записи на большее количество разделов

у нас есть 5 брокеров кафки, фактор репликации 3 и 2 темы - T1 и T2. Тема T1 имеет 100 разделов, T2 имеет 6. при записи с производителем kafka (используя KafkaProducer.send ()) на T1 и T2, ...
вопрос задан: 16 January 2019 12:08
0
ответов

Кафка с .Net клиентом

Я хочу использовать Кафку в нашей производственной среде. Я хочу знать, если последняя версия клиента без ошибок для запуска производства. Работает ли это с группой потребителей? Я хочу передать 10000 записей за ...
вопрос задан: 2 November 2016 09:48
0
ответов

Как проверить, работает ли Kafka Server?

Я хочу убедиться, что сервер kafka запущен или нет перед запуском производственных и потребительских заданий. Это в среде Windows, и вот мой код сервера kafka в затмении ... Свойства kafka = ...
вопрос задан: 20 June 2016 12:38