Skip to content

Instantly share code, notes, and snippets.

cd /opt
wget http://apache-mirror.rbc.ru/pub/apache/kafka/0.10.1.0/kafka_2.11-0.10.1.0.tgz
tar xvzf kafka_2.11-0.10.1.0.tgz
ln -s kafka_2.11-0.10.1.0/ kafka
vi /etc/systemd/system/kafka-zookeeper.service
[Unit]
Description=Apache Zookeeper server (Kafka)
Documentation=http://zookeeper.apache.org
@iboumedien
iboumedien / CsvToJson.java
Created July 19, 2018 06:25 — forked from arnaudroger/CsvToJson.java
How to Convert CSV to JSON in Java
import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.core.JsonGenerator;
import org.simpleflatmapper.csv.CsvParser;
import org.simpleflatmapper.csv.CsvReader;
import java.io.IOException;
import java.util.Iterator;
// uses http://simpleflatmapper.org/0101-getting-started-csv.html for csv parser
// and jackson-core for JsonGenerator
@iboumedien
iboumedien / gist:8774f8992dd7f9416aa2
Created February 28, 2016 14:49 — forked from rk295/gist:2ae30c7c58499f9c6718
LogStash proftpd xferlog grok
input {
file {
path => "/var/log/xferlog"
type => "xferlog"
add_field => { "program" => "proftpd" }
}
}
filter {
if [type] == "xferlog" {
@iboumedien
iboumedien / elasticsearch-analysis-french-stopwords
Created November 17, 2015 10:43 — forked from nboire/elasticsearch-analysis-french-stopwords
Elasticsearch : override stopwords list for specific "language" analyzer ( exemple with "french" list )
# delete all data
curl -XDELETE localhost:9200/test
# create an index and define specific french stop_words
curl -XPUT localhost:9200/test -d '{
"settings" : {
"index" : {
"analysis" : {
"analyzer" : {
"french" : {