confluent-platform Examples and Free Source Code

kafka sink connector with mysql DB table not found...

mysql apache-kafka apache-kafka-connect confluent-platform

Confluent Kafka Golang Client Producer "Broker: Not enough in-sync replicas"...

go apache-kafka confluent-platform

Kafka S3 Source Connector...

amazon-s3 apache-kafka apache-kafka-connect confluent-platform

How to modify/update to the data before sending it to downstream...

jdbc apache-kafka apache-kafka-connect confluent-platform debezium

Parsing Avro messages in flink , giving null pointer exception if field is nullable in Avro Schema...

java apache-flink confluent-platform

How to monitor disk space usage for Kafka Brokers in AWS MSK cluster...

apache-kafka devops confluent-platform prometheus-alertmanager aws-msk

How to create partitions in Kafka Topics with customer name/id...

apache-kafka apache-kafka-streams confluent-platform

Install confluent-kafka avro with pip...

python apache-kafka avro confluent-platform

Flask gevent threads are stuck on kafka consumer...

python flask gunicorn gevent confluent-platform

Why did I just start getting "Group authorization failed" on Kafka using Confluent for a ....

c#apache-kafka confluent-platform

Docker + docker-compose up + Cannot start service...

docker docker-compose docker-machine rhel confluent-platform

Waiting for every to connect to a topic with new consumer group in kafka (node-rdkafka)...

node.js apache-kafka kafka-consumer-api confluent-platform

How can I produce without schema as avro type with python?...

python apache-kafka avro confluent-platform confluent-schema-registry

Kafka connect could not find JdbcSinkConnector even if it's installed...

apache-kafka apache-kafka-connect confluent-platform

multiple tenants accessing Confluent kafka on GCP...

google-cloud-platform apache-kafka multi-tenant confluent-platform

Why might closing a Kafka Producer (producer.close()) block and takes a few minutes...

apache-kafka confluent-platform kafka-producer-api

Kafka Streams KTable foreign key join not working as expected...

java apache-kafka-streams apache-kafka-connect confluent-platform

Kafka Connect JSON Schema does not appear to support "$ref" tags...

apache-kafka apache-kafka-connect jsonschema confluent-platform

KTable from a topic and service restart...

apache-kafka kafka-consumer-api apache-kafka-streams confluent-platform

Kafka Connect schema format for JSONConverter...

json apache-kafka apache-kafka-connect jsonschema confluent-platform

Properly Configuring Kafka Connect S3 Sink TimeBasedPartitioner...

amazon-s3 apache-kafka apache-kafka-connect confluent-platform

How do we filter out tables and provide for source jdbc connector to fetch data...

apache-kafka apache-kafka-connect confluent-platform

Expose additional port on Kafka Connect for thread listener port...

apache-kafka docker-compose apache-kafka-connect confluent-platform

Use Kafka Connect to update Elasticsearch field on existing document instead of creating new...

elasticsearch apache-kafka apache-kafka-connect confluent-platform

Using kafka-json-schema-console-producer to produce message with a key schema and a value schema...

json apache-kafka jsonschema confluent-platform confluent-schema-registry

Kafka Avro Producer (kafka-avro-console-producer) schema error when sending to kafka connect...

apache-kafka apache-kafka-connect confluent-platform confluent-schema-registry

How to get number of items on producer(using librdkafka) send queue...

c confluent-platform librdkafka

How to overwrite log4j.properties in confluent zookeeper...

docker log4j apache-zookeeper confluent-platform

Spark Confluent schema registry client - Unrecognized field "schemaType"...

apache-spark apache-spark-sql schema confluent-platform confluent-schema-registry

k3s and kafka network -- port blocked for some reason...

confluent-platform k3s