Slide Deck: https://redhat.slides.com/rdasilva/amq-streams
To use another project different than myproject (livedemo)
sed -i '' 's/namespace: .*/namespace: livedemo/' install/cluster-operator/*RoleBinding*.yaml
unzip amq-streams-1.2.0-ocp-install-examples.zip oc replace --force -f examples/templates/cluster-operator/ -n openshift oc replace --force -f install/cluster-operator/ oc new-app strimzi-ephemeral
oc exec -it my-cluster-zookeeper-0 -- bin/kafka-topics.sh --zookeeper localhost:21810 --list oc exec -it my-cluster-zookeeper-0 -- bin/kafka-topics.sh --zookeeper localhost:21810 --describe oc exec -it my-cluster-zookeeper-0 -- bin/kafka-topics.sh --zookeeper localhost:21810 --create --topic created-in-kafka --partitions 1 --replication-factor 1
oc create -f https://raw.githubusercontent.com/scholzj/demo-amq-streams-webinar/master/08-my-user.yaml oc create -f https://raw.githubusercontent.com/scholzj/demo-amq-streams-webinar/master/09-demo-application.yaml
oc create -f ./stream-app/resources/topics.yml oc create -f ./stream-app/resources/stream-app.yml oc get kafkaTopics oc create -f ./consumer-app/resources/consumer-app.yml oc create -f ./device-app/resources/device-app.yml
After some while, scale consumer-app to 0, reset the offset and scale up:
oc exec -it my-cluster-zookeeper-0 -- bin/kafka-consumer-groups.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --group consumer-app --reset-offsets --to-earliest --all-topics --execute
Demo video:
https://drive.google.com/file/d/1eU11392hadTqxR6oMrZvvXlLnke75Hse/view
Source code:
https://gitlab.com/appdev-demos/camel-kafka-vr
Adjust the following files:
src/main/fabric8/swagger-std-route.yml src/main/fabric8/topicview-route.yml src/main/resources/application.properties
open http://analytic-ui-sko.apps.ramalho.openshiftworkshop.com/ oc rsh kafka-0 cd bin ./kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group analyticgroup --reset-offsets --to-earliest --all-topics --execute ./kafka-consumer-groups.sh --bootstrap-server kafka:9092 --group analyticgroup --describe