This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5ba7f79b5fc1f317b33b254707f2d6bded501a41
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Dec 2 12:18:03 2021 +0100
Polished
---
.../kafka/consumer/support/KafkaConsumerResumeStrategy.java | 1 -
.../camel/component/kafka/consumer/support/KafkaRecordProcessor.java | 1 -
.../kafka/consumer/support/OffsetKafkaConsumerResumeStrategy.java | 1 -
.../kafka/consumer/support/PartitionAssignmentListener.java | 2 +-
.../component/kafka/consumer/support/ResumeStrategyFactory.java | 3 +--
.../consumer/support/SeekPolicyKafkaConsumerResumeStrategy.java | 1 -
.../camel/component/kafka/producer/support/DelegatingCallback.java | 1 -
.../component/kafka/producer/support/KafkaProducerCallBack.java | 1 -
.../kafka/producer/support/KafkaProducerMetadataCallBack.java | 1 -
.../component/kafka/producer/support/KeyValueHolderIterator.java | 1 -
.../apache/camel/component/kafka/producer/support/ProducerUtil.java | 2 --
.../org/apache/camel/component/kafka/serde/KafkaSerdeHelper.java | 5 +----
12 files changed, 3 insertions(+), 17 deletions(-)
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaConsumerResumeStrategy.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaConsumerResumeStrategy.java
index 0deba22..b104bbf 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaConsumerResumeStrategy.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaConsumerResumeStrategy.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.consumer.support;
import org.apache.camel.ResumeStrategy;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
index 320cbfe..d1f7f76 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.consumer.support;
import java.time.Duration;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/OffsetKafkaConsumerResumeStrategy.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/OffsetKafkaConsumerResumeStrategy.java
index 5e690fa..cfe855c 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/OffsetKafkaConsumerResumeStrategy.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/OffsetKafkaConsumerResumeStrategy.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.consumer.support;
import java.util.Set;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/PartitionAssignmentListener.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/PartitionAssignmentListener.java
index 1ffbd2f..07d914a 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/PartitionAssignmentListener.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/PartitionAssignmentListener.java
@@ -51,7 +51,7 @@ public class PartitionAssignmentListener implements
ConsumerRebalanceListener {
this.lastProcessedOffset = lastProcessedOffset;
this.stopStateSupplier = stopStateSupplier;
- resumeStrategy =
ResumeStrategyFactory.newResumeStrategy(configuration);
+ this.resumeStrategy =
ResumeStrategyFactory.newResumeStrategy(configuration);
}
@Override
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
index 09f304b..bd94ccc 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ResumeStrategyFactory.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.consumer.support;
import org.apache.camel.component.kafka.KafkaConfiguration;
@@ -24,6 +23,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public final class ResumeStrategyFactory {
+
/**
* A NO-OP resume strategy that does nothing (i.e.: no resume)
*/
@@ -42,7 +42,6 @@ public final class ResumeStrategyFactory {
}
public static KafkaConsumerResumeStrategy
newResumeStrategy(KafkaConfiguration configuration) {
-
if (configuration.getResumeStrategy() != null) {
return configuration.getResumeStrategy();
}
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/SeekPolicyKafkaConsumerResumeStrategy.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/SeekPolicyKafkaConsumerResumeStrategy.java
index 1eba302..573d0b1 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/SeekPolicyKafkaConsumerResumeStrategy.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/SeekPolicyKafkaConsumerResumeStrategy.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.consumer.support;
import org.apache.kafka.clients.consumer.Consumer;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/DelegatingCallback.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/DelegatingCallback.java
index cc71667..f1a830e 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/DelegatingCallback.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/DelegatingCallback.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.producer.support;
import org.apache.kafka.clients.producer.Callback;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KafkaProducerCallBack.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KafkaProducerCallBack.java
index 32d0602..09b6a3d 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KafkaProducerCallBack.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KafkaProducerCallBack.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.producer.support;
import java.util.ArrayList;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KafkaProducerMetadataCallBack.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KafkaProducerMetadataCallBack.java
index a199881..37db490 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KafkaProducerMetadataCallBack.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KafkaProducerMetadataCallBack.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.producer.support;
import org.apache.kafka.clients.producer.Callback;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KeyValueHolderIterator.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KeyValueHolderIterator.java
index b3ee5e4..b46983a 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KeyValueHolderIterator.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/KeyValueHolderIterator.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.producer.support;
import java.util.Iterator;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/ProducerUtil.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/ProducerUtil.java
index 5b0499b..ba15dc3 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/ProducerUtil.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/producer/support/ProducerUtil.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.producer.support;
import java.nio.ByteBuffer;
@@ -30,7 +29,6 @@ import org.apache.kafka.common.utils.Bytes;
public final class ProducerUtil {
private ProducerUtil() {
-
}
public static Object tryConvertToSerializedType(Exchange exchange, Object
object, String valueSerializer) {
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/serde/KafkaSerdeHelper.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/serde/KafkaSerdeHelper.java
index 645da01..55b026a 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/serde/KafkaSerdeHelper.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/serde/KafkaSerdeHelper.java
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.component.kafka.serde;
import java.math.BigInteger;
@@ -24,8 +23,8 @@ import org.apache.camel.support.ExpressionAdapter;
import org.apache.camel.support.builder.ValueBuilder;
public final class KafkaSerdeHelper {
- private KafkaSerdeHelper() {
+ private KafkaSerdeHelper() {
}
public static ValueBuilder numericHeader(String name) {
@@ -33,9 +32,7 @@ public final class KafkaSerdeHelper {
@Override
public Object evaluate(Exchange exchange) {
byte[] id = exchange.getIn().getHeader(name, byte[].class);
-
BigInteger bi = new BigInteger(id);
-
return String.valueOf(bi.longValue());
}
});
