I am trying to setup Kafka connector to sink messages into Astra. I am working from the
conf/cassandra-sink-standalone.properties.sample
file provided in the connector zip. I am having trouble with authentication though.
The docs on the Datastax Kafka connector page seem to say that I should use DSE or GSSAPI or None. However, in the `connect-standalone.properties` template, it says "Authentication provider to use, if any. Valid choices: None, PLAIN, GSSAPI."
And indeed, if I try DSE it errors out saying:
[2020-08-25 21:11:49,758] ERROR WorkerSinkTask{id=cassandra-sink-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask) org.apache.kafka.common.config.ConfigException: Invalid value DSE for configuration auth.provider: valid values are None, PLAIN, GSSAPI
On the other hand, if I use PLAIN, I'm getting a different error, perhaps because of some other setting. Now it says:
[2020-08-25 20:58:44,186] WARN [s1|<my_host>-us-east1.db.astra.datastax.com:30185:413ab5b7-63ea-4d90-9fa6-57d40766c08a] Error while opening new ch annel (DriverTimeoutException: [s1|id: 0xeba1f6f0, L:/172.20.10.21:37394 - R:<my_host>-us-east1.db.astra.datastax.com/34.73.106.126:30185] Protocol initialization request, step 2 (AUTH_RESPONSE): timed out after 500 ms) (com.datastax.oss.driver.internal.core.pool.ChannelPoo ERROR WorkerSinkTask{id=cassandra-sink-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask) java.lang.RuntimeException: Prepare failed for statement: ... Caused by: com.datastax.oss.driver.api.core.NoNodeAvailableException: No node was available to execute the query
Is this an Authentication problem, since it is saying that it is failing in AUTH_RESPONSE above. Or I am doing something else wrong?