Activation des logs

# 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:ss} %-5p %c{1}:%L - %m%n

# Redirect log messages to a log file, support file 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:ss} %-5p %c{1}:%L - %m%n

Chemins importants :

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

Création de messages au format JSON