Modifier and Type | Field and Description |
---|---|
static PulsarConfigValidator |
SINK_CONFIG_VALIDATOR |
Modifier and Type | Method and Description |
---|---|
static <T> org.apache.pulsar.client.api.ProducerBuilder<T> |
createProducerBuilder(org.apache.pulsar.client.api.PulsarClient client,
org.apache.pulsar.client.api.Schema<T> schema,
SinkConfiguration configuration)
Create a pulsar producer builder by using the given Configuration.
|
public static final PulsarConfigValidator SINK_CONFIG_VALIDATOR
public static <T> org.apache.pulsar.client.api.ProducerBuilder<T> createProducerBuilder(org.apache.pulsar.client.api.PulsarClient client, org.apache.pulsar.client.api.Schema<T> schema, SinkConfiguration configuration)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.