Class | Description |
---|---|
PulsarCommittable |
The writer state for Pulsar connector.
|
PulsarCommittableSerializer |
A serializer used to serialize
PulsarCommittable . |
PulsarCommitter |
Committer implementation for
PulsarSink . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.