• File log4j.properties:

# 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.ConsoleAppender

log4j.appender.stdout. Target=System.out

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

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


# Redirect log messages to has log slips by, support spins rolling.

log4j.appender.file=org.apache.log4j.RollingFileAppender

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 {yyyy-MM-dd HH: mm: s} %-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 vent

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

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

kafka-topics.bat --describe --zookeeper localhost: 2181 --topic vent


Creation of messages to format JSON