kafka-producer-api

4зной

1ответ

У меня есть тема с кафкой с 1 перегородкой. если в нем было 100 сообщений, смещение было бы от 0,99. В соответствии с политикой сохранения kafka все сообщения будут уничтожены после указанного периода

0зной

1ответ

Как настроить Kafka, чтобы потребители и производители восстанавливались после сбоев при отключении репликации?

У нас есть прецедент, где допустимость потери данных (думаю, приемлема 30-50%). Чтобы уменьшить затраты, мы хотим знать, можно ли настроить Kafka с коэффициентом репликации 1, чтобы потребители и прои

2зной

1ответ

Kafka Producer Send String Not Working

Я пытаюсь создать производителя кафки, который отправляет строку «Эта программа работает» в тему кафки. Я не уверен, почему он не работает. Ниже приведен следующий код. Я не Клаудера. package kafka_te

1зной

1ответ

Apache Kafka Java Producer Scala Потребительские потоки

Я использую Apache Kafka. Я создал военный файл, в котором производитель закодирован в Java, а Consumer закодирован в Scala. Продюсер получает данные с HTML-страницы. Я вижу, что большая часть данных,

1зной

2ответ

Внедрение фильтрации для сообщений kafka

Недавно я начал использовать Kafka и оценил Kafka для нескольких случаев использования. Если бы мы хотели предоставить возможность фильтровать сообщения для потребителей (подписчиков) на основе содерж

0зной

1ответ

Проблема в объекте Deserialize protostuff в Кафки Consumer

Получение следующее исключение при десериализации байт [] в объект protostuff в Кафки Consumer java.lang.NegativeArraySizeException at com.dyuproject.protostuff.GraphIOUtil.mergeDelimitedFrom(GraphIO

1зной

1ответ

KafkaProducer не отправляет Запись

Я совершенно не знаком с Kafka, и у меня есть проблемы с использованием KafkaProducer. Метод отправки производителя блокирует ровно 1 мин, а затем приложение проходит без исключения. Это, очевидно, не