Kafka

Install

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

Usage

app.Deploy(kafka.New(kafka.WithConsumeHandler(name, handleFn)))

Config

kafka:
  brokers: 
    - "192.168.0.1:9092"
  producers:
    enable: true
    num: 4
    partitioner:
      name: "round_robin"
  consumers:
    nameA:
      group: "groupId"
      topics:
        - "topicA"

As proxy

publishErr := kafka.Publish(ctx, kafka.NewMessage(topic, key, body))