telegram/telegram-sink/config/openshift/telegram-sink.yaml (17 lines of code) (raw):
apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaConnector
metadata:
name: telegram-sink-connector
namespace: myproject
labels:
strimzi.io/cluster: my-connect-cluster
spec:
class: org.apache.camel.kafkaconnector.telegram.CamelTelegramSinkConnector
tasksMax: 1
config:
key.converter: org.apache.kafka.connect.storage.StringConverter
value.converter: org.apache.kafka.connect.storage.StringConverter
topics: telegram-topic
camel.sink.path.type: bots
camel.sink.endpoint.chatId: <group_chat_id>
camel.sink.endpoint.authorizationToken: ${file:/opt/kafka/external-configuration/telegram-token/telegram-token.properties:auth_token}