kafka-producer-api

0зной

1ответ

Может кто-нибудь помочь мне с ниже queries.I я использую Кафка-клиенты-0.10.1.1 (Single Node Single Broker) По умолчанию значение auto.create.topics.enable - это правда. 1.I Посылает сообщение на тему

1зной

1ответ

Публикация сообщения внешнему Kafka Broker из контейнера-докера

В моей IDE я могу использовать приложение для загрузки весны, которое создало бы сообщение (с Kafkaproducer) внешнему брокеру kafka. Но как только я разместил мое приложение для загрузки в контейнере

1зной

2ответ

Производитель/потребитель командной строки Kafka имеет 1 секунду латентности

Я делаю тестовый прогон с Kafka, используя производителя и потребителя командной строки. Я бегу это в одном окне терминала bin/kafka-console-producer.sh --broker-list localhost:9092 --topic tag7 и э

0зной

2ответ

Как отправить kafka соответствующие данные в другую тему

Как нажимать соответствующие данные между темой 1 и темой 2 в другой теме 3? при отправке сообщений от производителя к потребителю?

1зной

1ответ

Не найдено ни одного приложения для журнала (org.apache.kafka.clients.producer.ProducerConfig)

Я пишу код, в котором я пытаюсь использовать сообщения, используя kafka и искру. Но мой код не работает. Вот мой код: import org.apache.kafka.clients.producer.{ KafkaProducer, ProducerConfig, Producer

1зной

1ответ

Kafka max.request.size против buffer.memory против send.buffer.bytes

Я пытаюсь настроить своего продюсера Kafka и перейдя по документации, я пытаюсь понять лучшую корреляцию между разными значениями. Из чего я понимаю, эти значения должны соответствовать следующему пра

0зной

2ответ

Как получить смещение потребителя Кафки?

Работа с Kafka (v2.11-0.10.1.0) -spark-streaming (v-2.0.1-bin-hadoop2.7). У меня есть Kafka Producer и Spark-streaming потребитель для производства и потребления. Все работает нормально, пока я не ост