values.yaml

# This component is licensed for OpenFaaS Standard/Enterprise customers only.
# Purchase or obtain a trial license at https://openfaas.com/pricing/

# You will need to create a license named "openfaas-license" - see the
# chart README for detailed instructions.


# Set either a single topic, or multiple with a comma separating each
# topics: payment.requested
# topics: "payment.requested,customer.created,invoice.generated"
topics: faas-request

# The address of the Kafka broker, if multiple are available, include
# them as a comma separated list i.e. "kafka-1:9092,kafka-2:9092,kafka-3:9092"
brokerHosts: kf-kafka:9092

image: ghcr.io/openfaasltd/kafka-connector:0.7.10

# Output detailed logs from the consumer group's lifecycle
sessionLogging: true

# The number of replicas of the connector should usually match the size of the
# partition exactly. So for a topic with 6 partitions, set the replicas to 6.
# This number must not be higher, but can be lower, to save on resources.
replicas: 1

# Max timeout for a function
upstreamTimeout: 2m

# interval for rebuilding the map of functions and topics
rebuildInterval: 30s

# Invoke functions asynchronously.
asyncInvocation: false

async:
  # Limit the number of inflight async invocations for the connector.
  # A value of 0 indicates no concurrency limit.
  maxInflight: 0

# 1MB = 1024 bytes * 1024
maxBytes: "1048576"

# HTTP content-type for invoking functions
contentType: text/plain

# Set the consumer group
group: faas-group-1

logs:
  # Log debug messages
  debug: false
  # Set the log format, supports console or json
  format: "console"

# Print the data read from the Kafka topic before invoking functions
printRequestBody: false

# Print the HTTP status of invoked functions
printResponse: true

# Print the data received from invoked functions
printResponseBody: false

# intialOffset for Kafka consumer
#
# "newest" stands for the log head offset, i.e. the offset that will be
# assigned to the next message that will be produced to the partition. You
# can send this to a client's GetOffset method to get this offset, or when
# calling ConsumePartition to start consuming new messages.
#
# "oldest" stands for the oldest offset available on the broker for a
# partition. You can send this to a client's GetOffset method to get this
# offset, or when calling ConsumePartition to start consuming from the
# oldest offset that is still available on the broker.
initialOffset: oldest

# Gateway URL to access API and for invocations
gatewayURL: http://gateway.openfaas:8080

# Basic auth for the gateway
basic_auth: true

# NATS is used for async invocations and is required when
# setting the 'async.maxInflight' parameter to a value other than 0.
nats:
  # Configure an externally-managed NATS server.
  # When disabled the OpenFaaS embedded nats deployment is used. 
  # These values should be identical to the configuration in your OpenFaaS deployment values.yaml file
  # when external nats is enabled.
  external:
    enabled: false
    host: ""
    port: ""

nodeSelector: {}

tolerations: []

affinity: {}

resources:
  requests:
    memory: "64Mi"
    cpu: "100m"
  # limits:
  #   memory: "256Mi"

# Use TLS Encryption, this is usually set to true.
tls: true

# Authentication

## When set to true, create secrets: "kafka-broker-username" and "kafka-broker-password"
saslAuth: false

# kubectl create secret generic \
# kafka-broker-username \
# -n openfaas \
# --from-file broker-username=./broker-username.txt

# kubectl create secret generic \
# kafka-broker-password \
# -n openfaas \
# --from-file broker-password=./broker-password.txt

brokerPasswordSecret: kafka-broker-password
brokerUsernameSecret: kafka-broker-username

## When using a custom CA:

# kubectl create secret generic \
# kafka-broker-ca \
# -n openfaas \
# --from-file broker-ca=./broker-ca.pem

# When using client certs

# kubectl create secret generic \
# kafka-broker-cert \
# -n openfaas \
# --from-file broker-cert=./broker-cert.txt

# kubectl create secret generic \
# kafka-broker-key \
# -n openfaas \
# --from-file broker-key=./broker-key.txt

# Set to empty to disable:

caSecret: ""
certSecret: ""
keySecret: ""
# Or give a name to each to enable

# caSecret: kafka-broker-ca
# certSecret: kafka-broker-cert
# keySecret: kafka-broker-key