This is an automated email from the ASF dual-hosted git repository. fanningpj pushed a commit to branch wip-seglo-kafka-sharding in repository https://gitbox.apache.org/repos/asf/incubator-pekko-samples.git
commit 687eb63340b7569b19be80d8890af8995e268228 Author: Sean Glover <[email protected]> AuthorDate: Wed Feb 19 12:14:29 2020 -0500 Typos --- akka-sample-kafka-to-sharding-scala/README.md | 4 ++-- .../processor/src/main/resources/application.conf | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-sample-kafka-to-sharding-scala/README.md b/akka-sample-kafka-to-sharding-scala/README.md index 4913792..fbbaf7d 100644 --- a/akka-sample-kafka-to-sharding-scala/README.md +++ b/akka-sample-kafka-to-sharding-scala/README.md @@ -32,9 +32,9 @@ The sample is made up of three applications: * `client` A gRPC client for interacting with the cluster * `kafka` A local Kafka server -The sample demonstrates how the external shard allocation strategy can used so messages are processed locally. +The sample demonstrates how the external shard allocation strategy can be used so messages are processed locally. -The sample depends on a Kafka broker running locally on port `9092` with a topic with 128 partitions called `user-events.` +The sample depends on a Kafka broker running locally on port `9092` with a topic with 128 partitions called `user-events`. [Kafka can be run in Docker](https://github.com/wurstmeister/kafka-docker) or run locally using the optional `kafka` project. * Run the local Kafka server. This project will also create the `user-events` topic. diff --git a/akka-sample-kafka-to-sharding-scala/processor/src/main/resources/application.conf b/akka-sample-kafka-to-sharding-scala/processor/src/main/resources/application.conf index ef7e721..18a2c14 100644 --- a/akka-sample-kafka-to-sharding-scala/processor/src/main/resources/application.conf +++ b/akka-sample-kafka-to-sharding-scala/processor/src/main/resources/application.conf @@ -1,7 +1,7 @@ kafka-to-sharding-processor { bootstrap-servers = "localhost:9092" topics = ["user-events"] - group = "group-1" + group = "user-processing" } akka.http { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
