Это мои первые дни в изучении кафки. И я проверяю каждое свойство / концепцию kafka на моей...

Я написал функцию потребителя Kafka, которая сначала извлекает сообщение из последнего прочитанного...

укажите ниже конфигурацию Kafka для локального сервера @Bean public ConsumerFactory consumerFactory...

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

Я хочу опрашивать только записи, которые произвели менее 30 секунд. Есть ли какой-либо способ в...

Я получаю такие ошибки в журнале авторизации kafka: [2019-11-05 09:19:27,050] INFO Principal =...

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

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

У нас есть 3-узловое кластерное развертывание Kafka с 5 темами и 6 разделами на тему. мы настроили...

Я использую @KafkaListener и ConcurrentKafkaListenerContainerFactory для прослушивания 3 тем kafka,...

Потребитель Kafka продолжает печатать сообщения об ошибках Я собрал кластер (kafka версия 2.3.0),...

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

Представьте, что вы определили, что хотите использовать ровно 8 пользовательских потоков для своего...