Need assistance with testing new cluster #4745
Unanswered
davehouser1
asked this question in
Q&A
Replies: 1 comment 1 reply
-
nm, it works, albite a little unclear for myself.
|
Beta Was this translation helpful? Give feedback.
1 reply
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
Forgive me if this question is out of scope re: strimzi standpoint of view.
Followed these instructions here
Step 4 of Sending and receiving messages from a topic reads:
Open a terminal, and start the Kafka console producer with the topic my-topic:
bin/kafka-console-producer.sh --broker-list <node-address>:_<node-port>_ --topic my-topic
I downloaded and deployed the binary, built gradlew on my personal PC (not on any nodes of my cluster)
I then ran the producer and consumer steps on my personal PC.
They both seem to start up, but If I use a different IP or port (which did not appear when trying to run
kubectl get service my-cluster-kafka-external-bootstrap -n my-kafka-project -o=jsonpath='{.spec.ports[0].nodePort}{"\n"}'
andkubectl get nodes --output=jsonpath='{range .items[*]}{.status.addresses[?(@.type=="InternalIP")].address}{"\n"}{end}'
) and I see the same output.Does not seem right.
Also the step that says "Verify that you see the incoming messages in the consumer console."
how? Do I just start typing in one screen?
can you clarify how to perform a successful test with the deployment I made?
Beta Was this translation helpful? Give feedback.
All reactions