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

У меня две (и более) темы Кафки, и мне нужно присоединиться к ним. Мой вопрос из того, что я читаю...

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

версия сервера 0.10.1. мы передаем запрос производителя через прокси. теперь, результат состоит в...

Я хотел бы добавить ObjectMapper Джексона в JsonDeserializer для ConsumerFactory Кафки. Я сделал то...

В C # как ты это делаешь?Библиотека, кажется, не соответствует некоторым другим реализациям. Я...

У меня следующая ситуация: У меня есть 5 экземпляров одной и той же службы, все в одной группе...

Я создаю группы потребителей, используя Kafka-console-consumer.sh. Если я создаю старую группу...

Я уже установил зафиксированное смещение на: properties.setProperty("auto.commit.interval

Каков рекомендуемый способ перезагрузить контекст SSL в Spring Kafka? У меня есть требование...

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

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

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

Я новичок в Apache Storm. Я пытаюсь разработать систему обработки потоков в реальном времени с...

В последнее время мы выполняем потоковую работу с Apache Flink.Существует несколько тем KAFKA в...

Итак, у меня установлен разъем Confluent Kafka JDBC.Сначала я запускаю реестр схемы, например

Я использую Spring Kafka с SPEL и пытаюсь слушать разные темы на основе значения, представленного в...

у нас есть кластер ambari с 3 серверами zookeeper и 3 машинами kafka версия hadoop (HDP - 2.6.4)...

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

Мы используем streamset для вывода данных в тему kafka, у нас есть 3 брокера kafka в кластере).Мы...

Я регистрирую Схему в реестре Схемы следующим образом: { Prop1:val1, prop2:val2, prop3:val3} все...

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

Когда я пытаюсь подключить Debezium к моей базе данных SQL Server после включения функции CDC, у...

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

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