|
Rename Method public getZookeeperConnectionTimeoutMs() : Integer renamed to public getSessionTimeoutMs() : Integer in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getZookeeperSessionTimeoutMs() : Integer renamed to public getMetadataFetchTimeoutMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getZookeeperConnect() : String renamed to public getKerberosInitCmd() : String in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getRebalanceMaxRetries() : int renamed to public getMaxRequestSize() : Integer in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public setQueuedMaxMessageChunks(queuedMaxMessageChunks Integer) : void renamed to public setRequestRequiredAcks(requestRequiredAcks Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getProducerType() : String renamed to public getSslTruststoreType() : String in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public setProducerType(producerType String) : void renamed to public setSslKeystoreType(sslKeystoreType String) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getZookeeperHost() : String renamed to public getSslCipherSuites() : String in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setRefreshLeaderBackoffMs(refreshLeaderBackoffMs Integer) : void renamed to public setMetricsSampleWindowMs(metricsSampleWindowMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public isDualCommitEnabled() : Boolean renamed to public getBlockOnBufferFull() : Boolean in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getRebalanceBackoffMs() : Integer renamed to public getMetadataMaxAgeMs() : Integer in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getZookeeperHost() : String renamed to public getKeyDeserializer() : String in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getCompressedTopics() : String renamed to public getMetricReporters() : String in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public consumerRequiresZookeeperConnect() : void renamed to public consumerRequiresBootstrapServers() : void in class org.apache.camel.component.kafka.KafkaConsumerTest |
From |
To |
|
Rename Method public setMessageSendMaxRetries(messageSendMaxRetries Integer) : void renamed to public setSessionTimeoutMs(sessionTimeoutMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setQueueEnqueueTimeoutMs(queueEnqueueTimeoutMs Integer) : void renamed to public setConsumerRequestTimeoutMs(consumerRequestTimeoutMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getFetchMessageMaxBytes() : Integer renamed to public getMetadataMaxAgeMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setTopicMetadataRefreshIntervalMs(topicMetadataRefreshIntervalMs Integer) : void renamed to public setHeartbeatIntervalMs(heartbeatIntervalMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setConsumerTimeoutMs(consumerTimeoutMs Integer) : void renamed to public setLingerMs(lingerMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getRefreshLeaderBackoffMs() : Integer renamed to public getMetricsSampleWindowMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getOffsetsStorage() : String renamed to public getSslProtocol() : String in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getQueueEnqueueTimeoutMs() : Integer renamed to public getConsumerRequestTimeoutMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public consumerOnlyRequiresZookeeperConnectAndGroupId() : void renamed to public consumerOnlyRequiresBootstrapServersAndGroupId() : void in class org.apache.camel.component.kafka.KafkaConsumerTest |
From |
To |
|
Rename Method public getSocketTimeoutMs() : Integer renamed to public getTimeoutMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getRebalanceMaxRetries() : Integer renamed to public getRetries() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setRebalanceBackoffMs(rebalanceBackoffMs Integer) : void renamed to public setRetryBackoffMs(retryBackoffMs Integer) : void in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getQueueBufferingMaxMs() : Integer renamed to public getLingerMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getQueuedMaxMessageChunks() : Integer renamed to public getMaxRequestSize() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getBatchNumMessages() : Integer renamed to public getMaxBlockMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getZookeeperSessionTimeoutMs() : int renamed to public getKerberosBeforeReloginMinTime() : Integer in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getSocketReceiveBufferBytes() : Integer renamed to public getReceiveBufferBytes() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getTopicMetadataRefreshIntervalMs() : Integer renamed to public getHeartbeatIntervalMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setDualCommitEnabled(dualCommitEnabled Boolean) : void renamed to public setCheckCrcs(checkCrcs Boolean) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getRebalanceBackoffMs() : Integer renamed to public getReconnectBackoffMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getMessageSendMaxRetries() : Integer renamed to public getMaxInFlightRequest() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getConsumerTimeoutMs() : Integer renamed to public getSessionTimeoutMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getConsumerTimeoutMs() : Integer renamed to public getTimeoutMs() : Integer in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public getCompressedTopics() : String renamed to public getSslProvider() : String in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public setFetchMessageMaxBytes(fetchMessageMaxBytes Integer) : void renamed to public setMetadataMaxAgeMs(metadataMaxAgeMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setZookeeperConnectionTimeoutMs(zookeeperConnectionTimeoutMs Integer) : void renamed to public setConnectionMaxIdleMs(connectionMaxIdleMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getZookeeperSyncTimeMs() : Integer renamed to public getProducerBatchSize() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getOffsetsStorage() : String renamed to public getSslProtocol() : String in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setZookeeperSessionTimeoutMs(zookeeperSessionTimeoutMs Integer) : void renamed to public setMetadataFetchTimeoutMs(metadataFetchTimeoutMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getTopicMetadataRefreshIntervalMs() : int renamed to public getValueDeserializer() : String in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Method public setSocketReceiveBufferBytes(socketReceiveBufferBytes Integer) : void renamed to public setReceiveBufferBytes(receiveBufferBytes Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setCompressedTopics(compressedTopics String) : void renamed to public setSslProtocol(sslProtocol String) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public isDualCommitEnabled() : Boolean renamed to public getCheckCrcs() : Boolean in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getProducerType() : String renamed to public getSslKeystoreType() : String in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setSocketTimeoutMs(socketTimeoutMs Integer) : void renamed to public setTimeoutMs(timeoutMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setBatchNumMessages(batchNumMessages Integer) : void renamed to public setMaxRequestSize(maxRequestSize Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setQueueBufferingMaxMs(queueBufferingMaxMs Integer) : void renamed to public setBufferMemorySize(bufferMemorySize Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setRebalanceMaxRetries(rebalanceMaxRetries Integer) : void renamed to public setRetries(retries Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setZookeeperSyncTimeMs(zookeeperSyncTimeMs Integer) : void renamed to public setProducerBatchSize(producerBatchSize Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setOffsetsStorage(offsetsStorage String) : void renamed to public setSslProvider(sslProvider String) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public getZookeeperConnectionTimeoutMs() : Integer renamed to public getConnectionMaxIdleMs() : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Method public setRebalanceBackoffMs(rebalanceBackoffMs Integer) : void renamed to public setReconnectBackoffMs(reconnectBackoffMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute zookeeperSyncTimeMs : Integer to producerBatchSize : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute producerType : String to sslKeystoreType : String in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute rebalanceMaxRetries : Integer to retries : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute fetchMessageMaxBytes : Integer to metadataMaxAgeMs : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute offsetsStorage : String to sslProvider : String in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute rebalanceBackoffMs : Integer to reconnectBackoffMs : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute topicMetadataRefreshIntervalMs : Integer to heartbeatIntervalMs : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute queueBufferingMaxMs : Integer to bufferMemorySize : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute socketTimeoutMs : Integer to timeoutMs : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute queueEnqueueTimeoutMs : Integer to consumerRequestTimeoutMs : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute refreshLeaderBackoffMs : Integer to metricsSampleWindowMs : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute zookeeperSessionTimeoutMs : Integer to metadataFetchTimeoutMs : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute socketReceiveBufferBytes : Integer to receiveBufferBytes : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute dualCommitEnabled : Boolean to checkCrcs : Boolean in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Attribute zookeeperConnectionTimeoutMs : Integer to connectionMaxIdleMs : Integer in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter producerType : String to sslKeystoreType : String in method public setSslKeystoreType(sslKeystoreType String) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter zookeeperConnectionTimeoutMs : Integer to connectionMaxIdleMs : Integer in method public setConnectionMaxIdleMs(connectionMaxIdleMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter batchNumMessages : Integer to maxRequestSize : Integer in method public setMaxRequestSize(maxRequestSize Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter zookeeperSessionTimeoutMs : Integer to metadataFetchTimeoutMs : Integer in method public setMetadataFetchTimeoutMs(metadataFetchTimeoutMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter socketReceiveBufferBytes : Integer to receiveBufferBytes : Integer in method public setReceiveBufferBytes(receiveBufferBytes Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter rebalanceMaxRetries : Integer to retries : Integer in method public setRetries(retries Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter queueEnqueueTimeoutMs : Integer to consumerRequestTimeoutMs : Integer in method public setConsumerRequestTimeoutMs(consumerRequestTimeoutMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter mm : MessageAndMetadata<byte[],byte[]> to record : ConsumerRecord in method public createKafkaExchange(record ConsumerRecord) : Exchange in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Parameter fetchMessageMaxBytes : Integer to metadataMaxAgeMs : Integer in method public setMetadataMaxAgeMs(metadataMaxAgeMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter rebalanceBackoffMs : Integer to reconnectBackoffMs : Integer in method public setReconnectBackoffMs(reconnectBackoffMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter messageSendMaxRetries : Integer to sessionTimeoutMs : Integer in method public setSessionTimeoutMs(sessionTimeoutMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter refreshLeaderBackoffMs : Integer to metricsSampleWindowMs : Integer in method public setMetricsSampleWindowMs(metricsSampleWindowMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter socketTimeoutMs : Integer to timeoutMs : Integer in method public setTimeoutMs(timeoutMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter zookeeperSyncTimeMs : Integer to producerBatchSize : Integer in method public setProducerBatchSize(producerBatchSize Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter queuedMaxMessageChunks : Integer to requestRequiredAcks : Integer in method public setRequestRequiredAcks(requestRequiredAcks Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter queueBufferingMaxMs : Integer to bufferMemorySize : Integer in method public setBufferMemorySize(bufferMemorySize Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter dualCommitEnabled : Boolean to checkCrcs : Boolean in method public setCheckCrcs(checkCrcs Boolean) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter topicMetadataRefreshIntervalMs : Integer to heartbeatIntervalMs : Integer in method public setHeartbeatIntervalMs(heartbeatIntervalMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter rebalanceBackoffMs : Integer to retryBackoffMs : Integer in method public setRetryBackoffMs(retryBackoffMs Integer) : void in class org.apache.camel.component.kafka.KafkaEndpoint |
From |
To |
|
Rename Parameter offsetsStorage : String to sslProvider : String in method public setSslProvider(sslProvider String) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter compressedTopics : String to sslProtocol : String in method public setSslProtocol(sslProtocol String) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |
|
Rename Parameter consumerTimeoutMs : Integer to lingerMs : Integer in method public setLingerMs(lingerMs Integer) : void in class org.apache.camel.component.kafka.KafkaConfiguration |
From |
To |