Hello guys,
I tried to run this on my databricks cluster but it does not work. I tried all the work around mentioned in previous comments but still it does not work. Can you please let me know the fix?
command-4117866950448516:19: error: value create is not a member of object com.microsoft.azure.eventhubs.EventHubClient
val eventHubClient = EventHubClient.create(connStr.toString(), pool)
⚠Do not edit this section. It is required for docs.microsoft.com ➟ GitHub issue linking.
Thanks for the feedback and bringing this to our notice . At this time we are reviewing the feedback and will update the document as appropriate .
@prashant-kumar-mishra Thanks for reaching out on this. Just wanted to check if you have tried using com.microsoft.azure:azure-eventhubs-spark_2.11:2.3.14.1 by changing EventHubClient.create(connStr.toString(), pool) to EventHubClient.createFromConnectionString(connStr.toString(), pool)
Thanks Kranthi, I used the same and it worked for me.
@prashant-kumar-mishra We will now proceed to close this thread. If there are further questions regarding this matter, please comment and we will gladly continue the discussion.
Most helpful comment
@prashant-kumar-mishra Thanks for reaching out on this. Just wanted to check if you have tried using
com.microsoft.azure:azure-eventhubs-spark_2.11:2.3.14.1by changingEventHubClient.create(connStr.toString(), pool)toEventHubClient.createFromConnectionString(connStr.toString(), pool)