Skip to content
This repository has been archived by the owner on Oct 23, 2023. It is now read-only.

Commit

Permalink
Fix TOC and typo.
Browse files Browse the repository at this point in the history
  • Loading branch information
aquamatthias committed Dec 21, 2017
1 parent e3f58e3 commit 4bf9b84
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down Expand Up @@ -303,7 +305,7 @@ The client will handle checkpointing asynchronously PER SHARD according to the c
<a name="akka-stream-source"></a>
### 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`
Expand Down

0 comments on commit 4bf9b84

Please sign in to comment.