|
Change Return Type Fetcher<String,byte[]> to Fetcher in method public kafkaFetcher(consumerFactory ConsumerFactory<String,byte[]>, messageConverter KafkaMessageConverter<String,byte[]>) : Fetcher in class org.axonframework.boot.autoconfig.KafkaAutoConfiguration |
From |
To |
|
Change Return Type Fetcher<String,byte[]> to Fetcher in method private fetcher() : Fetcher in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageSourceTests |
From |
To |
|
Change Return Type Fetcher<K,V> to Fetcher in method public build() : Fetcher in class org.axonframework.kafka.eventhandling.consumer.AsyncFetcher.Builder |
From |
To |
|
Change Return Type KafkaMessageSource<String,byte[]> to KafkaMessageSource in method public kafkaMessageSource(fetcher Fetcher) : KafkaMessageSource in class org.axonframework.boot.autoconfig.KafkaAutoConfiguration |
From |
To |
|
Change Variable Type testSubject : Fetcher<String,String> to testSubject : Fetcher in method public testStartFetcherWith_ExistingToken_ShouldStartAtSpecificPositions() : void in class org.axonframework.kafka.eventhandling.consumer.AsyncFetcherTests |
From |
To |
|
Change Variable Type testSubject : Fetcher<String,String> to testSubject : Fetcher in method public testStartFetcherWith_NullToken_ShouldStartFromBeginning() : void in class org.axonframework.kafka.eventhandling.consumer.AsyncFetcherTests |
From |
To |
|
Change Variable Type fetcher : Fetcher<String,byte[]> to fetcher : Fetcher in method public testOpeningMessageStream_WithValidToken_ShouldStartTheFetcher() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageSourceTests |
From |
To |
|
Change Variable Type fetcher : Fetcher<String,byte[]> to fetcher : Fetcher in method public testOpeningMessageStream_WithNullToken_ShouldInvokeFetcher() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageSourceTests |
From |
To |