Ivan Ursul ivanursul
ivanursul
/ console-consumer.log
Created
April 10, 2017 08:37
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning \ | |
| --topic WordsWithCountsTopic2 \ | |
| --formatter kafka.tools.DefaultMessageFormatter \ | |
| --property print.key=true \ | |
| --property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer \ | |
| --property value.deserializer=org.apache.kafka.common.serialization.StringDeserializer | |
| null Ivan Baraban |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.kafka.examples; | |
| import org.apache.kafka.common.serialization.Serde; | |
| 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.GlobalKTable; | |
| import org.apache.kafka.streams.kstream.KStreamBuilder; | |
| import java.util.Properties; |
ivanursul
/ gist:42b2312055ab200bd4bba1d4cab5791a
Created
April 10, 2017 08:20
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning \ | |
| --topic WordsWithCountsTopic \ | |
| --formatter kafka.tools.DefaultMessageFormatter \ | |
| --property print.key=true \ | |
| --property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer \ | |
| --property value.deserializer=org.apache.kafka.common.serialization.LongDeserializer | |
| all 1 | |
| streams 1 | |
| lead 1 | |
| to 1 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <?xml version="1.0" encoding="UTF-8"?> | |
| <project xmlns="http://maven.apache.org/POM/4.0.0" | |
| xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" | |
| xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> | |
| <modelVersion>4.0.0</modelVersion> | |
| <groupId>kafka-streams</groupId> | |
| <artifactId>kafka-streams-hello-world</artifactId> | |
| <version>1.0-SNAPSHOT</version> | |
| <build> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.kafka.examples; | |
| import org.apache.kafka.common.serialization.Serde; | |
| import org.apache.kafka.common.serialization.Serdes; | |
| import org.apache.kafka.streams.KafkaStreams; | |
| import org.apache.kafka.streams.KeyValue; | |
| import org.apache.kafka.streams.StreamsConfig; | |
| import org.apache.kafka.streams.kstream.GlobalKTable; | |
| import org.apache.kafka.streams.kstream.KStream; | |
| import org.apache.kafka.streams.kstream.KStreamBuilder; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| /Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/bin/java -Didea.launcher.port=7537 "-Didea.launcher.bin.path=/Applications/IntelliJ IDEA CE.app/Contents/bin" -Dfile.encoding=UTF-8 -classpath "/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/charsets.jar:/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/deploy.jar:/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Users/ivanursul/development/java/jdk1.8.0_66.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Users/ivanursul/development/java/ |
ivanursul
/ QueueModel.java
Created
February 26, 2017 09:46
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import java.util.*; | |
| public class QueueModel { | |
| public static void main(String[] args) { | |
| Map<String, Queue<Message>> queueMap = createQueueMap(); | |
| QueueMessageProducer producer = new QueueMessageProducer(queueMap); | |
| initConsumers(queueMap); |
ivanursul
/ QueueModel.java
Created
February 25, 2017 11:05
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import java.util.*; | |
| public class QueueModel { | |
| public static void main(String[] args) { | |
| Queue<Message> queue = new LinkedList<>(); | |
| QueueMessageProducer producer = new QueueMessageProducer(queue); | |
| List<QueueConsumer> consumers = new ArrayList<>(); |
ivanursul
/ QueueModel.java
Created
February 25, 2017 11:04
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import java.util.*; | |
| public class QueueModel { | |
| public static void main(String[] args) { | |
| Queue<String> queue = new LinkedList<>(); | |
| QueueMessageProducer producer = new QueueMessageProducer(queue); | |
| List<QueueConsumer> consumers = new ArrayList<>(); |
ivanursul
/ PubSubModel.java
Created
February 25, 2017 11:02
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import java.util.*; | |
| import java.util.Queue; | |
| public class PubSubModel { | |
| public static void main(String[] args) { | |
| List<Consumer> consumers = new ArrayList<>(); | |
| for (int i = 0; i < 3; i++ ) { | |
| Consumer consumer = new Consumer( |