Hi,
I'm trying Getting Started with Snowpipe Streaming and Amazon MSK quickstarts and i found a lot of issues starting from point 5 of page 2: Install the Kafka connector for Snowpipe streaming
leaving aside typo as fixed path of the home (directory=/home/azureuser/snowpipe-streaming)
I setted a real password instead changeit (passwd=changeit # Use the default password for the Java keystore, you should change it after finishing the lab)
And use the same value on the point 7 (7. Create a configuration file) and in the point 8 (8. Create a security client.properties configuration file for the producer) of the quickstart.
But when I get to the point 9 (9. Create a streaming topic called "streaming" in the MSK cluster)
I got this error:
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
...
...
Caused by: org.apache.kafka.common.KafkaException: Failed to load SSL keystore /tmp/kafka.client.truststore.jks of type JKS
...
...
Caused by: java.security.UnrecoverableKeyException: Password verification failed
at sun.security.provider.JavaKeyStore.engineLoad(JavaKeyStore.java:790)
... 20 more
And I don't know how to resolve it.
Stefano G.
Desktop (please complete the following information):
Hi, I'm trying Getting Started with Snowpipe Streaming and Amazon MSK quickstarts and i found a lot of issues starting from point 5 of page 2: Install the Kafka connector for Snowpipe streaming
URL of quickstart
leaving aside typo as fixed path of the home (
directory=/home/azureuser/snowpipe-streaming
) I setted a real password instead changeit (passwd=changeit # Use the default password for the Java keystore, you should change it after finishing the lab
)And use the same value on the point 7 (7. Create a configuration file) and in the point 8 (8. Create a security client.properties configuration file for the producer) of the quickstart.
But when I get to the point 9 (9. Create a streaming topic called "streaming" in the MSK cluster) I got this error:
And I don't know how to resolve it.
Stefano G.
Desktop (please complete the following information):