[camel] branch main updated: CAMEL-19444: fixed a few grammar errors on code comments in camel-kafka

[or...@apache.org]

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


The following commit(s) were added to refs/heads/main by this push:
     new eb14362b281 CAMEL-19444: fixed a few grammar errors on code comments in camel-kafka
eb14362b281 is described below

commit eb14362b281e3d50c8e4290ef5e59f55336fbf63
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Jul 10 10:19:35 2023 +0200

    CAMEL-19444: fixed a few grammar errors on code comments in camel-kafka
---
 .../kafka/integration/commit/BaseManualCommitTestSupport.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/BaseManualCommitTestSupport.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/BaseManualCommitTestSupport.java
index 00870088828..ed662cec98b 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/BaseManualCommitTestSupport.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/BaseManualCommitTestSupport.java
@@ -69,7 +69,7 @@ abstract class BaseManualCommitTestSupport extends BaseEmbeddedKafkaTestSupport
         contextExtension.getContext().getRouteController().stopRoute("foo");
         to.expectedMessageCount(0);
 
-        // Third step: While our route is stopped, we send 3 records more to Kafka test topic
+        // Third step: While our route is stopped, we send 3 records more to a Kafka test topic
         sendRecords(5, 8, topic);
 
         to.assertIsSatisfied(3000);
@@ -77,7 +77,7 @@ abstract class BaseManualCommitTestSupport extends BaseEmbeddedKafkaTestSupport
         to.reset();
 
         // Fourth step: We start again our route, since we have been committing the offsets from the first step,
-        // we will expect to consume from the latest committed offset e.g from offset 5
+        // we will expect to consume from the latest committed offset (e.g.: from offset 5()
         contextExtension.getContext().getRouteController().startRoute("foo");
         setupPostExecutionExpectations();
 
@@ -103,7 +103,7 @@ abstract class BaseManualCommitTestSupport extends BaseEmbeddedKafkaTestSupport
         contextExtension.getContext().getRouteController().stopRoute("foo");
         to.expectedMessageCount(0);
 
-        // Third step: While our route is stopped, we send 3 records more to Kafka test topic
+        // Third step: While our route is stopped, we send 3 records more to a Kafka test topic
         sendRecords(5, 8, topic);
 
         to.assertIsSatisfied(3000);
@@ -111,7 +111,7 @@ abstract class BaseManualCommitTestSupport extends BaseEmbeddedKafkaTestSupport
         to.reset();
 
         // Fourth step: We start again our route, since we have been committing the offsets from the first step,
-        // we will expect to consume from the latest committed offset e.g from offset 5
+        // we will expect to consume from the latest committed offset (e.g.: from offset 5)
         contextExtension.getContext().getRouteController().startRoute("foo");
         setupPostExecutionExpectations();