Как использовать Vertx Pump () для подключения файлового потока к производительному потоку Kafka?

Question

Я читаю большой файл, используя Java readStream.И я хочу передать это к теме Кафки.В настоящее время я использую метод KafkawriteStream для потоковой передачи каждого ProducerRecord.Он работает нормально.

Но недавно я прочитал о методе vertx Pump (), который является гораздо лучшим и более чистым способом достижения этого.К сожалению, я новичок в vertx и не нашел много документов в Интернете, связанных с моей целью.

Как использовать метод Vertx Pump () для подключения файла readstream к kafkaWriteStream?Предложения также приветствуются.

Answer 1

Pump - это утилита, предоставляемая Vert.x , которая моделирует возможность обратного давления.

Для экземпляра класса утилит должны быть созданы ReadStream и WriteStream затем началось:

Pump.pump(readStream, kafkawriteStream).start();

Обратите внимание, что Pump не запускается по умолчанию и может запускаться и останавливаться столько раз, сколько вы хотите.