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 <angusyo...@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();