This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new 0992115b fix: correct typos in kafka connector code and docs (#561)
0992115b is described below
commit 0992115b71c864d514b4825ab68ffa2cba29162b
Author: He-Pin(kerr) <[email protected]>
AuthorDate: Fri Jun 19 05:32:36 2026 +0800
fix: correct typos in kafka connector code and docs (#561)
Motivation:
Several typos were found in config files, source code, docs, and test
resources.
Modification:
- ammount→amount in reference.conf
- setttings→settings in ConsumerResetProtection.scala
- transacitonal→transactional in TransactionalProducerStage.scala and docs
- preceeding→preceding in CommitCollectorStageSpec.scala
- levle→level in logback-test.xml
Result:
Cleaner codebase with corrected spelling.
Tests:
Not run - typo fixes only (comments, strings, config, docs)
References:
None - typo cleanup
---
core/src/main/resources/reference.conf | 2 +-
.../org/apache/pekko/kafka/internal/ConsumerResetProtection.scala | 4 ++--
.../org/apache/pekko/kafka/internal/TransactionalProducerStage.scala | 2 +-
docs/src/main/paradox/transactions.md | 4 ++--
int-tests/src/test/resources/logback-test.xml | 2 +-
.../org/apache/pekko/kafka/internal/CommitCollectorStageSpec.scala | 2 +-
6 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/core/src/main/resources/reference.conf
b/core/src/main/resources/reference.conf
index 3beee771..ba42a51f 100644
--- a/core/src/main/resources/reference.conf
+++ b/core/src/main/resources/reference.conf
@@ -79,7 +79,7 @@ pekko.kafka.consumer {
# If offset commit requests are not completed within this timeout
# the returned Future is completed `CommitTimeoutException`.
- # The `Transactional.source` waits this ammount of time for the producer to
mark messages as not
+ # The `Transactional.source` waits this amount of time for the producer to
mark messages as not
# being in flight anymore as well as waiting for messages to drain, when
rebalance is triggered.
commit-timeout = 15s
diff --git
a/core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala
b/core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala
index 8387fa95..ec9f0236 100644
---
a/core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala
+++
b/core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala
@@ -46,9 +46,9 @@ sealed trait ConsumerResetProtection {
@InternalApi
object ConsumerResetProtection {
def apply[K, V](log: LoggingAdapter,
- setttings: OffsetResetProtectionSettings,
+ settings: OffsetResetProtectionSettings,
progress: () => ConsumerProgressTracking): ConsumerResetProtection = {
- if (setttings.enable) new Impl(log, setttings, progress()) else
ConsumerResetProtection.Noop
+ if (settings.enable) new Impl(log, settings, progress()) else
ConsumerResetProtection.Noop
}
private object Noop extends ConsumerResetProtection {
diff --git
a/core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalProducerStage.scala
b/core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalProducerStage.scala
index 6766beba..d41752f7 100644
---
a/core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalProducerStage.scala
+++
b/core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalProducerStage.scala
@@ -185,7 +185,7 @@ private final class TransactionalProducerStageLogic[K, V,
P](
/**
* When using partitioned sources we extract the transactional id, group id,
and topic partition information from
- * the first message in order to define a `transacitonal.id` before
constructing the [[org.apache.kafka.clients.producer.KafkaProducer]]
+ * the first message in order to define a `transactional.id` before
constructing the [[org.apache.kafka.clients.producer.KafkaProducer]]
*/
private def parseFirstMessage(msg: Envelope[K, V, P]): Boolean =
producerAssignmentLifecycle match {
diff --git a/docs/src/main/paradox/transactions.md
b/docs/src/main/paradox/transactions.md
index e1a3984b..91a76dcb 100644
--- a/docs/src/main/paradox/transactions.md
+++ b/docs/src/main/paradox/transactions.md
@@ -17,7 +17,7 @@ A consumer group ID must be provided.
Only use this source if you have the intention to connect it to a
@apidoc[Transactional.flow](Transactional$) or
@apidoc[Transactional.sink](Transactional$).
-<!-- TODO: uncomment when Transacitonal.partitionedSource is ready
+<!-- TODO: uncomment when Transactional.partitionedSource is ready
## Transactional Partitioned Source
The @apidoc[Transactional.partitionedSource](Transactional$) is similar to the
`Transactional.source`.
@@ -79,7 +79,7 @@ Java
: @@ snip
[snip](/java-tests/src/test/java/docs/javadsl/TransactionsExampleTest.java) {
#transactionalSink }
-<!-- TODO: uncomment when Transacitonal.partitionedSource is ready
+<!-- TODO: uncomment when Transactional.partitionedSource is ready
### Partitioned Source Example
Scala
diff --git a/int-tests/src/test/resources/logback-test.xml
b/int-tests/src/test/resources/logback-test.xml
index c71cf40d..173b8e78 100644
--- a/int-tests/src/test/resources/logback-test.xml
+++ b/int-tests/src/test/resources/logback-test.xml
@@ -27,7 +27,7 @@
<logger name="org.apache.pekko" level="DEBUG"/>
<logger name="org.apache.pekko.kafka" level="DEBUG"/>
<logger name="org.apache.pekko.kafka.test.testcontainers.logs"
level="INFO" />
- <logger name="docs.scaladsl" levle="DEBUG"/>
+ <logger name="docs.scaladsl" level="DEBUG"/>
<logger name="org.apache.zookeeper" level="WARN"/>
<logger name="org.I0Itec.zkclient" level="WARN"/>
diff --git
a/tests/src/test/scala/org/apache/pekko/kafka/internal/CommitCollectorStageSpec.scala
b/tests/src/test/scala/org/apache/pekko/kafka/internal/CommitCollectorStageSpec.scala
index bca4f25a..782a2344 100644
---
a/tests/src/test/scala/org/apache/pekko/kafka/internal/CommitCollectorStageSpec.scala
+++
b/tests/src/test/scala/org/apache/pekko/kafka/internal/CommitCollectorStageSpec.scala
@@ -234,7 +234,7 @@ class CommitCollectorStageSpec(_system: ActorSystem)
val commits = factory.committer.commits
- (commits.last._2 shouldBe 10).withClue("last offset commit should be
exactly the one preceeding the error")
+ (commits.last._2 shouldBe 10).withClue("last offset commit should be
exactly the one preceding the error")
control.shutdown().futureValue shouldBe Done
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
