-
In this demo, based on the schema-registry-confluent-avro-serializer sample, we will create three Spring Cloud Stream applications, one consumer and two producers, all of them using the Confluent Schema Registry Server and the Confluent Avro Serializers.
-
SaaSHub
SaaSHub - Software Alternatives and Reviews. SaaSHub helps you find the best software and product alternatives
-
gradle-avro-plugin
Discontinued A Gradle plugin to allow easily performing Java code generation for Apache Avro. It supports JSON schema declaration files, JSON protocol declaration files, and Avro IDL files.
As we do not use maven like the schema-registry-confluent-avro-serializer sample, we cannot use the official avro-maven-plugin. We will use davidmc24/gradle-avro-plugin instead.
-
spring-cloud-stream-kafka-confluent-avro-schema-registry
🍀 Spring Cloud Stream Kafka & Confluent Avro Schema Registry
We will use a docker-compose.yml based on the one from confluent/cp-all-in-one both to run it locally and to execute the integration tests. From that configuration we will keep only the containers: zookeeper, broker, schema-registry and control-center.
-
cp-all-in-one
docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud, Apache Kafka Confluent Platform
We will use a docker-compose.yml based on the one from confluent/cp-all-in-one both to run it locally and to execute the integration tests. From that configuration we will keep only the containers: zookeeper, broker, schema-registry and control-center.
-
Just to keep it simple we will put the consumer and the two producers as modules of a gradle multi-module project, with a little help of spring initializr.
Related posts
-
My local Kafka instance stuck in "auto leader balancing"
-
Has anyone seen and handled this error successfully ? : /bin/sh^M: bad interpreter: No such file or directory
-
How to use Kafka to stream files using three separate machines (one for the producer, one for the broker, and one for the broker)?
-
Kafka Streams application doesn't start up
-
Apache Kafka Using Docker