[WIP] DEVX-1293: Spring Cloud Stream Producer / Consumer example

clients/cloud/java-springcloudstream/.gitignore

@@ -0,0 +1,32 @@
+HELP.md
+.gradle
+build/
+!gradle/wrapper/gradle-wrapper.jar
+!**/src/main/**
+!**/src/test/**
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+out/
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+
+### VS Code ###
+.vscode/

clients/cloud/java-springcloudstream/build.gradle

@@ -0,0 +1,67 @@
+buildscript {
+  repositories {
+    jcenter()
+  }
+  dependencies {
+    classpath 'com.commercehub.gradle.plugin:gradle-avro-plugin:0.15.1'
+  }
+}
+
+plugins {
+  id 'org.springframework.boot' version '2.2.4.RELEASE'
+  id 'io.spring.dependency-management' version '1.0.9.RELEASE'
+  id 'java'
+}
+
+apply plugin: 'com.commercehub.gradle.plugin.avro'
+apply plugin: 'idea'
+
+group = 'io.confluent.examples.clients.cloud.scs'
+version = '0.0.1-SNAPSHOT'
+sourceCompatibility = '1.8'
+
+configurations {
+  compileOnly {
+    extendsFrom annotationProcessor
+  }
+}
+
+repositories {
+  jcenter()
+
+  maven {
+    url 'http://packages.confluent.io/maven'
+  }
+}
+
+ext {
+  set('springCloudVersion', "Hoxton.SR1")
+}
+
+dependencies {
+  implementation 'org.apache.kafka:kafka-streams'
+  implementation 'org.springframework.cloud:spring-cloud-stream'
+  implementation 'org.springframework.cloud:spring-cloud-stream-binder-kafka'
+  implementation 'org.springframework.cloud:spring-cloud-stream-binder-kafka-streams'
+  implementation 'org.springframework.kafka:spring-kafka'
+  compileOnly 'org.projectlombok:lombok'
+  annotationProcessor 'org.projectlombok:lombok'
+  testImplementation('org.springframework.boot:spring-boot-starter-test') {
+    exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
+  }
+  testImplementation 'org.springframework.cloud:spring-cloud-stream-test-support'
+  testImplementation 'org.springframework.kafka:spring-kafka-test'
+
+  implementation 'org.apache.avro:avro'
+  implementation 'io.confluent:kafka-streams-avro-serde:5.4.0'
+}
+
+dependencyManagement {
+  imports {
+    mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
+  }
+}
+
+test {
+  useJUnitPlatform()
+}

clients/cloud/java-springcloudstream/gradle/wrapper/gradle-wrapper.properties

@@ -0,0 +1,6 @@
+#Fri Feb 14 16:23:55 EST 2020
+distributionUrl=https\://services.gradle.org/distributions/gradle-6.0.1-all.zip
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStorePath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME

clients/cloud/java-springcloudstream/settings.gradle

@@ -0,0 +1 @@
+rootProject.name = 'spring-cloud-stream-kafka'

clients/cloud/java-springcloudstream/src/main/avro/DataRecord.avsc

@@ -0,0 +1,11 @@
+{
+  "namespace": "io.confluent.examples.clients.cloud",
+  "type": "record",
+  "name": "DataRecordAvro",
+  "fields": [
+    {
+      "name": "count",
+      "type": "long"
+    }
+  ]
+}

clients/cloud/java-springcloudstream/src/main/java/io/confluent/examples/clients/cloud/scs/model/DataRecord.java

@@ -0,0 +1,12 @@
+package io.confluent.examples.clients.cloud.scs.model;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+@Data
+@AllArgsConstructor
+public class DataRecord {
+
+  Long count;
+}