demo.incoming тема в Кафке продолжает накапливаться. Я использую блок скрапа . Около 70 запросов в...

В документах Kafka упоминается, что потребители не являются потокобезопасными.Чтобы избежать этой...

У меня есть тема kafka с фактором репликации 3 и min.insync.replicas = 2, продюсер, который...

размышляя о масштабировании, мне интересно, как запросы распределяются между серверами KSQL? 1 -...

У меня были проблемы с настройкой моего коннектора приемника и запуском базы данных postgresql,...

Интересно, какая выгода от добавления схемы json к вашему сообщению, поскольку kafka connect ее...

Я пытаюсь установить и запустить kafaka локально, но он показывает ошибку, не может загрузить класс...

Я пытаюсь реализовать SSL на моей локальной машине, которая имеет брокер с одним узлом и zk. Я...

Я новичок в Джанго и Кафке. У меня есть требования, чтобы получить сообщение в формате ниже в Kafka...

Я пытался сделать что-то вроде следующего: public List<SourceRecord> poll() throws...

Мой потребитель Kafka опрашивает быстрее, чем я ожидал. Есть ли какой-нибудь конфиг, который я могу...

Я работаю с очень маленьким фрагментом кода nodeJS, который использует экспресс.Приложение получает...

Моя настройка следующая: я извлекаю XML-файлы с ftp-сервера, распаковываю их в POJO, сопоставляю их...

Будучи новичком в kafka, мы задаемся вопросом, поддерживает ли kafka наш вариант использования. Мы...

Я написал простое приложение для подсчета слов, используя Flink 1.7.2 с Kafka 2.2 как для...

У нас есть Кафка-кластер в производственной среде и тестовой среде. У нас есть решение для...

Я установил zookeeper и Kafka с помощью докера по следующей ссылке https://crunchytechbytz

У меня есть пара пользователей Kafka, подписавшихся на тему, и мне нужно добавить несколько...

У меня весенний загрузочный проект с потребителем кафки.Мне нужно обрабатывать ошибки, если...

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

В server-1.properties Я изменил порт, журнал и идентификатор брокера, но когда я запускаю это...

Я новичок в Кафке и, может быть, это очень легко.Но я не мог найти решение проблемы, с которой я...

Я довольно новый в Кафке. Для проведения стресс-тестирования моего кластера и создания опыта...

Пока мы пытаемся использовать Kafka Connect для HDFS Sink на основе статьи в блоге Confluent:...

У меня работает один узел Kafka (v 0.10.2). Мы настроили log.retention.hours = 480, но сообщения не...