From 4bf9b84a93f2dea90f42c5c6739730c98e5d17ff Mon Sep 17 00:00:00 2001 From: Matthias Veit Date: Thu, 21 Dec 2017 17:38:31 +0100 Subject: [PATCH] Fix TOC and typo. --- README.md | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index f1b62a8..5ddb277 100644 --- a/README.md +++ b/README.md @@ -15,8 +15,10 @@ It's worth familiarising yourself with [Sequence numbers and Sub sequence number * [Notable Consumer Configuration Values](#usage-defining-a-config-file-in-the-client-application-notable-consumer-configuration-values) * [Notable Producer Configuration Values](#usage-defining-a-config-file-in-the-client-application-notable-producer-configuration-values) * [Usage: Consumer](#usage-usage-consumer) - * [Important considerations when implementing the Event Processor](#usage-usage-consumer-important-considerations-when-implementing-the-event-processor) - * [Checkpointing](#usage-usage-consumer-checkpointing) + * [Actor Based Consumer](#actor-based-consumer) + * [Important considerations when implementing the Event Processor](#usage-usage-consumer-important-considerations-when-implementing-the-event-processor) + * [Checkpointing](#usage-usage-consumer-checkpointing) + * [Akka Stream Source](#akka-stream-source) * [Graceful Shutdown](#usage-usage-consumer-graceful-shutdown) * [Usage: Producer](#usage-usage-producer) * [Actor Based Implementation](#usage-usage-producer-actor-based-implementation) @@ -303,7 +305,7 @@ The client will handle checkpointing asynchronously PER SHARD according to the c ### Akka Stream Source -An akka `Source` is provided that can be used with streams. It is possible to create a source from a `ConsumerConf` or +An Akka `Source` is provided that can be used with streams. It is possible to create a source from a `ConsumerConf` or directly from the consumer name that is defined in the configuration. Every message that is emitted to the stream is of type `CommitableEvent[ConsumerEvent]` and has to be committed explicitly downstream with a call to `event.commit()`. It is possible to map to a different type of `CommittableEvent`