You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2024/01/10 09:24:05 UTC
(camel) 02/02: CAMEL-20044: formatting fixes
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b7dc1da4dbef98d9af96fe4abc0b75cc0578feeb
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Jan 9 17:39:40 2024 +0100
CAMEL-20044: formatting fixes
---
.../java/org/apache/camel/component/kafka/KafkaFetchRecords.java | 8 ++++----
.../kafka/consumer/support/KafkaRecordProcessorFacade.java | 3 ++-
.../camel/component/kafka/consumer/support/ProcessingResult.java | 1 -
.../KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java | 4 ++--
.../integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java | 4 ++--
.../kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java | 4 ++--
...KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java | 4 ++--
.../KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java | 4 ++--
...kaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java | 4 ++--
.../KafkaBreakOnFirstErrorWithBatchUsingSynchCommitManagerIT.java | 4 ++--
.../kafka/integration/health/KafkaConsumerHealthCheckIT.java | 4 ++--
11 files changed, 22 insertions(+), 22 deletions(-)
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
index 9a5004cc2de..2c32e727a50 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
@@ -305,7 +305,7 @@ public class KafkaFetchRecords implements Runnable {
}
protected void startPolling() {
-
+
try {
/*
* We lock the processing of the record to avoid raising a WakeUpException as a result to a call
@@ -315,7 +315,7 @@ public class KafkaFetchRecords implements Runnable {
long pollTimeoutMs = kafkaConsumer.getEndpoint().getConfiguration().getPollTimeoutMs();
Duration pollDuration = Duration.ofMillis(pollTimeoutMs);
-
+
if (LOG.isTraceEnabled()) {
LOG.trace("Polling {} from {} with timeout: {}", threadId, getPrintableTopic(), pollTimeoutMs);
}
@@ -333,8 +333,8 @@ public class KafkaFetchRecords implements Runnable {
ProcessingResult result = recordProcessorFacade.processPolledRecords(allRecords);
updateTaskState();
-
- // when breakOnFirstError we want to unsubscribe from Kafka
+
+ // when breakOnFirstError we want to unsubscribe from Kafka
if (result != null && result.isBreakOnErrorHit() && !this.state.equals(State.PAUSED)) {
LOG.debug("We hit an error ... setting flags to force reconnect");
// force re-connect
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessorFacade.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessorFacade.java
index 470e2ea01e6..8965a1037c4 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessorFacade.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessorFacade.java
@@ -83,7 +83,8 @@ public class KafkaRecordProcessorFacade {
result = processRecord(partition, partitionIterator.hasNext(), recordIterator.hasNext(),
kafkaRecordProcessor, consumerRecord);
- LOG.debug("Processed record on partition {} with offset {}", consumerRecord.partition(), consumerRecord.offset());
+ LOG.debug("Processed record on partition {} with offset {}", consumerRecord.partition(),
+ consumerRecord.offset());
if (consumerListener != null) {
if (!consumerListener.afterProcess(result)) {
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ProcessingResult.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ProcessingResult.java
index 87f88c6e23d..1728616cf9e 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ProcessingResult.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/ProcessingResult.java
@@ -17,7 +17,6 @@
package org.apache.camel.component.kafka.consumer.support;
-
public final class ProcessingResult {
private static final ProcessingResult UNPROCESSED_RESULT
= new ProcessingResult(false, false);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
index bc3ad03f37e..4d1d355e935 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT.java
@@ -48,8 +48,8 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch_64", "s390x" },
- disabledReason = "This test does not run reliably on ppc64le")
+ architectures = { "amd64", "aarch_64", "s390x" },
+ disabledReason = "This test does not run reliably on ppc64le")
class KafkaBreakOnFirstErrorOffUsingKafkaManualCommitIT extends BaseEmbeddedKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorOff";
public static final String TOPIC = "breakOnFirstErrorOff";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
index 7f401847667..9025cea92a0 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReplayOldMessagesIT.java
@@ -55,8 +55,8 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch_64", "s390x" },
- disabledReason = "This test does not run reliably on ppc64le")
+ architectures = { "amd64", "aarch_64", "s390x" },
+ disabledReason = "This test does not run reliably on ppc64le")
class KafkaBreakOnFirstErrorReplayOldMessagesIT extends BaseEmbeddedKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstError-20044";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
index 6a0069201aa..f59cbefb485 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorSeekIssueIT.java
@@ -52,8 +52,8 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch_64", "s390x" },
- disabledReason = "This test does not run reliably on ppc64le")
+ architectures = { "amd64", "aarch_64", "s390x" },
+ disabledReason = "This test does not run reliably on ppc64le")
class KafkaBreakOnFirstErrorSeekIssueIT extends BaseEmbeddedKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstError-19894";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java
index c02b3524a0f..f0842dac801 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT.java
@@ -48,8 +48,8 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch_64", "s390x" },
- disabledReason = "This test does not run reliably on ppc64le")
+ architectures = { "amd64", "aarch_64", "s390x" },
+ disabledReason = "This test does not run reliably on ppc64le")
class KafkaBreakOnFirstErrorWithBatchUsingAsynchCommitManagerIT extends BaseEmbeddedKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorBatchIT";
public static final String TOPIC = "breakOnFirstErrorBatchIT";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
index b0e719751a2..9c8bbe3f503 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT.java
@@ -48,8 +48,8 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch_64", "s390x" },
- disabledReason = "This test does not run reliably on ppc64le")
+ architectures = { "amd64", "aarch_64", "s390x" },
+ disabledReason = "This test does not run reliably on ppc64le")
class KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitIT extends BaseEmbeddedKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorBatchOnExceptionIT";
public static final String TOPIC = "breakOnFirstErrorBatchOnExceptionIT";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
index 504a34feb13..e0640c82757 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT.java
@@ -52,8 +52,8 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch_64", "s390x" },
- disabledReason = "This test does not run reliably on ppc64le")
+ architectures = { "amd64", "aarch_64", "s390x" },
+ disabledReason = "This test does not run reliably on ppc64le")
class KafkaBreakOnFirstErrorWithBatchUsingKafkaManualCommitRetryIT extends BaseEmbeddedKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorBatchRetryIT";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSynchCommitManagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSynchCommitManagerIT.java
index f025d3b9917..e944fdfaa19 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSynchCommitManagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSynchCommitManagerIT.java
@@ -48,8 +48,8 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
*/
@Tags({ @Tag("breakOnFirstError") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch_64", "s390x" },
- disabledReason = "This test does not run reliably on ppc64le")
+ architectures = { "amd64", "aarch_64", "s390x" },
+ disabledReason = "This test does not run reliably on ppc64le")
class KafkaBreakOnFirstErrorWithBatchUsingSynchCommitManagerIT extends BaseEmbeddedKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstErrorBatchIT";
public static final String TOPIC = "breakOnFirstErrorBatchIT";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java
index 73b95b0eb07..b1c2a787da7 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerHealthCheckIT.java
@@ -59,8 +59,8 @@ import static org.testcontainers.shaded.org.awaitility.Awaitility.await;
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@Tags({ @Tag("health") })
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
- architectures = { "amd64", "aarch_64", "s390x" },
- disabledReason = "This test does not run reliably on ppc64le")
+ architectures = { "amd64", "aarch_64", "s390x" },
+ disabledReason = "This test does not run reliably on ppc64le")
public class KafkaConsumerHealthCheckIT extends KafkaHealthCheckTestSupport {
public static final String TOPIC = "test-health";
public static final String SKIPPED_HEADER_KEY = "CamelSkippedHeader";