You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2023/06/07 20:20:51 UTC
[incubator-pekko-connectors-kafka] branch main updated: fully qualify the package name (#86)
This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new ec306c46 fully qualify the package name (#86)
ec306c46 is described below
commit ec306c46774545d656b3f1b8e25e54de7d8e8289
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Wed Jun 7 21:20:45 2023 +0100
fully qualify the package name (#86)
---
.../src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala | 4 ++--
core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala | 8 ++++----
core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala | 8 ++++----
3 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala b/core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala
index d1c75b9d..7a5dfd71 100644
--- a/core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala
+++ b/core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala
@@ -121,7 +121,7 @@ object CommitterSettings {
* Create settings from the default configuration
* `pekko.kafka.committer`.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def apply(actorSystem: pekko.actor.ClassicActorSystemProvider): CommitterSettings =
apply(actorSystem.classicSystem.settings.config.getConfig(configPath))
@@ -150,7 +150,7 @@ object CommitterSettings {
* Java API: Create settings from the default configuration
* `pekko.kafka.committer`.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def create(actorSystem: pekko.actor.ClassicActorSystemProvider): CommitterSettings =
apply(actorSystem)
diff --git a/core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala b/core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala
index c6842b7c..8cc948a6 100644
--- a/core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala
+++ b/core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala
@@ -53,7 +53,7 @@ object ConsumerSettings {
* `pekko.kafka.consumer`.
* Key or value deserializer can be passed explicitly or retrieved from configuration.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def apply[K, V](
system: pekko.actor.ClassicActorSystemProvider,
@@ -137,7 +137,7 @@ object ConsumerSettings {
* `pekko.kafka.consumer`.
* Key and value serializer must be passed explicitly.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def apply[K, V](
system: pekko.actor.ClassicActorSystemProvider,
@@ -172,7 +172,7 @@ object ConsumerSettings {
* `pekko.kafka.consumer`.
* Key or value deserializer can be passed explicitly or retrieved from configuration.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def create[K, V](
system: pekko.actor.ClassicActorSystemProvider,
@@ -207,7 +207,7 @@ object ConsumerSettings {
* `pekko.kafka.consumer`.
* Key and value serializer must be passed explicitly.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def create[K, V](
system: pekko.actor.ClassicActorSystemProvider,
diff --git a/core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala b/core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala
index 75a48c4c..2a1e8e94 100644
--- a/core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala
+++ b/core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala
@@ -52,7 +52,7 @@ object ProducerSettings {
* `pekko.kafka.producer`.
* Key or value serializer can be passed explicitly or retrieved from configuration.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def apply[K, V](
system: org.apache.pekko.actor.ClassicActorSystemProvider,
@@ -112,7 +112,7 @@ object ProducerSettings {
* `pekko.kafka.producer`.
* Key and value serializer must be passed explicitly.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def apply[K, V](
system: org.apache.pekko.actor.ClassicActorSystemProvider,
@@ -147,7 +147,7 @@ object ProducerSettings {
* `pekko.kafka.producer`.
* Key or value serializer can be passed explicitly or retrieved from configuration.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def create[K, V](
system: org.apache.pekko.actor.ClassicActorSystemProvider,
@@ -182,7 +182,7 @@ object ProducerSettings {
* `pekko.kafka.producer`.
* Key and value serializer must be passed explicitly.
*
- * For use with the `pekko.actor.typed` API.
+ * For use with the `org.apache.pekko.actor.typed` API.
*/
def create[K, V](
system: org.apache.pekko.actor.ClassicActorSystemProvider,
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org