Исключением является ошибка отправки HTTP-запроса в конечную точку:...

Я строю планировщик корпоративных событий на основе потоков Kafka.Запланированные события...

Попытка понять API производителя Java. Что означает завершение? Помоги мне понять за то же самое....

У меня вопрос о том, как мы можем интегрировать производителя kafka с интерфейсным веб-приложением....

у нас есть 5 брокеров kafka, фактор репликации 3 и 2 темы - T1 и T2. В теме T1 100 разделов, в T2 -...

Средний размер сообщения невелик, но размер варьируется. Средний размер сообщения: 1 КБ 1Мбайт...

Я хочу использовать пользовательский раздел в kafka с помощью приложения .net. Я создал тему,...

Есть ли способ приостановить или подавить производителя Kafka на основе отставания потребителей или...

По умолчанию Kafka отправляет сообщения из темы всем группам потребителей. В моем случае у меня...

Невозможно записать сообщение в тему kafka (продюсер) при вызове kakfa производить класс с циклом....

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

Я создавал пример Kafka Producer, используя Java. я был отправив обычные данные, которые просто...

Есть ли недостатки при использовании одного и того же кода производителя и потребителя для всех...

Работая над созданием новой темы Кафки для некоторой информации, которой вы можете поделиться, не...

Я хочу получить данные из сокета и поместить их в тему kafka, чтобы моя программа flink могла...

Событие delivery-report вызывается каждый раз для каждого созданного сообщения и продолжает давать...

Когда брокер kafka отключен, производитель все еще пытается связаться с ним.provider.send ()...

Есть ли способ получить данные о происхождении для Kafka заданий. Как, например, у нас есть URL...

Я пытаюсь запустить производителя kafka с помощью API kafka-clients.У меня есть несколько...

В Java-приложении, интенсивно использующем память, наличие нескольких экземпляров KafkaProducer,...

Я строю производителя Apache kafka, который потребляется потребителем flink Kafka.Мне нужно...

Пытаюсь включить опцию 'idempotent' на kafka-console -roduction.Ссылка на следующие ссылки:...

У меня есть один узел Kafka-2.11, установленный в экземпляре EC2, группа безопасности настроена...

Я пытаюсь соединить соединитель Kafka с базой данных, используя соединитель jafb kafka. Я могу...

Мой Java KafkaProducer способен отправлять сообщения и получать асинхронный обратный вызов в обоих...