Мой кластер Kafka имеет следующую конфигурацию. Кластер версий Kafka (v1.1.0) с 3 брокерами Одна...
В настоящее время я создаю kafka потребитель в Java, где он будет отображать только разделы (у меня...
У меня проблема при использовании MassTransit v5.1.5 со стандартным DI ASP.NET Core.У меня есть...
1.- В этом назначении вы будете реализовывать свободный от тупиков вариант производителя /...
Проблема этого кода в выводе.Продюсера производят не раз.Почему и как я могу это решить?Ведь каждый...
Я изучаю системное программирование в Linux, поэтому я просто попытался написать очень...
Я работаю над управляемой событиями архитектурой потока, и я хотел бы иметь как можно больше...
Я использую Kafka (kafka-python) версии 3.0.0-1.3.0.0.p0.40.Мне нужно настроить потребителя для...
Я пытаюсь создать издателя и потребителя, чтобы справиться с большим импортом.Мне удалось настроить...
Я создал класс, который реализует org.apache.kafka.common.metrics.KafkaMetric примерно так: public...
в моей программе я получаю сообщение от Exchange. Я создал свой собственный Consumer и...
У нас есть темы со сроком хранения 7 дней (168 часов).Сообщения потребляются в режиме реального...
Я пытаюсь передать подкласс в качестве параметра методу.До сих пор я не был успешным, и даже сказал...
Я пытаюсь добиться следующего: Я хочу убедиться, что конкретный узел в теле («запись») имеет от...
В приведенном ниже коде используются исходные кафки, стоковые hdfs, с использованием потоковой...
Я использую плагин https://github.com/bbc/sqs-consumer/ SQS Consumer для опроса очереди SQS. Время...
Я использую пакет модуля узла sqs-consumer. У меня есть следующий код: init: function () { var app...
Я нашел некоторые ресурсы о том, как проверить производителя, но я ничего не смог найти, чтобы...
Могу ли я сделать так, чтобы следующее действие фактически было двумя действиями в одном? static...
Я должен реализовать проблему производителя-потребителя через разделяемую память и семафоры.Он...
Шаг 1: создать тему только с одним разделом: bin/kafka-topics.sh --create --zookeeper...
я пытаюсь реализовать производителя - потребителя с потоками. В моем коде ниже работает хорошо, за...
Привет. Я пытаюсь использовать поставщика и потребителя, представленных в Java8.Я пытаюсь...
У нас есть настройка KAFKA в AWS, и мы публикуем там сообщения от издателя, мы хотим получать эти...
Я хочу написать скрипт, который рассчитывает общую задержку на потребителя / раздел. Я знаю общую...