bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic DBinfotopic
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic purchasestopic
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic salestopic

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic revenuetopic
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic expensestopic
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic profittopic
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic total-topic

DATA BASE:
bin/connect-standalone.sh config/connect-standalone.properties config/connect-jdbc-source-kafka.properties config/connect-jdbc-sink-kafka.properties

CONSUMER:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic revenuetopic --from-beginning
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic expensestopic --from-beginning
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic profittopic --from-beginning

SEE TOPICS:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092

DELETE:
bin/kafka-topics.sh --zookeeper localhost:9092 --delete --topic test