install jre
$ brew tap caskroom/versions
$ brew cask install java8
create directory
$ mkdir ~/workshop/
$ cd ~/workshop/
Surasit Liangpornrattana punneng
punneng
/ kafka-workshop-prerequisite.md
Last active
August 16, 2018 16:41
punneng
/ EsConsumer.kt
Last active
July 4, 2018 18:10
This file contains hidden or 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.Properties | |
| import org.apache.http.HttpHost | |
| import com.fasterxml.jackson.databind.JsonNode | |
| import org.apache.kafka.clients.consumer.ConsumerConfig | |
| import org.apache.kafka.clients.consumer.KafkaConsumer | |
| import org.apache.kafka.common.serialization.StringDeserializer | |
| import org.apache.kafka.connect.json.JsonDeserializer | |
| import org.elasticsearch.ElasticsearchException |
punneng
/ build.gradle
Created
July 2, 2018 17:57
This file contains hidden or 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
| buildscript { | |
| ext.kotlin_version = '1.2.50' | |
| repositories { | |
| mavenCentral() | |
| } | |
| dependencies { | |
| classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version" | |
| } |
This file contains hidden or 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 main | |
| import ( | |
| "log" | |
| "os" | |
| "fmt" | |
| "net/http" | |
| "encoding/json" | |
| "github.com/joho/godotenv" |
punneng
/ producer.go
Last active
June 24, 2018 11:53
This file contains hidden or 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 producer | |
| import ( | |
| "fmt" | |
| "os" | |
| "github.com/confluentinc/confluent-kafka-go/kafka" | |
| ) | |
| var producer *kafka.Producer |
This file contains hidden or 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
| CHANNEL_SECRET=your_channel_secret | |
| CHANNEL_ACCESS_TOKEN=your_channel_access_token | |
| # BOOTSTRAP_SERVERS=localhost:9092 |
This file contains hidden or 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 main | |
| import ( | |
| "log" | |
| "os" | |
| "net/http" | |
| "github.com/joho/godotenv" | |
| "github.com/labstack/echo" | |
| "github.com/line/line-bot-sdk-go/linebot" |
punneng
/ gist:ba4b43528f221a87ba27dd4aef7888b9
Created
June 13, 2018 07:24
This file contains hidden or 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
| success: function (res, status) { | |
| liff.getProfile() | |
| .catch(function (error) { | |
| window.alert('Error message from getProfile: ' + error.message); | |
| }.then(function (profile) { | |
| liff.sendMessages([ | |
| { | |
| type: 'image', | |
| originalContentUrl: 'https://' + document.domain + '/static/imgs/' + res + '.jpg', | |
| previewImageUrl: 'https://' + document.domain + '/static/imgs/' + res + '_240.jpg' |
punneng
/ gist:71587989179fe9e34b466d22ec3d5114
Last active
May 11, 2018 09:52
This file contains hidden or 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
| class Obj { | |
| var v1 | |
| def doSomething() { | |
| [1,2,3].forEach(i => { | |
| this.v1 = i | |
| this.v2 = random() | |
| this.validate_with_instance_variable() // (1) | |
| this.validate_with_passing_variable(i, this.v2) // (2) | |
| }) |
punneng
/ gist:20090fb41853043b14a3139b0ede400f
Created
May 9, 2018 11:06
This file contains hidden or 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
| <!-- main pom.xml --> | |
| <?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>group1</groupId> | |
| <artifactId>multipleprojects</artifactId> | |
| <version>1.0-SNAPSHOT</version> |
NewerOlder