LogCorner.EduSync.Speech.ServiceBus

start zookeeper-server

zookeeper-server-start.bat config\zookeeper.properties

#start kafka-server kafka-server-start.bat config\server.properties

create a topic first_topic

kafka-topics --zookeeper 127.0.0.1:2181 --topic speech --create --partitions 3 --replication-factor 1 kafka-topics --zookeeper 127.0.0.1:2181 --topic eventbus --create --partitions 3 --replication-factor 1

kafka-topics --zookeeper 127.0.0.1:2181 --topic second_topic --create --partitions 3 --replication-factor 1

#list topic kafka-topics --zookeeper 127.0.0.1:2181 --list

#describe topic kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --describe

#list topic kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --describe

#delete topic #list topic kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --delete

#producer kafka-console-producer kafka-console-producer --broker-list 127.0.0.1:9092 --topic first_topic

#consume kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic first_topic

#consume from beginning kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic first_topic --from-beginning

##ELASTIC SEARCH

delete speechindex

GET speechindex/_search { "query": { "match_all": {} } } curl -X GET "http://localhost:9200/speech/_search?pretty"

#KIBANA bin/kibana http://localhost:5601

http://localhost:5601/app/dev_tools#/console

SAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAV => https://dev.azure.com/logcorner-workshop/_git/EventSourcingCQRS-mongo-event-store

docker network create speech_network

ng serve --configuration=docker

/************************* TELEMETRY ********************************/ Set up Zipkin for distributed tracing kubectl create ns opentelemetry kubectl create deployment zipkin --image openzipkin/zipkin -n opentelemetry

kubectl expose deployment zipkin --type ClusterIP --port 9411 -n opentelemetry kubectl port-forward svc/zipkin 9411:9411 -n opentelemetry

Install Jaeger

helm repo add jaegertracing https://jaegertracing.github.io/helm-charts helm install jaeger-operator jaegertracing/jaeger-operator kubectl apply -f jaeger-operator.yml

Wait for Jaeger to be up and running

kubectl wait deploy --selector app.kubernetes.io/name=jaeger --for=condition=available

kubectl port-forward svc/jaeger-query 16686