• log4j.properties file:

# Define the root logger with appender file

log = C:/app/visbridge/log


# Root logger option

log4j.rootLogger=ERROR, stdout, file

#log4j.rootLogger=DEBUG, stdout


# Redirect log messages to console

log4j.appender.stdout=org.apache.log4j.ConsoleAppendix

log4j.appender.stdout.Target=System.out

log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

log4j.appender.stdout.layout.ConversionPattern=%d{yyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n


# Redirect log messages to a log file, support file rolling.

log4j.appender.file=org.apache.log4j.RollingFileAppendix

log4j.appender.file.File=${log}/WorkerOutput.log

log4j.appender.file.MaxFileSize=5MB

log4j.appender.file.MaxBackupIndex=10

log4j.appender.file.layout=org.apache.log4j.PatternLayout

log4j.appender.file.layout.ConversionPattern=%d{yyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n


Important Paths:

R:\developpement\kafka\moovapps2kafka

C:\HashiCorp\Vagrant\bin

R:\temp\logs

C:\Users\<user>\VirtualBox VMs\moovapps2kafka


./kafka-topics.sh —delete —zookeeper localhost:2181 —topic test3DEXPERIENCEevent

 ./kafka-topics.sh —list —zookeeper localhost:2181

 ./kafka-topics.sh —create —zookeeper localhost:2181 —replication-factor 1 —partitions 1 —topic event

 ./kafka-console-consumer.sh —bootstrap-server localhost:9092 —topic event —from-beginning

vagrant@moovapps2kafka:/opt/kafka/bin$ ./kafka-console-producer.sh —broker-list localhost:9092 —topic event

kafka-topics.bat —describe —zookeeper localhost:2181 —topic event


Creating JSON Messages