Reads messages from a topic

Deletes old messages

Writes messages to a topic

Balances partitions

Writes data to topics

Reads data from topics

Creates partitions

Manages brokers

A consumer group leader

A server that stores topic data

A producer that sends messages

A partitioning algorithm

1

3

6

9

No acknowledgments are needed

Only the leader must acknowledge

All in-sync replicas must acknowledge

The consumer must acknowledge

The maximum size of a topic

The maximum number of records per partition

The maximum amount of data (in bytes) that can be batched before sending to a broker

The number of retries before failure

The delay before retrying a failed request

The delay before sending a batch, allowing more records to accumulate

The maximum time a consumer waits for data

The time Kafka keeps messages before deletion

Restart the consumer after each poll

Manually commit offsets in code

Set auto.offset.reset=latest

Increase batch.size

Round Robin Assignment

Range Assignment

Sticky Assignor

Hash Partitioning

Start reading from the latest messages only

Start reading from the beginning of the partition if no valid offset is found

Discard all records and start fresh

Throw an error if no offset exists

To stream real-time credit card transactions for fraud detection

To store scanned copies of customer IDs in PDF format

To send monthly account statements via email

To keep historical loan records in cold storage