|
Re: Adding annotations and limits of kafka connect created pods
Yeah, the annotations are strings. So you need to wrap it into quotes to make it a string. Without them it will be interpreted as array.
Yeah, the annotations are strings. So you need to wrap it into quotes to make it a string. Without them it will be interpreted as array.
|
By
Jakub Scholz
·
#37
·
|
|
Re: 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
·
|
|
Re: 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",
Thanks, following your advice I've added:
template:
pod:
metadata:
annotations:
ad.datadoghq.com/kafka-connect-container-name.logs: [{"type":"file",
|
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
·
|
|
Re: 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
·
|
|
Re: 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
·
|
|
Re: Is there a way to use topic operator with zookeepr?
I'm afraid that is not possible. The Topic Operator is currently using Zookeeper for storing some additional data, so it it really needed there. Since Zookeeper will be removed from Kafka in the
I'm afraid that is not possible. The Topic Operator is currently using Zookeeper for storing some additional data, so it it really needed there. Since Zookeeper will be removed from Kafka in the
|
By
Jakub Scholz
·
#31
·
|
|
Re: Adding annotations and limits of kafka connect created pods
Hi,
For specifying the resources, you can do something like this:
apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaConnect
metadata:
name: my-connect
# ...
spec:
# ...
resources:
Hi,
For specifying the resources, you can do something like this:
apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaConnect
metadata:
name: my-connect
# ...
spec:
# ...
resources:
|
By
Jakub Scholz
·
#30
·
|
|
Re: 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
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
|
By
alonisser@...
·
#27
·
|
|
RC2 of Strimzi Kafka Operators 0.17.0 is now available
Release Candidate 2 of Strimzi Kafka Operators 0.17.0 is now available. It took us more than two weeks since the RC1, but we spent them with a lot of testing and improving the code to make sure the
Release Candidate 2 of Strimzi Kafka Operators 0.17.0 is now available. It took us more than two weeks since the RC1, but we spent them with a lot of testing and improving the code to make sure the
|
By
Jakub Scholz
·
#26
·
|
|
Re: Does anyone here has an experience with running schema manager (for avro) with strimzi kafka ?
I used the open source helm chart from Confluent: https://github.com/confluentinc/cp-helm-charts/tree/v5.4.0/charts/cp-schema-registry
The heap settings and resource limits were not sufficient for the
I used the open source helm chart from Confluent: https://github.com/confluentinc/cp-helm-charts/tree/v5.4.0/charts/cp-schema-registry
The heap settings and resource limits were not sufficient for the
|
By
Matthew Isaacs
·
#25
·
|
|
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
·
|
|
RC1 of Strimzi Kafka Operators 0.17.0 is now available
The Release Candidate 1 of Strimzi Kafka Operators 0.17.0 is now available. It doesn't include many new features, but some of those included were in high demand. The main features are:
* Add
The Release Candidate 1 of Strimzi Kafka Operators 0.17.0 is now available. It doesn't include many new features, but some of those included were in high demand. The main features are:
* Add
|
By
Jakub Scholz
·
#23
·
|
|
[ANNOUNCE] Strimzi Kafka bridge 0.15.2
Strimzi Kafka Bridge 0.15.2 is now available with the following changes:
* Fixed missing Jackson Core dependency
For more details go to:
Strimzi Kafka Bridge 0.15.2 is now available with the following changes:
* Fixed missing Jackson Core dependency
For more details go to:
|
By
Paolo Patierno
·
#22
·
|
|
[ANNOUNCE] Strimzi Kafka bridge 0.15.1
Strimzi Kafka Bridge 0.15.1 is now available with the following changes:
* Bumped Apache Kafka version to 2.4.0 and other dependencies
For more details go to:
Strimzi Kafka Bridge 0.15.1 is now available with the following changes:
* Bumped Apache Kafka version to 2.4.0 and other dependencies
For more details go to:
|
By
Paolo Patierno
·
#21
·
|
|
[ANNOUNCE] Strimzi Kafka OAuth library 0.3.0 release
The 0.3.0 version of the Strimzi Kafka OAuth library for using OAuth authentication in Kafka clients and brokers has been released and should be available in the Maven repositories. The main
The 0.3.0 version of the Strimzi Kafka OAuth library for using OAuth authentication in Kafka clients and brokers has been released and should be available in the Maven repositories. The main
|
By
Jakub Scholz
·
#20
·
|
|
[ANNOUNCE] Strimzi Kafka operator 0.16.2
Strimzi Kafka Operators 0.16.2 is now available with two bug fixes:
* Fix bug in upgrade when the Kafka.spec.kafka.version field is not specified
* Fix network policies for port 3.11 on older
Strimzi Kafka Operators 0.16.2 is now available with two bug fixes:
* Fix bug in upgrade when the Kafka.spec.kafka.version field is not specified
* Fix network policies for port 3.11 on older
|
By
Jakub Scholz
·
#19
·
|
|
RC1 of Strimzi Kafka OAuth library 0.3.0
Hi,
Release Candidate 1 of the 0.3.0 version of the Strimzi Kafka OAuth library is now available for testing: https://github.com/strimzi/strimzi-kafka-oauth/releases/tag/0.3.0-rc1. The main
Hi,
Release Candidate 1 of the 0.3.0 version of the Strimzi Kafka OAuth library is now available for testing: https://github.com/strimzi/strimzi-kafka-oauth/releases/tag/0.3.0-rc1. The main
|
By
Jakub Scholz
·
#18
·
|