|
Rename Parameter partitionLastOffset : long to recordOffset : long in method protected commitOffset(offsetRepository StateRepository<String,String>, partition TopicPartition, recordOffset long) : void in class org.apache.camel.component.kafka.DefaultKafkaManualCommit |
From |
To |
|
Rename Parameter partitionLastOffset : long to recordOffset : long in method public newInstance(exchange Exchange, consumer KafkaConsumer, topicName String, threadId String, offsetRepository StateRepository<String,String>, partition TopicPartition, recordOffset long) : KafkaManualCommit in class org.apache.camel.component.kafka.DefaultKafkaManualCommitFactory |
From |
To |
|
Rename Parameter partitionLastOffset : long to recordOffset : long in method public DefaultKafkaManualCommit(consumer KafkaConsumer, topicName String, threadId String, offsetRepository StateRepository<String,String>, partition TopicPartition, recordOffset long) in class org.apache.camel.component.kafka.DefaultKafkaManualCommit |
From |
To |
|
Rename Parameter partitionLastOffset : long to recordOffset : long in method public newInstance(exchange Exchange, consumer KafkaConsumer, topicName String, threadId String, offsetRepository StateRepository<String,String>, partition TopicPartition, recordOffset long) : KafkaManualCommit in class org.apache.camel.component.kafka.KafkaManualCommitFactory |
From |
To |