в kafka cosummer, если обработка сообщения занимает более 5 минут, сообщение обрабатывается заново,...

Давайте предположим, что у меня есть данные в Кафке теме employee-topic, 2 SpringBoot экземпляров...

Не могу найти, как передать имя пользователя и пароль в KafkaConsumer. Я использую SASL PLAINTEXT...

Я новичок в Kafka и Spring Boot и пытаюсь заставить мое приложение читать из определенного раздела...

Чтобы отобразить весь список пользователей с квотами в Kafka, мы используем: kafka-configs...

Exception Stacktrace: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested...

Я проходил через API Kafka Spring . В разделе шаблон Кафки написано: Вы можете...

Я создал тему Кафки, которая получает данные JSON. Поскольку я выполняю массовую загрузку (из...

@Configuration public class KafkaConfiguration { @Value("${kafka.boot.server}") private...

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

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

Я пробовал базовое приложение весенней загрузки kafka, используя этот учебник. Моя иерархия проекта...

Я пытаюсь получить оперативные данные из openweathermap.org API с помощью kafka Producer python....

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

Я хочу отправить несколько пользовательских заголовков запроса при подключении к реестру схемы из...

Я пытаюсь обогатить некоторые данные о событиях с помощью KSQL (5.2.3) и Kafka (2.12-2.3.0). Left...

Kafka Concurrent Consumer делает автоматическое принятие кафки в значение false. Затем, основываясь...

Есть ли способ использовать Broadcast Join в FLINK так же, как я использовал в SPARK. Я работаю с...

Существуют документы, подобные приведенным ниже, в которых утверждается, что изменения конфигурации...

Я пытаюсь написать стойкого потребителя Кафки. Если при обработке сообщения в методе слушателя...

Я использовал соединитель источника kafka для передачи документов из Couchbase в kafka. Эти...

Я настраиваю производителя, который отправляет сообщения в виде (значения ключа) [key - это...

В моем потоковом приложении Scala (2.11) я потребляю данные из одной очереди в IBM MQ и записываю...

Я пытался создать тему кафки, например: kafka-topics --zookeeper HOST --create --topic TOPIC...

Я изучаю схему реестра, используя слияние. Кажется, я не могу загрузить 'kafka avro serializer'. Я...