|
Change Parameter Type interceptors : ConsumerInterceptors to interceptors : ConsumerInterceptors<T> in method package ConsumerImpl(client PulsarClientImpl, topic String, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, partitionIndex int, subscribeFuture CompletableFuture<Consumer<T>>, schema Schema<T>, interceptors ConsumerInterceptors<T>) in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |
|
Change Parameter Type interceptors : ConsumerInterceptors to interceptors : ConsumerInterceptors<T> in method private patternTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>, interceptors ConsumerInterceptors<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Parameter Type mode : Mode to regexSubscriptionMode : RegexSubscriptionMode in method public subscriptionTopicsMode(regexSubscriptionMode RegexSubscriptionMode) : ConsumerBuilder<T> in class org.apache.pulsar.client.api.ConsumerBuilder |
From |
To |
|
Change Parameter Type mode : Mode to mode : RegexSubscriptionMode in method public subscriptionTopicsMode(mode RegexSubscriptionMode) : ConsumerBuilder<T> in class org.apache.pulsar.client.impl.ConsumerBuilderImpl |
From |
To |
|
Change Parameter Type topicName : TopicName to topicName : String in method public fromByteArrayWithTopic(data byte[], topicName String) : MessageId in class org.apache.pulsar.client.api.MessageId |
From |
To |
|
Change Parameter Type interceptors : ConsumerInterceptors to interceptors : ConsumerInterceptors<T> in method package ConsumerImpl(client PulsarClientImpl, topic String, conf ConsumerConfigurationData<T>, listenerExecutor ExecutorService, partitionIndex int, subscribeFuture CompletableFuture<Consumer<T>>, subscriptionMode SubscriptionMode, startMessageId MessageId, schema Schema<T>, interceptors ConsumerInterceptors<T>) in class org.apache.pulsar.client.impl.ConsumerImpl |
From |
To |