Arjun Chakraborty

Confluent-Kafka-Python producing SSL handshake error

4

Description =========== I'm trying to run a Kafka consumer using the confluent-kafka python package. I've been using this example : https://github.com/confluentinc/confluent-kafka-python/blob/master/examples/oauth_producer.py as reference. We have oauth setup. And this setup...

I am using an AWS s3 source connector to transfer files from an s3 bucket to a Kafka topic. I'm running into a problem where the size of the messages...

UseDefaultCredentials Provider doesn't recognize web identity token file

26

I have a AWS s3 source connector with the following configurations : ``` apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnector metadata: name: source-connector namespace : my-namespace labels: strimzi.io/cluster: my-connect-cluster spec: class: org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector serviceAccountName:...

I have a AWS s3 source connector with the following configurations : ``` apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnector metadata: name: cloudtrail-s3-source-connector namespace : my-kafka labels: strimzi.io/cluster: my-kafka-connect-cluster spec: class: org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector tasksMax:...

Gracefully exit python script using Streams

1

I have a use case associated with pulling data from a Kafka topic. I need the streamz operator exit gracefully and exit the python script once it hits an exception....