|
Change Parameter Type consumeFunction : Function<String,CompletableFuture<Void>> to consumeFunction : Function<Message<String>,CompletableFuture<Void>> in method public setConsumer(consumeFunction Function<Message<String>,CompletableFuture<Void>>) : void in class org.apache.pulsar.connect.twitter.TwitterFireHose |
From |
To |
|
Change Parameter Type tuple : KeyValue<K,V> to tuple : Message<KeyValue<K,V>> in method public write(tuple Message<KeyValue<K,V>>) : CompletableFuture<Void> in class org.apache.pulsar.connect.cassandra.CassandraSink |
From |
To |
|
Change Parameter Type consumer : Function<T,CompletableFuture<Void>> to consumer : Function<Message<T>,CompletableFuture<Void>> in method public setConsumer(consumer Function<Message<T>,CompletableFuture<Void>>) : void in class org.apache.pulsar.connect.core.PushSource |
From |
To |
|
Change Parameter Type consumeFunction : Function<V,CompletableFuture<Void>> to consumeFunction : Function<Message<V>,CompletableFuture<Void>> in method public setConsumer(consumeFunction Function<Message<V>,CompletableFuture<Void>>) : void in class org.apache.pulsar.connect.kafka.KafkaSource |
From |
To |
|
Change Parameter Type consumeFunction : Function<byte[],CompletableFuture<Void>> to consumeFunction : Function<Message<byte[]>,CompletableFuture<Void>> in method public setConsumer(consumeFunction Function<Message<byte[]>,CompletableFuture<Void>>) : void in class org.apache.pulsar.connect.rabbitmq.RabbitMQSource |
From |
To |
|
Change Parameter Type tuple : KeyValue<K,V> to tuple : Message<KeyValue<K,V>> in method public write(tuple Message<KeyValue<K,V>>) : CompletableFuture<Void> in class org.apache.pulsar.connect.aerospike.AerospikeSink |
From |
To |
|
Change Parameter Type consumeFunction : Function<byte[],CompletableFuture<Void>> to consumeFunction : Function<Message<byte[]>,CompletableFuture<Void>> in method public RabbitMQConsumer(consumeFunction Function<Message<byte[]>,CompletableFuture<Void>>, channel Channel) in class org.apache.pulsar.connect.rabbitmq.RabbitMQSource.RabbitMQConsumer |
From |
To |
|
Change Parameter Type message : KeyValue<K,V> to message : Message<KeyValue<K,V>> in method public write(message Message<KeyValue<K,V>>) : CompletableFuture<Void> in class org.apache.pulsar.connect.kafka.KafkaSink |
From |
To |
|
Change Attribute Type consumeFunction : Function<String,CompletableFuture<Void>> to consumeFunction : Function<Message<String>,CompletableFuture<Void>> in class org.apache.pulsar.connect.twitter.TwitterFireHose |
From |
To |
|
Change Attribute Type consumeFunction : Function<byte[],CompletableFuture<Void>> to consumeFunction : Function<Message<byte[]>,CompletableFuture<Void>> in class org.apache.pulsar.connect.rabbitmq.RabbitMQSource.RabbitMQConsumer |
From |
To |
|
Change Attribute Type consumeFunction : Function<V,CompletableFuture<Void>> to consumeFunction : Function<Message<V>,CompletableFuture<Void>> in class org.apache.pulsar.connect.kafka.KafkaSource |
From |
To |
|
Change Attribute Type consumer : Function<byte[],CompletableFuture<Void>> to consumer : Function<Message<byte[]>,CompletableFuture<Void>> in class org.apache.pulsar.connect.rabbitmq.RabbitMQSource |
From |
To |