Kafka

Install

go get github.com/aacfactory/fns-contrib/message-queues/kafka

Usage

app.Deploy(kafka.Service())

Config

rabbitmq:
  brokers: 
    - "192.168.0.1:9093"
  options:
    saslType: "plain"
    username: "user"
    password: "pass"
    clientId: "clientId"
    clientTLS:
      ca: "path of ca.pem"
      cert: "path of cert.pem"
      key: "path of key.pem"
  producers:
    topicA:
      compression: "snappy"
      balancer: "round_robin"
      requiredAck: "one"
      batchSize: 100
      async: false
  consumers:
    topicB:
      handler: "default"
      groupId: ""
      autoCommit: false

Use user consumer handler

consumers:
  bar:
    handler: user_consumer
    handlerOptions:
      userId: "userId"

As proxy

published, publishErr := kafka.Publish(ctx, kafka.PublishArgument{
	Topic: "topicB"
	Key: "foo", 
	Body: json.RawMessage([]byte("{}"))
})