Skip to content

Instantly share code, notes, and snippets.

View ivanursul's full-sized avatar

Ivan Ursul ivanursul

31 followers · 18 following
View GitHub Profile
@ivanursul
ivanursul / Installing OpenCV with Java support on Raspberry PI 1
Last active April 5, 2023 09:28
1)SD Card Formatter - Format SD Card
2)
sudo diskutil unmount /dev/disk2s1
sudo dd if=/Users/ivanursul/Downloads/2017-07-05-raspbian-jessie.img of=/dev/rdisk2 bs=1m
sudo diskutil eject /dev/rdisk2
3)
sudo mv /var/lib/dpkg/info/linux* ./
@ivanursul
ivanursul / console-consumer.log
Created April 10, 2017 08:37
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
@ivanursul
ivanursul / Main.java
Created April 10, 2017 08:36
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
ivanursul / gist:42b2312055ab200bd4bba1d4cab5791a
Created April 10, 2017 08:20
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
@ivanursul
ivanursul / pom.xml
Created April 10, 2017 08:12
<?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>
@ivanursul
ivanursul / Main.java
Created April 10, 2017 08:11
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;
@ivanursul
ivanursul / gist:4d023c783a80ea745f6ebade88c6b810
Created April 10, 2017 08:07
kafka-streams.log
/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
ivanursul / QueueModel.java
Created February 26, 2017 09:46
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
ivanursul / QueueModel.java
Created February 25, 2017 11:05
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
ivanursul / QueueModel.java
Created February 25, 2017 11:04
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<>();