Я отправляю входные данные JSON в тему Кафки. Я могу увидеть те же данные JSON в kafka при помощи...

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

У меня есть тема Kafka, из которой мне нужно читать данные JSON с помощью потребителя, но на основе...

У нас есть проблемы с производительностью среди наших потребителей.Точнее, в ЧТО это делается с...

Я использую небольшой вариант примера кода опроса клиента, который я нашел в Confluent github : c =...

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

Я новичок в kafka и прошел документацию , но ничего не понял.Может кто-нибудь объяснить, когда...

У нас есть KafkaConsuer: KafkaConsumer<String, XYZ> kafkaConsumer = new...

У меня есть два брокера Kafka (2.11-0.11.0.1).Коэффициент репликации тем по умолчанию установлен...

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

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

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

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

Я создал многопоточный потребитель Kafka, в котором каждому разделу назначен один поток (у меня...

Я пытаюсь реализовать потребителя Kafka на Java, чтобы получать и обрабатывать записи из тем Kafka

Я новичок в кафке.Я написал потребительское приложение kafka с использованием весенней загрузки.Это...

позвольте мне описать обоснование моего вопроса: У нас есть приложение на базе Micronaut,...

Я хочу использовать сотни тысяч KafkaConsumer .Например, мне нужно 100_000 потребителей для...

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

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

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

Я установил для enable.auto.commit значение true, для интервала автоматического принятия - 1000 мс,...

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

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

Я пытаюсь отфильтровать сообщения ConsumerRecord перед использованием, основываясь на содержимом...