Skip to content

Commit

Permalink
kafka partition scaling notes
Browse files Browse the repository at this point in the history
  • Loading branch information
morten-andersen committed Apr 7, 2024
1 parent 759645b commit 316f415
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion kafka/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,11 @@
##### Scaling Kafka / Number of Partitions (p.62)

```
# max processable messages per second equals number of partitions multiplied by messages processed per second in a consumer
total_number_messages_sec = partitions x number_messages_per_consumer_sec
number_messages_per_consumer_sec = 1000 ms / processing_time_per_message_sec
# if the avg processing time per message is known, the number of messages per second on one conumser is
number_messages_per_consumer_sec = 1000 ms / processing_time_per_message_ms
```

Example:
Expand Down

0 comments on commit 316f415

Please sign in to comment.