import (
"context"
"fmt"
"sync"
conf "github.com/pip-services3-gox/pip-services3-commons-gox/config"
kafkaqueue "github.com/pip-services3-gox/pip-services3-kafka-gox/queues"
)
ctx := context.Background()
queue := kafkaqueue.NewKafkaMessageQueue()
queue.Configure(ctx, conf.NewConfigParamsFromTuples(
"topic", "mytopic",
"connection.protocol", "tcp",
"connection.host", "localhost",
"connection.port", 9092,
"options.autosubscribe", true,
))
queue.Open(ctx, "123")