miguno’s gists

miguno / clone_repo.sh

Last active May 3, 2017 21:08

Clone the Confluent Docker repository

	# Clone the git repository
	$ git clone https://github.com/confluentinc/cp-docker-images

	# Change into the directory for this tutorial
	$ cd cp-docker-images/examples/kafka-streams-examples

	# Switch to the `v3.2.1` branch
	$ git checkout v3.2.1

miguno / docker-compose.sh

Created April 11, 2017 14:18

Start the services

$ docker-compose up -d

miguno / rest_api_example1.sh

Last active May 19, 2017 22:10

REST API example 1: list all running application instances of the Kafka Music application

	# List all running application instances of the Kafka Music application
	$ curl -sXGET http://localhost:7070/kafka-music/instances

	# You should see output similar to following, though here
	# the output is pretty-printed so that it's easier to read:
	[
	{
	"host": "localhost",
	"port": 7070,
	"storeNames": [

miguno / rest_api_example2.sh

Last active May 19, 2017 22:10

REST API example 2: get the latest Top 5 songs across all music genres

	# Retrieve the latest Top 5 songs across all music genres
	$ curl -sXGET http://localhost:7070/kafka-music/charts/top-five

	# You should see output similar to following, though here
	# the output is pretty-printed so that it's easier to read:
	[
	{
	"artist": "Jello Biafra And The Guantanamo School Of Medicine",
	"album": "The Audacity Of Hype",
	"name": "Three Strikes",

miguno / docker-compose.sh

Created April 11, 2017 14:23

Stop all the services.

$ docker-compose down

miguno / docker_versions.sh

Created April 11, 2017 14:34

	$ docker --version
	Docker version 17.03.1-ce, build c6d412e
	$ docker-compose --version
	docker-compose version 1.11.2, build dfed245
	$ docker-machine --version
	docker-machine version 0.10.0, build 76ed2a6

miguno / WordCount.java

Last active September 26, 2022 11:51

WordCount application in Java 8+, using Kafka's Streams API (Kafka version 0.11.0.0)

	import org.apache.kafka.common.serialization.Serdes;
	import org.apache.kafka.streams.KafkaStreams;
	import org.apache.kafka.streams.StreamsConfig;
	import org.apache.kafka.streams.kstream.KStream;
	import org.apache.kafka.streams.kstream.KStreamBuilder;
	import org.apache.kafka.streams.kstream.KTable;

	import java.util.Arrays;
	import java.util.Properties;

miguno / WordCount.java

Last active July 12, 2017 07:07

WordCount application in Java 8+, using Kafka's Streams API (Kafka version 0.11.0.0)

	import org.apache.kafka.common.serialization.Serdes;
	import org.apache.kafka.streams.KafkaStreams;
	import org.apache.kafka.streams.StreamsConfig;
	import org.apache.kafka.streams.kstream.KStream;
	import org.apache.kafka.streams.kstream.KStreamBuilder;
	import org.apache.kafka.streams.kstream.KTable;

	import java.util.Arrays;
	import java.util.Properties;
	import java.util.concurrent.TimeUnit;

miguno / WordCount.java

Last active July 12, 2017 06:33

WordCount application in Java 8+, using Kafka's Streams API (Kafka version 0.11.0.0)

	import org.apache.kafka.common.serialization.Serdes;
	import org.apache.kafka.streams.KafkaStreams;
	import org.apache.kafka.streams.StreamsConfig;
	import org.apache.kafka.streams.kstream.KStream;
	import org.apache.kafka.streams.kstream.KStreamBuilder;
	import org.apache.kafka.streams.kstream.KTable;

	import java.util.Arrays;
	import java.util.Properties;

miguno / WordCount.scala

Last active December 30, 2018 06:28

WordCount application in Scala 2.11+, using Kafka's Streams API (Kafka version 0.11.0.0)

	import java.lang.Long
	import java.util.Properties
	import java.util.concurrent.TimeUnit

	import org.apache.kafka.common.serialization._
	import org.apache.kafka.streams._
	import org.apache.kafka.streams.kstream.{KStream, KStreamBuilder, KTable}

	import scala.collection.JavaConverters.asJavaIterableConverter

miguno miguno