This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 7d40b297a Update ElasticsearchV5Spec.scala (#1830)
7d40b297a is described below
commit 7d40b297af31137fc5a9ea2b818f5abfdf0e4bee
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Aug 10 17:44:07 2026 +0100
Update ElasticsearchV5Spec.scala (#1830)
---
.../src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala | 10 +++-------
1 file changed, 3 insertions(+), 7 deletions(-)
diff --git
a/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala
b/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala
index 1b17aff40..8e92a0b9f 100644
--- a/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala
+++ b/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchV5Spec.scala
@@ -219,7 +219,6 @@ class ElasticsearchV5Spec extends ElasticsearchSpecBase
with ElasticsearchSpecUt
.runWith(Sink.ignore)
kafkaToEs.futureValue shouldBe Done
- // #kafka-example
flushAndRefresh(connectionSettings, indexName)
// Make sure all messages was committed to kafka
@@ -234,7 +233,7 @@ class ElasticsearchV5Spec extends ElasticsearchSpecBase
with ElasticsearchSpecUt
// #kafka-example
// We're going to pretend we got messages from kafka.
- // After we've written them to Elastic, we want
+ // After we've written them to Elastic in bulk, we want
// to commit the offset to Kafka
case class KafkaOffset(offset: Int)
@@ -272,7 +271,6 @@ class ElasticsearchV5Spec extends ElasticsearchSpecBase
with ElasticsearchSpecUt
.runWith(Sink.ignore)
kafkaToEs.futureValue shouldBe Done
- // #kafka-example
flushAndRefresh(connectionSettings, indexName)
// Make sure all messages was committed to kafka
@@ -287,7 +285,7 @@ class ElasticsearchV5Spec extends ElasticsearchSpecBase
with ElasticsearchSpecUt
// #kafka-example
// We're going to pretend we got messages from kafka.
- // After we've written them to Elastic, we want
+ // Of those, only some will be written to Elastic, we want
// to commit the offset to Kafka
case class KafkaOffset(offset: Int)
@@ -330,7 +328,6 @@ class ElasticsearchV5Spec extends ElasticsearchSpecBase
with ElasticsearchSpecUt
.runWith(Sink.ignore)
kafkaToEs.futureValue shouldBe Done
- // #kafka-example
flushAndRefresh(connectionSettings, indexName)
// Make sure all messages was committed to kafka
@@ -346,7 +343,7 @@ class ElasticsearchV5Spec extends ElasticsearchSpecBase
with ElasticsearchSpecUt
// #kafka-example
// We're going to pretend we got messages from kafka.
- // After we've written them to Elastic, we want
+ // After we skip all NOP docs, we want
// to commit the offset to Kafka
case class KafkaOffset(offset: Int)
@@ -388,7 +385,6 @@ class ElasticsearchV5Spec extends ElasticsearchSpecBase
with ElasticsearchSpecUt
.runWith(Sink.ignore)
kafkaToEs.futureValue shouldBe Done
- // #kafka-example
flushAndRefresh(connectionSettings, indexName)
// Make sure all messages was committed to kafka
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
