kafka-grpc Binding

The grpc request message is received from a requests topic, with a zilla:correlation-id header, initiating a grpc service method invocation. When the grpc response received, a response message is produced to the responses topic, with the same zilla:correlation-id header to correlate the response.

Note that grpc requests and responses can be unary or streaming.

remote_server

Full config

The remote_server kind kafka-grpc binding adapts kafka topic streams to grpc request-response streams.

kafka_grpc_proxy:
  type: kafka-grpc
  kind: remote_server
  entry: kafka_cache_client
  options:
    acks: leader_only
    idempotency:
      metadata: idempotency-key
    correlation:
      headers:
        service: zilla:service
        method: zilla:method
        correlation-id: zilla:correlation-id
        reply-to: zilla:reply-to
  routes:
    - when:
        - topic: requests
          reply-to: responses
          method: example.EchoService/*
      exit: grpc
      with:
        scheme: http
        authority: localhost:7151