Connect - Connector

Question 1

Connect: labels or annotations

Answer 1

annotation

Question 2

Connector: labels or annotations

Answer 2

labels

Question 3

Debezium: label or annotation

Answer 3

labels

Question 4

Transformation: labels or annotation

Answer 4

labels

Question 5

Connect annotations

Answer 5

annotations:
___strimzi.io/use-connector-resources: ‘true’

Question 6

Connect abbreviation

Answer 6

bbc virtual reality

Question 7

Expand bbc virtual reality

Answer 7

Elements of connect spec:

build
bootstrapServer
config
version
replicas

Question 8

Connect’s build element

Answer 8

build:
___output:
____ image: ‘quay.io/USERNAME/filewatch-:latest’
____ pushSecret: filewatch-connect-push-secret
____ type: docker
___plugins:
____ - artifacts:
_____ - type: tgz
_____ url: https://repo1.maven.org/maven2/or.gz
____ name: filewatch-source-connector

Question 9

Connect config

Answer 9

config. storage.topic: filewatch-connect-cluster-configs
offset. storage.topic: filewatch-connect-cluster-offsets
status. storage.topic: filewatch-connect-cluster-status
key. converter: org.apache.kafka.connect.storage.StringConverter
value. converter: org.apache.kafka.connect.storage.StringConverter
config. storage.replication.factor: 1
offset. storage.replication.factor: 1
status. storage.replication.factor: 1

Question 10

Connector abreviation

Answer 10

cct

Question 11

Expand cct

Answer 11

class
config
taskMax

Question 12

File source complete connector

Answer 12

Question 13

Create connector from CLI

Answer 13

curl -X POST \

http: //localhost:8083/connectors \
- H ‘Content-Type: application/json’ \
- d ‘{ “name”: “connector-name”, “config”: {}}’

Question 14

Config elements for creating connector from CLI

Answer 14

“connector.class”: “‘$connector_class’”,

“tasks.max”: “1”,

“topics”: “github-events”,

“camel.sink.endpoint.hostAddresses”: “elasticsearch-es-http:9200”,

“camel.sink.endpoint.indexName”: “github_events”,

“camel.sink.endpoint.operation”: “Index”,

“camel.sink.path.clusterName”: “elasticsearch”,

“key.converter”: “org.apache.kafka.connect.storage.StringConverter”,

“value.converter”: “org.apache.kafka.connect.storage.StringConverter”

Question 15

Spec of camel github soucrce connector

Answer 15

Question 16

Debezium connector

Answer 16

Question 17

Connector transform fields

Answer 17

transforms: Mask,Insert
transforms. Mask.type: org.apache.kafka.connect.transforms.MaskField$Value
transforms. Mask.fields: ssn
transforms. Insert.type: org.apache.kafka.connect.transforms.InsertField$Value
transforms. Insert.static.field: data-source
transforms. Insert.static.value: database

Question 18

JDBC Connector

Answer 18

Question 19

Event router transform

Answer 19

transforms: EventRouter
transforms. EventRouter.type: io.debezium.transforms.outbox.EventRouter
transforms. EventRouter.table.fields.additional.placement: type:header:eventType
transforms. EventRouter.route.topic.replacement: ${routedByValue}.events

Question 20

Standard JDBC connector config elements

Answer 20

database. hostname: postgresql-repair-requests
database. port: 5432
database. user: postgres
database. password: postgres
database. dbname: waterleakdb
database. server.name: waterleakdb1

Question 21

Alternative to bbc vr

Answer 21

bic vr

Question 22

Expand bic vr

Answer 22

build

image

config

version

replica

Question 23

Standard config elements for connect

Answer 23

config. storage.topic: my-connect-cluster-configs
offset. storage.topic: my-connect-cluster-offsets
status. storage.topic: my-connect-cluster-status
key. converter: org.apache.kafka.connect.storage.StringConverter
value. converter: org.apache.kafka.connect.storage.StringConverter
config. storage.replication.factor: 1
offset. storage.replication.factor: 1
status. storage.replication.factor: 1