Kafka - распределенная потоковая платформа: хранит сообщения в топиках разбитых на партиции, обеспечивает персистентность, масштабирование и повторное чтение. Производители пишут в топики, потребители читают из партиций (consumer groups). Используют для логов, событий, стриминга, очередей. В Go популярны библиотеки: confluent-kafka-go, segmentio/kafka-go, sarama.
conn, _ := kafka.DialLeader(ctx, "tcp", "localhost:9092", "topic", 0)
conn.WriteMessages(kafka.Message{Value: []byte("hello")})