Hi,
I am using Flink 1.4 along with Kafka 0.11. My stream job has 4 Kafka
consumers each subscribing to 4 different topics. The stream from each
consumer gets processed in 3 to 4 different ways there by writing to a
total of 12 sinks (cassandra tables). When the job runs, up to 8 or 10
records get
I have a single node Flink instance which has the required jars for logback
in the lib folder (logback-classic.jar, logback-core.jar,
log4j-over-slf4j.jar). I have removed the jars for log4j from the lib
folder (log4j-1.2.17.jar, slf4j-log4j12-1.7.7.jar). 'logback.xml' is also
correctly updated in
