Hi Folks,
newbie here so bear with me please :-)
I've created our first event stream service on IBM Cloud. I have created credentials and they work when I try the test client.
However, putting those same credentials into my own client fails with a continuous stream of warning messages:
Cancelled in-flight API_VERSIONS request with correlation id 2 due to node -5 being disconnected (elapsed time since creation: 15ms, elapsed time since send: 15ms, request timeout: 30000ms) (org.apache.kafka.clients.NetworkClient:341)
It comes from this piece of code I think - but it means nothing to me.
kafka/NetworkClient.java at master · a0x8o/kafka
I think the credentials are working fine because if I put a bad key in then it very clearly fails to connect.
I've looked at the test client's code and I think I have set the exact same properties.
Here's my relevant properties:
bootstrap.servers=broker-2-...etc.eventstreams.cloud.ibm.com:9093,etc. etc.
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
username="token" \
password="MY SECRET TOKEN";
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
ssl.protocol=TLSv1.2
ssl.enabled.protocols=TLSv1.2
ssl.endpoint.identification.algorithm=HTTPS
Is this a version issue or something?
It's happening with two different clients that I'm using (producer and consumer)
many thanks for your help !
John.
------------------------------
John Hawkins
Integration Consultant
------------------------------