To read messages from a topic, you need to run a consumer. As with the producer, the consumer will automatically select the broker to read from and will recover in case of failure.

The consumer reads the messages from all partitions. Within a partition, it is guaranteed to receive messages in the same order as they were produced.