Мы отправляем сообщение с заголовками в Kafka, используя org.apache.kafka.clients.producer

Как обрабатывать большие сообщения в Kafka, такие как более 20 МБ и т. Д. [2019-03-13 08: 59: 10...

Кафка удалил параметр --num-threads из option of org.apache.kafka.tools.ProducerPerformance из...

Я новичок в весенней интеграции. Я пытаюсь создать службу весеннего отдыха, где он будет получать...

Я пытаюсь реализовать управление окнами с помощью Kafka Streams, в котором мы получаем несколько...

Я использую Scala 2.12 и мне требуются библиотеки для преобразования сообщений в Avro (необходимо...

Я использую пакет nuget Kafka-Net, чтобы сделать базовый POC для производства и потребления Kafka....

Это мой server.properties: listeners=PLAINTEXT://localhost:9092,SSl://localhost:9093 ssl.client

Я тестирую точно один раз доставку с spring-kafka. Насколько я понимаю, смещения и любые сообщения,...

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

Я тестирую Apache Kafka Producer с нативной реализацией java против confluent-kafka Python, чтобы...

Я планирую использовать kafka Java Producer на POS-терминале для записи транзакций.Программное...

Я пытаюсь настроить клиент kafka для аутентификации на защищенном kafkaserver.Я настроил jaas и ssl...

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

Можно ли произвести вывод в тему Кафки и записать в хранилище состояний за одну транзакцию?Но не...

При записи данных в kafka можно использовать столбец с именем key, который будет использоваться для...

В моем приложении я буду использовать данные из более чем 100 тем.Должен ли я создать одного...

Я должен добавить шифрование и аутентификацию с помощью SSL в kafka. Вот что я сделал: Создание...

Сообщение под темой Кафки также называется log? log разделы = разделы сообщения темы? # The default...

Я использую оба Kafka и Kafka Streams в моем приложении Spring.В то время как обычная Kafka связь,...

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

Я использую provider-perf-test.sh для тестирования производительности.Выходные метрические...

Мы используем процессоры с единовременной доставкой (фиксируя смещение потребителя через...

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

Сообщение о проблеме здесь.Производитель скинул ошибки ниже.Прождал час или около того, и ошибка...