Package | Description |
---|---|
org.apache.flink.connector.pulsar.sink.writer.delayer |
Modifier and Type | Method and Description |
---|---|
static <IN> FixedMessageDelayer<IN> |
MessageDelayer.fixed(java.time.Duration duration)
All the messages should be consumed in a fixed duration.
|
static <IN> FixedMessageDelayer<IN> |
MessageDelayer.never()
All the messages should be consumed immediately.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.