Start Server Service
./bin/kafka-server-start.sh ./config/kraft/server.properties
Error Unformatted
./bin/kafka-storage.sh random-uuid
./bin/kafka-storage.sh format -t wTJ2_4vKQcujLyzgVBznow -c config/kraft/server.properties
Connect Standalone
Start Connect-Standalone
./bin/connect-standalone.sh config/connect-standalone.properties config/cassandra-sink-standalone.properties
Topics
./bin/kafka-configs.sh --bootstrap-server 10.102.235.46:9092 --alter --entity-type topics --entity-name kapalpatroli --add-config segment.bytes=32768,min.compaction.lag.ms=1000,min.cleanable.dirty.ratio=0.01,delete.retention.ms=100,segment.ms=100,cleanup.policy=compact,retention.ms=1000
./bin/kafka-topics.sh --bootstrap-server 10.102.235.46:9092 --create --topic kapalpatroli --partitions 6 --replication-factor 1 --config cleanup.policy=compact --config retention.ms=1000
./bin/kafka-console-consumer.sh --bootstrap-server 10.102.235.46:9092 --topic kapalpatroli --property "print.key=true"
./bin/kafka-topics.sh --delete --bootstrap-server=10.102.235.46:9092 --topic kapalpatroli
