grpc/src/main/resources/reference.conf

# SPDX-License-Identifier: Apache-2.0

pekko.projection.grpc {
  consumer {
    class = "org.apache.pekko.projection.grpc.consumer.GrpcReadJournalProvider"

    # Note: these settings are only applied when constructing the consumer from config
    #       if creating the GrpcQuerySettings programmatically these settings are ignored

    # Configuration of gRPC client.
    # See https://pekko.apache.org/docs/pekko-grpc/current/client/configuration.html#by-configuration
    client = ${pekko.grpc.client."*"}
    client {
    }

    # Mandatory field identifying the stream to consume/type of entity, must be a stream id
    # exposed by the producing/publishing side
    stream-id = ""

    # Pass these additional request headers as string values in each request to the producer
    # can be used for example for authorization in combination with an interceptor in the producer.
    # Example "x-auth-header": "secret"
    additional-request-headers {}

    filter {
      ddata-read-timeout = 3s
      ddata-write-timeout = 3s
    }
  }

  producer {
    # Query plugin for eventsBySlices, such as "pekko.persistence.r2dbc.query".
    query-plugin-id = ""

    # When using async transformations it can be good to increase this.
    transformation-parallelism = 1

    filter {
      replay-parallelism = 3
    }

  }


}

pekko {
  actor {
    serializers {
      pekko-projection-grpc-consumer = "org.apache.pekko.projection.grpc.internal.ConsumerSerializer"
    }
    serialization-identifiers {
      "org.apache.pekko.projection.grpc.internal.ConsumerSerializer" = 1558148901
    }
    serialization-bindings {
      "org.apache.pekko.projection.grpc.internal.DdataConsumerFilterStore$State" = pekko-projection-grpc-consumer
      "org.apache.pekko.projection.grpc.internal.DdataConsumerFilterStore$ConsumerFilterKey" = pekko-projection-grpc-consumer
    }
  }
}