Test drive KRaft with GA Docker images with 6.2.0 GA code (#1001)

* DEVX-2631: Test drive KRaft with GA Docker images with 6.2.0 GA code

* Replace ksqlDB query with kafka-avro-console-consumer

cp-quickstart/start-docker-community.sh

@@ -25,12 +25,14 @@ curl -X POST -H "Content-Type: application/json" --data @connector_users_cos.con
 # Verify topics exist
 MAX_WAIT=30
 echo -e "\nWaiting up to $MAX_WAIT seconds for topics (pageviews, users) to exist"
-retry $MAX_WAIT check_topic_exists broker broker:9092 pageviews || exit 1
-retry $MAX_WAIT check_topic_exists broker broker:9092 users || exit 1
+retry $MAX_WAIT check_topic_exists broker broker:29092 pageviews || exit 1
+retry $MAX_WAIT check_topic_exists broker broker:29092 users || exit 1
 echo "Topics exist!"
 
 # Run the KSQL queries
 docker-compose exec ksqldb-cli bash -c "ksql http://ksqldb-server:8088 <<EOF
 run script '/tmp/statements.sql';
 exit ;
 EOF"
+
+printf "\n====== Successfully Completed ======\n\n"

cp-quickstart/start-docker-kraft.sh

@@ -25,12 +25,12 @@ source ./connectors/submit_datagen_users_config.sh
 # Verify topics exist
 MAX_WAIT=30
 echo -e "\nWaiting up to $MAX_WAIT seconds for topics (pageviews, users) to exist"
-retry $MAX_WAIT check_topic_exists broker broker:9092 pageviews || exit 1
-retry $MAX_WAIT check_topic_exists broker broker:9092 users || exit 1
+retry $MAX_WAIT check_topic_exists broker broker:29092 pageviews || exit 1
+retry $MAX_WAIT check_topic_exists broker broker:29092 users || exit 1
 echo "Topics exist!"
 
-# Run the KSQL queries
-docker-compose exec ksqldb-cli bash -c "ksql http://ksqldb-server:8088 <<EOF
-run script '/tmp/statements.sql';
-exit ;
-EOF"
+# Read topics
+docker-compose exec connect kafka-avro-console-consumer --bootstrap-server broker:29092 --timeout-ms 10000 --max-messages 5 --topic users --property schema.registry.url=http://schema-registry:8081
+docker-compose exec connect kafka-avro-console-consumer --bootstrap-server broker:29092 --timeout-ms 10000 --max-messages 5 --topic pageviews --property schema.registry.url=http://schema-registry:8081
+
+printf "\n====== Successfully Completed ======\n\n"

cp-quickstart/start-docker.sh

@@ -23,12 +23,14 @@ source ./connectors/submit_datagen_users_config.sh
 # Verify topics exist
 MAX_WAIT=30
 echo -e "\nWaiting up to $MAX_WAIT seconds for topics (pageviews, users) to exist"
-retry $MAX_WAIT check_topic_exists broker broker:9092 pageviews || exit 1
-retry $MAX_WAIT check_topic_exists broker broker:9092 users || exit 1
+retry $MAX_WAIT check_topic_exists broker broker:29092 pageviews || exit 1
+retry $MAX_WAIT check_topic_exists broker broker:29092 users || exit 1
 echo "Topics exist!"
 
 # Run the KSQL queries
 docker-compose exec ksqldb-cli bash -c "ksql http://ksqldb-server:8088 <<EOF
 run script '/tmp/statements.sql';
 exit ;
 EOF"
+
+printf "\n====== Successfully Completed ======\n\n"