Interface | Description |
---|---|
PulsarSerializationSchema<IN> |
The serialization schema for how to serialize records into Pulsar.
|
Class | Description |
---|---|
PulsarSchemaWrapper<IN> |
Wrap the Pulsar's Schema into PulsarSerializationSchema.
|
PulsarSerializationSchemaWrapper<IN> |
Wrap the Flink's SerializationSchema into PulsarSerializationSchema.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.