Нужна помощь, чтобы получить некоторую помощь для публикации всего сообщения из GCP (Google Cloud...

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

Я попробовал с 5.1.0-post веткой. Выдает несколько ошибок при настройке с SSL / TLS, Я также...

У меня есть производитель какфа, которому не нужно сериализовать ключ, только значения.Но для...

Я использую kafka monitor для изменения LocalFile и SparkStreaming для анализа.Но я не могу извлечь...

Отправьте сообщение kafka через «Процесс публикации kafka» в nifi.Другая Java-программа,...

Я построил потребителя, используя Kafka Consumer API, способ, которым этот потребитель должен...

Для данных, которые передаются из нашей системы заявок, мы пытаемся добиться следующего: Получите...

У меня есть конфиг nginx kafka lua: local client = require "resty.kafka.client" local...

Предположим, у меня есть 2 проекта SpringBoot.Оба они имеют свои собственные свойства профиля,...

Я пытаюсь создать простую демонстрацию, используя Kafka с Go, но получаю эту ошибку: [56] Kafka...

Я пытаюсь использовать потребительскую библиотеку https://doc.akka

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

Предположим, у меня есть файл, заполненный JSON объектами / строками, разделенными символами новой...

Мне нужно отправить два события на кафку. Я могу нажать одно. Я получаю Арифметическое Исключение,...

Скажем, у меня есть приложение, которое считывает пакет данных из KAFKA, оно использует ключи...

Я использую Kafka Consumer API для построения потребителя. Структура сообщения сложная. Для...

Мы используем Kafka S3 Connector для конвейерного журнала, поскольку он гарантирует семантику ровно...

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

Я пытаюсь реализовать способ произвольного доступа к сообщениям от Kafka, используя KafkaConsumer

Я понимаю, что если Acks = all и min ISR установлены на> = 2, это уменьшает вероятность потери...

Я пытался реализовать сливное изображение kafka-connect для подключения или наше на прем S3. Мы...

При попытке подключиться к теме из микросервиса Java Jetty, я получаю эту ошибку внутреннего...

Я настраиваю Kafka-кластер с Kerberos, и инструкции / документация немного редки, когда речь идет о...

Как мне остановить весеннюю кафку, не повторять не прочитанные сообщения из темы. Например, я...