Можете объяснить, как реализована система очередей событий в Kafka?