Class | Description |
---|---|
PulsarConsumerBuilder<T> |
Override the default consumer builder for supporting build the custom Key_Shared consumer.
|
PulsarSourceConfigUtils |
Create source related
Consumer and validate config. |
SourceConfiguration |
The configuration class for pulsar source.
|
Enum | Description |
---|---|
CursorVerification |
The enum class for defining the cursor verify behavior.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.