Adding zipkin integration

gr8-rest-consumer/build.gradle

@@ -31,6 +31,7 @@ ext {
 repositories {
     mavenLocal()
     maven { url "https://repo.grails.org/grails/core" }
+    maven { url 'https://repo.spring.io/libs-snapshot' }
 }
 
 dependencyManagement {
@@ -49,9 +50,11 @@ dependencies {
     compile "org.grails:grails-core"
     compile "org.springframework.boot:spring-boot-starter-logging"
     compile "org.springframework.boot:spring-boot-autoconfigure"
-    compile "org.springframework.boot:spring-boot-starter-amqp" //AMQP
+    compile "org.springframework.boot:spring-boot-starter-amqp"
     compile "org.springframework.boot:spring-boot-starter-actuator"
     compile "org.springframework.boot:spring-boot-starter-tomcat"
+    compile 'org.springframework.cloud:spring-cloud-sleuth-core:1.0.3.RELEASE'
+    compile 'org.springframework.cloud:spring-cloud-sleuth-zipkin:1.0.3.RELEASE'
     compile "org.grails:grails-plugin-url-mappings"
     compile "org.grails:grails-plugin-rest"
     compile "org.grails:grails-plugin-codecs"
@@ -62,7 +65,7 @@ dependencies {
     compile "org.grails:grails-plugin-async"
     compile "org.grails:grails-web-boot"
     compile "org.grails:grails-logging"
-    compile "org.grails.plugins:cache"
+//    compile "org.grails.plugins:cache"
     compile "org.grails.plugins:hibernate4"
     compile "org.hibernate:hibernate-ehcache"
     compile "org.grails.plugins:views-json"

gr8-rest-consumer/gradle/wrapper/gradle-wrapper.properties

@@ -1,4 +1,4 @@
-#Mon Jan 11 13:11:34 CST 2016
+#Mon Jul 25 10:23:01 CDT 2016
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME

gr8-rest-consumer/gradlew

@@ -42,11 +42,6 @@ case "`uname`" in
     ;;
 esac
 
-# For Cygwin, ensure paths are in UNIX format before anything is touched.
-if $cygwin ; then
-    [ -n "$JAVA_HOME" ] && JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
-fi
-
 # Attempt to set APP_HOME
 # Resolve links: $0 may be a link
 PRG="$0"
@@ -61,9 +56,9 @@ while [ -h "$PRG" ] ; do
     fi
 done
 SAVED="`pwd`"
-cd "`dirname \"$PRG\"`/" >&-
+cd "`dirname \"$PRG\"`/" >/dev/null
 APP_HOME="`pwd -P`"
-cd "$SAVED" >&-
+cd "$SAVED" >/dev/null
 
 CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
 
@@ -114,6 +109,7 @@ fi
 if $cygwin ; then
     APP_HOME=`cygpath --path --mixed "$APP_HOME"`
     CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+    JAVACMD=`cygpath --unix "$JAVACMD"`
 
     # We build the pattern for arguments to be converted via cygpath
     ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`

gr8-rest-consumer/grails-app/conf/application.yml

@@ -6,6 +6,20 @@ rabbit.host.name: localhost
 
 spring.cloud.zookeeper.connect-string: localhost:2181
 
+---
+spring:
+  zipkin:
+    # Uncomment to send to zipkin, replacing 192.168.99.100 with your zipkin IP address
+    # baseUrl: http://192.168.99.100:9411/
+  sleuth:
+    sampler:
+      percentage: 1.0
+
+sample:
+  zipkin:
+    # When enabled=false, traces log to the console. Comment to send to zipkin
+    enabled: false
+
 logging.level.kafka: WARN
 
 ---

gr8-rest-consumer/grails-app/init/gr8/rest/consumer/Application.groovy

@@ -5,15 +5,24 @@ import gr8.rest.api.config.RabbitConfiguration
 import grails.boot.GrailsApp
 import grails.boot.config.GrailsAutoConfiguration
 import grails.converters.JSON
+import groovy.util.logging.Slf4j
 import org.springframework.amqp.rabbit.annotation.EnableRabbit
 import org.springframework.amqp.rabbit.annotation.RabbitListener
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
 import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.EnableAspectJAutoProxy
 import org.springframework.context.annotation.Import
+import org.springframework.cloud.sleuth.zipkin.ZipkinSpanReporter
+import org.springframework.scheduling.annotation.EnableAsync
+import zipkin.Span
 
 import javax.annotation.PostConstruct
 
 @Import([RabbitConfiguration, KafkaConfig])
 @EnableRabbit
+@EnableAspectJAutoProxy(proxyTargetClass = true)
+@EnableAsync
+@Slf4j
 class Application extends GrailsAutoConfiguration {
 	static void main(String[] args) {
 		GrailsApp.run(Application, args)
@@ -23,6 +32,17 @@ class Application extends GrailsAutoConfiguration {
 	Receiver receiver() {
 		new Receiver()
 	}
+
+	@Bean
+	@ConditionalOnProperty(value = "sample.zipkin.enabled", havingValue = "false")
+	public ZipkinSpanReporter spanCollector() {
+		return new ZipkinSpanReporter() {
+			@Override
+			public void report(Span span) {
+				log.info(String.format("Consumer reporting span [%s]", span));
+			}
+		};
+	}
 }
 
 class Receiver {

gr8-rest-producer/build.gradle

@@ -31,6 +31,7 @@ ext {
 repositories {
     mavenLocal()
     maven { url "https://repo.grails.org/grails/core" }
+    maven { url 'https://repo.spring.io/libs-snapshot' }
 }
 
 dependencyManagement {
@@ -51,7 +52,10 @@ dependencies {
     compile "org.grails:grails-core"
     compile "org.springframework.boot:spring-boot-starter-actuator"
     compile "org.springframework.boot:spring-boot-starter-tomcat"
-    compile "org.springframework.boot:spring-boot-starter-amqp" //AMQP
+    compile "org.springframework.boot:spring-boot-starter-amqp"
+    compile 'org.springframework.cloud:spring-cloud-sleuth-core:1.0.3.RELEASE'
+    compile 'org.springframework.cloud:spring-cloud-sleuth-zipkin:1.0.3.RELEASE'
+//    compile 'org.springframework.cloud:spring-cloud-sleuth:1.1.0.BUILD-SNAPSHOT'
     compile "org.grails:grails-plugin-url-mappings"
     compile "org.grails:grails-plugin-rest"
     compile "org.grails:grails-plugin-codecs"
@@ -62,7 +66,7 @@ dependencies {
     compile "org.grails:grails-plugin-async"
     compile "org.grails:grails-web-boot"
     compile "org.grails:grails-logging"
-    compile "org.grails.plugins:cache"
+//    compile "org.grails.plugins:cache"
     compile "org.grails.plugins:hibernate4"
     compile "org.hibernate:hibernate-ehcache"
     compile "org.grails.plugins:views-json"

gr8-rest-producer/gradle/wrapper/gradle-wrapper.properties

@@ -1,4 +1,4 @@
-#Mon Jan 11 13:11:34 CST 2016
+#Mon Jul 25 10:23:01 CDT 2016
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME

gr8-rest-producer/gradlew

@@ -42,11 +42,6 @@ case "`uname`" in
     ;;
 esac
 
-# For Cygwin, ensure paths are in UNIX format before anything is touched.
-if $cygwin ; then
-    [ -n "$JAVA_HOME" ] && JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
-fi
-
 # Attempt to set APP_HOME
 # Resolve links: $0 may be a link
 PRG="$0"
@@ -61,9 +56,9 @@ while [ -h "$PRG" ] ; do
     fi
 done
 SAVED="`pwd`"
-cd "`dirname \"$PRG\"`/" >&-
+cd "`dirname \"$PRG\"`/" >/dev/null
 APP_HOME="`pwd -P`"
-cd "$SAVED" >&-
+cd "$SAVED" >/dev/null
 
 CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
 
@@ -114,6 +109,7 @@ fi
 if $cygwin ; then
     APP_HOME=`cygpath --path --mixed "$APP_HOME"`
     CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+    JAVACMD=`cygpath --unix "$JAVACMD"`
 
     # We build the pattern for arguments to be converted via cygpath
     ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`

gr8-rest-producer/grails-app/conf/application.yml

@@ -8,6 +8,22 @@ brokerList: localhost:9092
 sync: async
 topic: person
 
+---
+spring:
+  zipkin:
+    # Uncomment to send to zipkin, replacing 192.168.99.100 with your zipkin IP address
+    # baseUrl: http://192.168.99.100:9411/
+  sleuth:
+    sampler:
+      percentage: 1.0
+
+sample:
+  zipkin:
+    # When enabled=false, traces log to the console. Comment to send to zipkin
+    enabled: false
+
+logging.level.kafka: WARN
+
 ---
 hibernate:
     cache:

gr8-rest-producer/grails-app/controllers/gr8/rest/producer/PersonController.groovy

@@ -1,14 +1,17 @@
 package gr8.rest.producer
 
-import gr8.rest.api.config.RabbitConfiguration
 import grails.converters.JSON
 import grails.rest.RestfulController
 import grails.transaction.Transactional
 import org.springframework.beans.factory.annotation.Autowired
+import reactor.spring.context.annotation.Consumer
+import reactor.spring.context.annotation.Selector
 
-import static org.springframework.http.HttpStatus.*
+import static org.springframework.http.HttpStatus.CREATED
+import static org.springframework.http.HttpStatus.NOT_FOUND
 
 @Transactional(readOnly = false)
+@Consumer
 class PersonController extends RestfulController {
 
     @Autowired
@@ -46,8 +49,15 @@ class PersonController extends RestfulController {
 
         person.save(flush: true)
 
+        //fire some events
+        //notify "person:saved", (person as JSON).toString()
         eventEmitterService.emitEvent((person as JSON).toString())
 
         respond person, [status: CREATED, view: "show"]
     }
+
+    @Selector("person:saved")
+    public consumePersonSavedEvent(String json) {
+        log.error "Internal person saved event with data $json"
+    }
 }

gr8-rest-producer/grails-app/init/gr8/rest/producer/Application.groovy

@@ -4,13 +4,34 @@ import gr8.rest.api.config.KafkaConfiguration
 import gr8.rest.api.config.RabbitConfiguration
 import grails.boot.GrailsApp
 import grails.boot.config.GrailsAutoConfiguration
+import groovy.util.logging.Slf4j
 import org.springframework.amqp.rabbit.annotation.EnableRabbit
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.EnableAspectJAutoProxy
 import org.springframework.context.annotation.Import
+import org.springframework.cloud.sleuth.zipkin.ZipkinSpanReporter
+import org.springframework.scheduling.annotation.EnableAsync
+import zipkin.Span;
 
 @Import([RabbitConfiguration, KafkaConfiguration])
 @EnableRabbit
+@EnableAspectJAutoProxy(proxyTargetClass = true)
+@EnableAsync
+@Slf4j
 class Application extends GrailsAutoConfiguration {
     static void main(String[] args) {
         GrailsApp.run(Application, args)
     }
+
+    @Bean
+    @ConditionalOnProperty(value = "sample.zipkin.enabled", havingValue = "false")
+    public ZipkinSpanReporter spanCollector() {
+        return new ZipkinSpanReporter() {
+            @Override
+            public void report(Span span) {
+                log.info(String.format("Producer reporting span [%s]", span));
+            }
+        };
+    }
 }

gr8-rest-producer/grails-app/services/gr8/rest/producer/EventEmitterService.groovy

@@ -21,6 +21,7 @@ class EventEmitterService {
 
     public void emitEvent(String messageBody) {
         //emit a kafka event to the producer
+        log.info("You are going to emit an event to Kafka!")
         try {
             if (kafkaEnabled) {
                 springBootKafkaProducer.send(messageBody);

gr8-rest-producer/src/main/java/gr8/rest/producer/SpringBootKafkaProducer.java

@@ -76,10 +76,14 @@ private void sendAsync(String value) {
         ProducerRecord<String, String> record = new ProducerRecord<>(topic, value);
 
         producer.send(record, (RecordMetadata recordMetadata, Exception e) -> {
-            logger.info("Received callback data: " + recordMetadata.toString());
-            if (e != null) {
-                //This will trip on grails development mode due to spring reloader.  Not sure why
-                logger.info("Received exception on callback: " + e.getMessage());
+            if(recordMetadata != null) {
+                logger.info("Received callback data: " + recordMetadata.toString());
+                if (e != null) {
+                    //This will trip on grails development mode due to spring reloader.  Not sure why
+                    logger.info("Received exception on callback: " + e.getMessage());
+                }
+            } else {
+                logger.info("Received null record on callback");
             }
         });
     }

gradle/wrapper/gradle-wrapper.properties

@@ -1,4 +1,4 @@
-#Fri Nov 27 23:09:32 CET 2015
+#Mon Jul 25 10:23:01 CDT 2016
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME

readme.md

@@ -78,6 +78,11 @@ To put a message onto the RabbitMQ and/or the Kafka topic simply use your favori
 curl -X POST -H "Content-type: application/json" --data '{"name": "Christian"}' http://localhost:8080/person
 ```
 
+Docker Machine
+```bash
+curl -X POST -H "Content-type: application/json" --data '{"name": "Christian"}' http://192.168.99.100:8080/person
+```
+
 Notes
 ---
 You may see a `java.lang.RuntimeException: Reloading agent exited via exception, please raise a jira` exception during the first post to kafka when running in `run-app` or `bootRun` if using async.  This can be ignored and appears to not cause any data issues.