Logs corresponding to test run knative-extensions/eventing-kafka-broker#2240 (comment)
To reproduce setup everything needed for Knative and then:
https://github.com/aavarghese/eventing-kafka-broker.git
cd eventing-kafka-broker
git checkout incrementalassignor
./hack/run.sh deploy-source
To run
git clone https://github.com/aslom/reproduce-kafka-source.git
cd reproduce-kafka-source
# optional - if you want to run exactlu the smae test code:
#git checkout 1abba8978e8694e16ebc187c6a0211f89c03ea2b
ko apply -f duplicates1
After few minutes running test do scale Kafka source
kubectl scale --replicas=50 kafkasources/kafka-src50
To gather logs
Knative eventing:
k -n knative-eventing logs -l=app=kafka-source-dispatcher --max-log-requests 10 -f | tee logs-kafka-source-data-plane2.txt
k -n knative-eventing logs -f kafka-source-controller- | tee -a logs-kafka-source-controller2.txt
Test side:
k logs eventdisplay- -f | tee logs-event-display2.txt
k logs duplicates1-kafkaproduce- | tee logs-kafkaproducer2.txt
To monitor test exeuciton:
kubectl run curl --image=curlimages/curl --rm=true --restart=Never -ti -- http://kafkascraper/stats
kubectl -n kafka run kafka-consumer-groups -ti --image=quay.io/strimzi/kafka:0.28.0-kafka-3.1.0 --rm=true --restart=Never -- bin/kafka-consumer-groups.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --describe --group kafka-src50c