Interface PulsarClientProvider

public interface PulsarClientProvider

Service Provider Interface for the Pulsar client implementation.

The implementation module registers itself via META-INF/services using the standard Java ServiceLoader mechanism.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	PulsarClientProvider.Holder	Lazy initialization holder for the provider singleton.

Method Summary

Modifier and Type	Method	Description
Authentication	authenticationTls()
Authentication	authenticationToken(String token)
Authentication	authenticationToken(Supplier<String> tokenSupplier)
Schema<GenericRecord>	autoConsumeSchema()
Schema<byte[]>	autoProduceBytesSchema()
Schema<byte[]>	autoProduceBytesSchema(Schema<?> base)
<T> Schema<T>	avroSchema(Class<T> pojo)
Schema<Boolean>	booleanSchema()
Schema<Byte>	byteSchema()
Schema<byte[]>	bytesSchema()
Checkpoint	checkpointFromBytes(byte[] data)
Authentication	createAuthentication(String className, String params)
Authentication	createAuthentication(String className, Map<String,String> params)
Schema<Double>	doubleSchema()
Checkpoint	earliestCheckpoint()
MessageId	earliestMessageId()
Schema<Float>	floatSchema()
Schema<?>	genericSchema(SchemaInfo schemaInfo)
static PulsarClientProvider	get()
Schema<Integer>	intSchema()
<T> Schema<T>	jsonSchema(Class<T> pojo)
Checkpoint	latestCheckpoint()
MessageId	latestMessageId()
Schema<Long>	longSchema()
MessageId	messageIdFromBytes(byte[] data)
PulsarClientBuilder	newClientBuilder()
<T extends com.google.protobuf.Message> Schema<T>	protobufSchema(Class<T> clazz)
Schema<Short>	shortSchema()
Schema<String>	stringSchema()

Method Details

newClientBuilder

PulsarClientBuilder newClientBuilder()

messageIdFromBytes

MessageId messageIdFromBytes(byte[] data)
                      throws IOException

Throws:

IOException

earliestMessageId

MessageId earliestMessageId()

latestMessageId

MessageId latestMessageId()

bytesSchema

Schema<byte[]> bytesSchema()

stringSchema

Schema<String> stringSchema()

booleanSchema

Schema<Boolean> booleanSchema()

byteSchema

Schema<Byte> byteSchema()

shortSchema

Schema<Short> shortSchema()

intSchema

Schema<Integer> intSchema()

longSchema

Schema<Long> longSchema()

floatSchema

Schema<Float> floatSchema()

doubleSchema

Schema<Double> doubleSchema()

jsonSchema

<T> Schema<T> jsonSchema(Class<T> pojo)

avroSchema

<T> Schema<T> avroSchema(Class<T> pojo)

protobufSchema

<T extends com.google.protobuf.Message> Schema<T> protobufSchema(Class<T> clazz)

autoProduceBytesSchema

Schema<byte[]> autoProduceBytesSchema()

genericSchema

Schema<?> genericSchema(SchemaInfo schemaInfo)

autoProduceBytesSchema

Schema<byte[]> autoProduceBytesSchema(Schema<?> base)

autoConsumeSchema

Schema<GenericRecord> autoConsumeSchema()

checkpointFromBytes

Checkpoint checkpointFromBytes(byte[] data)
                        throws IOException

Throws:

IOException

earliestCheckpoint

Checkpoint earliestCheckpoint()

latestCheckpoint

Checkpoint latestCheckpoint()

authenticationToken

Authentication authenticationToken(String token)

authenticationToken

Authentication authenticationToken(Supplier<String> tokenSupplier)

authenticationTls

Authentication authenticationTls()

createAuthentication

Authentication createAuthentication(String className,
 String params)
                             throws PulsarClientException

Throws:

PulsarClientException

createAuthentication

Authentication createAuthentication(String className,
 Map<String,String> params)
                             throws PulsarClientException

Throws:

PulsarClientException

get

static PulsarClientProvider get()