-
MethodDescriptionThis method will be deleted on version 2.0, instead please use configure(String encodedAuthParamString) which is in EncodedAuthenticationParameterSupport for now and will be integrated into this interface.use "pulsar+ssl://" in serviceUrl to enableUse
Consumer.getLastMessageIds()
instead.UseConsumer.getLastMessageIdsAsync()
} instead.since 1.22.0. Please useMessageRouter.choosePartition(Message, TopicMetadata)
instead.UsePulsarClient.newTableView(Schema)
to build and configure aTableViewBuilder
instance