|
support for 2.4.1
Does the new 0.17 operator uses kafka-connect 2.4.1 ? or still the 2.4.1 image?
Does the new 0.17 operator uses kafka-connect 2.4.1 ? or still the 2.4.1 image?
|
By
alonisser@...
· #45
·
|
|
Updating the kafka connect deployment with changes in the kafka connect crd
Turns out the issue was the changed CRD had errors strimzi operator couldn't handle, following the logs of the operator pods, I've found the error and now it does update as expected.
Turns out the issue was the changed CRD had errors strimzi operator couldn't handle, following the logs of the operator pods, I've found the error and now it does update as expected.
|
By
alonisser@...
· #36
·
|
|
Adding annotations and limits of kafka connect created pods
Thanks, following your advice I've added: template: pod: metadata: annotations: ad.datadoghq.com/kafka-connect-container-name.logs: [{"type":"file", "source":"java","sourcecategory":"sourcecode", "ser
Thanks, following your advice I've added: template: pod: metadata: annotations: ad.datadoghq.com/kafka-connect-container-name.logs: [{"type":"file", "source":"java","sourcecategory":"sourcecode", "ser
|
By
alonisser@...
· #35
·
|
|
Updating the kafka connect deployment with changes in the kafka connect crd
I've updated the crd after it created the deployment and pods and services (adding configs, annotations and resources)but it seems the deployment is stuck where I started Is there a way to update the
I've updated the crd after it created the deployment and pods and services (adding configs, annotations and resources)but it seems the deployment is stuck where I started Is there a way to update the
|
By
alonisser@...
· #34
·
|
|
Is there a way to use topic operator with zookeepr?
Thanks for the kind and authoritative response! I'll roll my own for now
Thanks for the kind and authoritative response! I'll roll my own for now
|
By
alonisser@...
· #33
·
|
|
Adding annotations and limits of kafka connect created pods
Thanks I would try that! I was missing the pod/deployment sub level
Thanks I would try that! I was missing the pod/deployment sub level
|
By
alonisser@...
· #32
·
|
|
Is there a way to use topic operator with zookeepr?
Without zookeeper that is, I need topic operator without touching zookeeper
Without zookeeper that is, I need topic operator without touching zookeeper
|
By
alonisser@...
· #29
·
|
|
Is there a way to use topic operator with zookeepr?
I want to use it for programmatic management of my topics, but my kafka is hosted in confluent and I don't think I can access the zookeeper cluster there
I want to use it for programmatic management of my topics, but my kafka is hosted in confluent and I don't think I can access the zookeeper cluster there
|
By
alonisser@...
· #28
·
|
|
Adding annotations and limits of kafka connect created pods
Trying to add pod annotations (for our log connector) and resource request/limits to the KafkaConnect created resources What should I add in the resource so it would create the pods/deployment with th
Trying to add pod annotations (for our log connector) and resource request/limits to the KafkaConnect created resources What should I add in the resource so it would create the pods/deployment with th
|
By
alonisser@...
· #27
·
|
|
Does anyone here has an experience with running schema manager (for avro) with strimzi kafka ?
I've setup the most basic kafka persistent setup (see the crd below) But can't seem to understand how to run schema registy against it (with kafka based leader selection) I see kafka logs with endless
I've setup the most basic kafka persistent setup (see the crd below) But can't seem to understand how to run schema registy against it (with kafka based leader selection) I see kafka logs with endless
|
By
alonisser@...
· #24
·
|
|
KafkaConnect resource - how to use SASL_SSL
Turns out that adding ssl :{} in the spec. does the trick :)
Turns out that adding ssl :{} in the spec. does the trick :)
|
By
alonisser@...
· #15
·
|
|
KafkaConnect resource - how to use SASL_SSL
For connection for my kafka instance (by eventhub kafka facade) I need the following properties security.protocol=SASL_SSL producer.sasl.mechanism=SASL_SSL consumer.sasl.mechanism=SASL_SSL I've verifi
For connection for my kafka instance (by eventhub kafka facade) I need the following properties security.protocol=SASL_SSL producer.sasl.mechanism=SASL_SSL consumer.sasl.mechanism=SASL_SSL I've verifi
|
By
alonisser@...
· #14
·
|
|
strimzi for debezium with a managed fafka (eventhub kafka facade)
I want to use strimzi to deploy debezium with kafka connect and eventhub kafka facade in my aks cluster, All the tutorial I've encountered are about using strimzi to create a kafka cluster (which I do
I want to use strimzi to deploy debezium with kafka connect and eventhub kafka facade in my aks cluster, All the tutorial I've encountered are about using strimzi to create a kafka cluster (which I do
|
By
alonisser@...
· #10
·
|