NATS JetStream sarama implementation (EXPERIMENTAL) NATS JetStream implementation of sarama.Producer and sarama.SyncConsumer