---
apiVersion: v1
kind: ConfigMap
metadata:
  labels:
    funktion.fabric8.io/kind: Connector
  name: k8kafka
data:
  deployment.yml: |
    ---
    apiVersion: extensions/v1beta1
    kind: Deployment
    metadata:
      labels:
        funktion.fabric8.io/kind: Subscription
        connector: k8kafka
    spec:
      replicas: 1
      template:
        metadata:
          labels:
            funktion.fabric8.io/kind: Subscription
            connector: k8kafka
        spec:
          containers:
          - image: funktion/connector-k8kafka:${project.version}
            name: connector
  schema.yml: |
    ---
    component:
      kind: component
      scheme: k8kafka
      syntax: k8kafka:<topic>
      title: k8Kafka
      description: The k8kafka component allows messages to be sent to (or consumed from) Apache Kafka brokers.
      label: messaging
      deprecated: false
      async: false
      javaType: io.fabric8.funktion.camel.components.k8kafka.K8KafkaComponent
      groupId: io.fabric8.funktion.camel-k8
      artifactId: k8kafka
      version: 1.0-SNAPSHOT
    componentProperties:
      workerPool:
        kind: property
        type: object
        javaType: java.util.concurrent.ExecutorService
        deprecated: false
        secret: false
        order: 0
    properties:
      brokers:
        kind: path
        group: common
        required: true
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 0
      clientId:
        kind: parameter
        group: common
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 1
      groupId:
        kind: parameter
        group: common
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 2
      partitioner:
        kind: parameter
        group: common
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: org.apache.kafka.clients.producer.internals.DefaultPartitioner
        order: 3
      topic:
        kind: parameter
        group: common
        required: true
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 4
      autoCommitEnable:
        kind: parameter
        group: consumer
        label: consumer
        type: boolean
        javaType: java.lang.Boolean
        deprecated: false
        secret: false
        defaultValue: true
        order: 5
      autoCommitIntervalMs:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "5000"
        order: 6
      autoOffsetReset:
        kind: parameter
        group: consumer
        label: consumer
        type: string
        javaType: java.lang.String
        enum:
        - latest
        - earliest
        - none
        deprecated: false
        secret: false
        defaultValue: latest
        order: 7
      bridgeErrorHandler:
        kind: parameter
        group: consumer
        label: consumer
        type: boolean
        javaType: boolean
        optionalPrefix: consumer.
        deprecated: false
        secret: false
        defaultValue: false
        description: Allows for bridging the consumer to the Camel routing Error Handler which mean any exceptions occurred while the consumer is trying to pickup incoming messages or the likes will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions that will be logged at WARN/ERROR level and ignored.
        order: 8
      checkCrcs:
        kind: parameter
        group: consumer
        label: consumer
        type: boolean
        javaType: java.lang.Boolean
        deprecated: false
        secret: false
        defaultValue: true
        order: 9
      consumerId:
        kind: parameter
        group: consumer
        label: consumer
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 10
      consumerRequestTimeoutMs:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "40000"
        order: 11
      consumersCount:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: int
        deprecated: false
        secret: false
        defaultValue: "1"
        order: 12
      consumerStreams:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: int
        deprecated: false
        secret: false
        defaultValue: "10"
        order: 13
      fetchMinBytes:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "1024"
        order: 14
      fetchWaitMaxMs:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "500"
        order: 15
      heartbeatIntervalMs:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "3000"
        order: 16
      keyDeserializer:
        kind: parameter
        group: consumer
        label: consumer
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: org.apache.kafka.common.serialization.StringDeserializer
        order: 17
      maxPartitionFetchBytes:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "1048576"
        order: 18
      maxPollRecords:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "2147483647"
        order: 19
      partitionAssignor:
        kind: parameter
        group: consumer
        label: consumer
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: org.apache.kafka.clients.consumer.RangeAssignor
        order: 20
      pollTimeoutMs:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Long
        deprecated: false
        secret: false
        defaultValue: "5000"
        order: 21
      seekToBeginning:
        kind: parameter
        group: consumer
        label: consumer
        type: boolean
        javaType: boolean
        deprecated: false
        secret: false
        defaultValue: false
        order: 22
      sessionTimeoutMs:
        kind: parameter
        group: consumer
        label: consumer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "30000"
        order: 23
      valueDeserializer:
        kind: parameter
        group: consumer
        label: consumer
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: org.apache.kafka.common.serialization.StringDeserializer
        order: 24
      exceptionHandler:
        kind: parameter
        group: consumer (advanced)
        label: consumer,advanced
        type: object
        javaType: org.apache.camel.spi.ExceptionHandler
        optionalPrefix: consumer.
        deprecated: false
        secret: false
        description: To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this options is not in use. By default the consumer will deal with exceptions that will be logged at WARN/ERROR level and ignored.
        order: 25
      exchangePattern:
        kind: parameter
        group: consumer (advanced)
        label: consumer,advanced
        type: string
        javaType: org.apache.camel.ExchangePattern
        enum:
        - InOnly
        - RobustInOnly
        - InOut
        - InOptionalOut
        - OutOnly
        - RobustOutOnly
        - OutIn
        - OutOptionalIn
        deprecated: false
        secret: false
        description: Sets the exchange pattern when the consumer creates an exchange.
        order: 26
      bridgeEndpoint:
        kind: parameter
        group: producer
        label: producer
        type: boolean
        javaType: boolean
        deprecated: false
        secret: false
        defaultValue: false
        order: 27
      bufferMemorySize:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "33554432"
        order: 28
      compressionCodec:
        kind: parameter
        group: producer
        label: producer
        type: string
        javaType: java.lang.String
        enum:
        - none
        - gzip
        - snappy
        - lz4
        deprecated: false
        secret: false
        defaultValue: none
        order: 29
      connectionMaxIdleMs:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "540000"
        order: 30
      keySerializerClass:
        kind: parameter
        group: producer
        label: producer
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 31
      lingerMs:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "0"
        order: 32
      maxBlockMs:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "60000"
        order: 33
      maxInFlightRequest:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "5"
        order: 34
      maxRequestSize:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "1048576"
        order: 35
      metadataMaxAgeMs:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "300000"
        order: 36
      metricReporters:
        kind: parameter
        group: producer
        label: producer
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 37
      metricsSampleWindowMs:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "30000"
        order: 38
      noOfMetricsSample:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "2"
        order: 39
      producerBatchSize:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "16384"
        order: 40
      queueBufferingMaxMessages:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "10000"
        order: 41
      receiveBufferBytes:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "32768"
        order: 42
      reconnectBackoffMs:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "50"
        order: 43
      recordMetadata:
        kind: parameter
        group: producer
        label: producer
        type: boolean
        javaType: boolean
        deprecated: false
        secret: false
        defaultValue: true
        order: 44
      requestRequiredAcks:
        kind: parameter
        group: producer
        label: producer
        type: string
        javaType: java.lang.String
        enum:
        - -1
        - "0"
        - "1"
        - all
        deprecated: false
        secret: false
        defaultValue: "1"
        order: 45
      requestTimeoutMs:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "30000"
        order: 46
      retries:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "0"
        order: 47
      retryBackoffMs:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "100"
        order: 48
      sendBufferBytes:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "131072"
        order: 49
      serializerClass:
        kind: parameter
        group: producer
        label: producer
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 50
      workerPool:
        kind: parameter
        group: producer
        label: producer
        type: object
        javaType: java.util.concurrent.ExecutorService
        deprecated: false
        secret: false
        order: 51
      workerPoolCoreSize:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "10"
        order: 52
      workerPoolMaxSize:
        kind: parameter
        group: producer
        label: producer
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "20"
        order: 53
      synchronous:
        kind: parameter
        group: advanced
        label: advanced
        type: boolean
        javaType: boolean
        deprecated: false
        secret: false
        defaultValue: false
        description: Sets whether synchronous processing should be strictly used or Camel is allowed to use asynchronous processing (if supported).
        order: 54
      kerberosBeforeReloginMinTime:
        kind: parameter
        group: security
        label: common,security
        type: integer
        javaType: java.lang.Integer
        deprecated: false
        secret: false
        defaultValue: "60000"
        order: 55
      kerberosInitCmd:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: /usr/bin/kinit
        order: 56
      kerberosPrincipalToLocalRules:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: DEFAULT
        order: 57
      kerberosRenewJitter:
        kind: parameter
        group: security
        label: common,security
        type: number
        javaType: java.lang.Double
        deprecated: false
        secret: false
        defaultValue: "0.05"
        order: 58
      kerberosRenewWindowFactor:
        kind: parameter
        group: security
        label: common,security
        type: number
        javaType: java.lang.Double
        deprecated: false
        secret: false
        defaultValue: "0.8"
        order: 59
      saslKerberosServiceName:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 60
      saslMechanism:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: GSSAPI
        order: 61
      securityProtocol:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: PLAINTEXT
        order: 62
      sslCipherSuites:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 63
      sslEnabledProtocols:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: TLSv1.2,TLSv1.1,TLSv1
        order: 64
      sslEndpointAlgorithm:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 65
      sslKeymanagerAlgorithm:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: SunX509
        order: 66
      sslKeyPassword:
        kind: parameter
        group: security
        label: producer,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 67
      sslKeystoreLocation:
        kind: parameter
        group: security
        label: producer,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 68
      sslKeystorePassword:
        kind: parameter
        group: security
        label: producer,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 69
      sslKeystoreType:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: JKS
        order: 70
      sslProtocol:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: TLS
        order: 71
      sslProvider:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 72
      sslTrustmanagerAlgorithm:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: PKIX
        order: 73
      port:
        kind: parameter
        group: port
        label: port
        type: integer
        javaType: int
        deprecated: false
        secret: false
        defaultValue: "9092"
        order: 74
      sslTruststoreLocation:
        kind: parameter
        group: security
        label: producer,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 75
      sslTruststorePassword:
        kind: parameter
        group: security
        label: producer,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        order: 76
      sslTruststoreType:
        kind: parameter
        group: security
        label: common,security
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: JKS
        order: 77
      serviceName:
        kind: parameter
        group: serviceName
        label: serviceName
        type: string
        javaType: java.lang.String
        deprecated: false
        secret: false
        defaultValue: kafka
        order: 78
