PubSub One Currently support Kafka (using sarama) RabbitMQ (using rabbitmq/amqp091-go) See example Reference See how to consume rabbitmq concurrently here.