Я использую Kafka 2.1.0 и хочу опубликовать сообщение после подписки.Есть ли способ для...
У меня есть json публикация в одной из моих тем по kafka: { "hash": "ABC",...
В приложении Node js, когда я пытаюсь отправить сообщения на тему Kafka, все собираются в Раздел 0....
Я наткнулся на эту ссылку для заголовков кафки.Как обсуждается в приведенной ниже ссылке заголовок...
При поиске записи dns (?) Во время инициации производителя kafka я наблюдаю очень странную...
Справочная информация: Я установил число разделов по умолчанию = 1 и коэффициент репликации = 3 в...
Я пытаюсь найти способы получения текущей статистики использования для моего кластера kafka.Я...
Я реализовал простой процессор записи мертвых букв Kafka. Он отлично работает при использовании...
так что я довольно новичок в Кафке.Я пытался запустить простого потребителя и производителя Kafka
У меня есть 3 брокера kafka кластера с 3 zookeeper. У меня вопрос, нужно ли нам давать только один...
Я использую rdkafka_simple_producer.c для создания сообщений в кластер Kafka.У меня одна тема и 30...
Я использую Kafka Java API v2.1.Я хочу знать, какие исключения будут распространяться на код...
Я знаю, это кажется странным, но когда я установил «linger.ms» больше 0, пропускная способность...
spring-kafka не может отправить запись в обратном вызове ListenableFuture<SendResult<String,...
У меня есть сценарий, в котором кафка падает случайным образом.Когда я посылаю сообщение Кафке, и...
Получение исключения тайм-аута с API Kafka Producer. Ручной процесс создания сообщения Kafka Мы...
У нас есть сценарий, в котором мы должны читать файлы журналов с 50 различных типов серверов,...
У нас были процессоры, которые передают смещение через производителя для достижения точной...
Каков наилучший способ реализации производителя Kafka в RoR с использованием ruby-kafka (0.7.4) gem...
У меня есть кластер kafka с определенной темой, в котором было слишком мало разделов, поэтому было...
Я пытаюсь отправить сообщение в тему Кафки. Тема создана на экземпляре AWS EC2. Когда я отправляю...
Я тестирую восстановление после отказа серверов Kafka. То есть я перезагружаю серверы Kafka по...
У меня возникла следующая проблема: Я установил максимально возможную базовую платформу на AWS,...
В моем приложении при отправке сообщений я использую метаданные в обратном вызове, чтобы сохранить...
Я использую spring-kafka 2.1.10. ВЫПУСК.У меня есть потребитель со следующими свойствами...