You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: README.md
+4-9Lines changed: 4 additions & 9 deletions
Original file line number
Diff line number
Diff line change
@@ -18,7 +18,8 @@ and [Pekko HTTP](https://pekko.apache.org/docs/pekko-http/current/) tutorials, b
18
18
>
19
19
> For now the branch <ahref="https://github.com/pbernet/akka_streams_tutorial/tree/migrate_pekko">migrate_pekko</a>
20
20
> contains the migration (with a few losses). Currently, this is the only maintained branch.
21
-
> The plan is to move the content of this branch to a new `pekko_tutorial` repo and support Scala 3.
21
+
> The plan is to move the content of this branch to a new `pekko_tutorial` repo and to support Scala 3 when Pekko
22
+
> Connectors is ready.
22
23
23
24
## Project Description
24
25
@@ -154,7 +155,6 @@ Start the classes in the order below and watch the console output.
154
155
|[WordCountProducer](src/main/scala/alpakka/kafka/WordCountProducer.scala)|[pekko-streams-kafka](https://pekko.apache.org/docs/pekko-connectors-kafka/current/"Doc") client which feeds random words to topic `wordcount-input`|
155
156
|[WordCountKStreams.java](src/main/scala/alpakka/kafka/WordCountKStreams.java)|[Kafka Streams DSL](https://kafka.apache.org/documentation/streams"Doc") client to count words and messages and feed the results to `wordcount-output` and `messagecount-output` topics. Contains additional interactive queries which should yield the same results `WordCountConsumer`|
156
157
|[WordCountConsumer](src/main/scala/alpakka/kafka/WordCountConsumer.scala)|[pekko-streams-kafka](https://pekko.apache.org/docs/pekko-connectors-kafka/current/"Doc") client which consumes aggregated results from topic `wordcount-output` and `messagecount-output`|
157
-
|[DeleteTopicUtil](src/main/scala/alpakka/kafka/DeleteTopicUtil.scala)| Utility to reset the offset |
158
158
159
159
## HL7 V2 over TCP via Kafka to Websockets ##
160
160
@@ -183,15 +183,10 @@ The index is queried periodically and the content may also be viewed with a Brow
0 commit comments