Simple solution to use Alpakka Kafka connector to produce and consume kafka messages.
I assume that you have 2 scala apps, a producer and a consumer.
Add the following dependencies:
lucasrpb
/ IntelliJ_IDEA__Perf_Tuning.txt
Created
December 14, 2016 01:23
— forked from P7h/IntelliJ_IDEA__Perf_Tuning.txt
Performance tuning parameters for IntelliJ IDEA. Add these params in idea64.exe.vmoptions or idea.exe.vmoptions file in IntelliJ IDEA. If you are using JDK 8.x, please knock off PermSize and MaxPermSize parameters from the tuning configuration.
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
| -server | |
| -Xms2048m | |
| -Xmx2048m | |
| -XX:NewSize=512m | |
| -XX:MaxNewSize=512m | |
| -XX:PermSize=512m | |
| -XX:MaxPermSize=512m | |
| -XX:+UseParNewGC | |
| -XX:ParallelGCThreads=4 | |
| -XX:MaxTenuringThreshold=1 |
lucasrpb
/ SimpleHttpServer.java
Created
March 2, 2017 02:49
— forked from travisbrown/SimpleHttpServer.java
A very simple Finagle HTTP server example (no error handling, etc.)
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 com.twitter.finagle.Http; | |
| import com.twitter.finagle.ListeningServer; | |
| import com.twitter.finagle.Service; | |
| import com.twitter.finagle.http.HttpMuxer; | |
| import com.twitter.util.Await; | |
| import com.twitter.util.Future; | |
| import java.net.InetSocketAddress; | |
| import static java.nio.charset.StandardCharsets.UTF_8; | |
| import static org.jboss.netty.buffer.ChannelBuffers.copiedBuffer; | |
| import org.jboss.netty.handler.codec.http.*; |
lucasrpb
/ Install etcd On Ubuntu 16.04.md
Created
January 26, 2019 19:05
— forked from sanjid133/Install etcd On Ubuntu 16.04.md
Install etcd On Ubuntu 16.04
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
| #!/bin/bash | |
| curl -L https://github.com/coreos/etcd/releases/download/v3.3.1/etcd-v3.3.1-linux-amd64.tar.gz -o etcd-v3.3.1-linux-amd64.tar.gz | |
| tar xzvf etcd-v3.3.1-linux-amd64.tar.gz | |
| cd etcd-v3.3.1-linux-amd64 | |
| sudo cp etcd /usr/local/bin/ | |
| sudo cp etcdctl /usr/local/bin/ | |
| etcd --version |
lucasrpb
/ README.md
Created
January 31, 2020 20:05
— forked from davideicardi/README.md
Alpakka Kafka connector (akka-stream-kafka) example. Produce and consumer kafka messages using Akka Stream.