Azure/azure-event-hubs-spark

Issues

• The auth docs are wrong - causing service unavailability issues

  #681 opened a year ago by bgavrilMS
  1

• java.util.concurrent.TimeoutException: Futures timed out after [5 minutes]

  #687 opened 5 months ago by pthalasta
  2

• Java 11 support so connector can be used on Synapse?

  #689 opened 3 months ago by wyatt-troia-msft
  0

• pyspark - azure eventhub emulator - com.microsoft.azure.eventhubs.CommunicationException: Connection refused

  #688 opened 4 months ago by smpurkis
  0

• EventHub AAD authentication with Service Principal and Secret . Class Loader could not find AuthBySecretCallBackWithParams class

  #627 opened 3 years ago by seblea
  3

• Support for Spark v3.3.0

  #683 opened 10 months ago by paripooranan20
  1

• Package Support for Scala 2.13 or 3+

  #671 opened 2 years ago by kenny-chalupa
  4

• EventHub Writer fails due to Throttling of EventHub, configuration settings have no impact.

  #679 opened 2 years ago by steffenmarschall
  1

• Azure EventHub - PySpark Failed to configure SaslClientAuthenticator works when using Confluent cloud

  #682 opened a year ago by ozkary
  0

• Azure Event Hub Consumer Group and Partition Id issue with spark streaming

  #655 opened 2 years ago by milinddhotarkar
  2

• ReceiverDisconnectedException even if using different consumer groups

  #680 opened a year ago by HaowenZhangBD
  1

• Spark streaming AvailableNow trigger terminates after first batch

  #656 opened 2 years ago by seb-emmot
  1

• Checkpoint write to blob storage using hadoop configuration

  #674 opened 2 years ago by ddevidence
  3

• Spark streaming kubernetes - Fails to recover from chechpoint. Cannot find endpoint: spark://PartitionPerformanceReceiver

  #678 opened 2 years ago by galexiou
  0

• maxEventsPerTrigger is not working

  #677 opened 2 years ago by thetruelam
  0

• Spark-scala api references for Azure eventhub schema registry

  #676 opened 2 years ago by trsree
  0

• Missing tag for v2.3.22

  #675 opened 2 years ago by preethamrajk
  0

• Error while trying to use use AAD Authentication to Connect Event Hubs with secrets in callback

  #649 opened 2 years ago by Silverutm
  2

• Job for consumption of Event Hub messages aborts on Databricks (request seqNo less than received seqNo)

  #670 opened 2 years ago by relayr-huzaifah
  3

• Batch read from eventhubs throws duration format error

  #673 opened 2 years ago by venkatrajupalepu
  0

• PySpark job doesnt stop on stopping query

  #672 opened 2 years ago by ronban
  0

• EH - Trigger once

  #666 opened 2 years ago by rbushri
  1

• Migrating connector to use azure-messaging-eventhubs (new recommended client library from Azure SDK)

  #630 opened 3 years ago by jesinity
  2

• AAD Authentication is terminated after running for a couple of minutes

  #669 opened 2 years ago by vaiyarUp
  1

• Using Kafka driver for Spark the throughput is 50-80 times faster

  #668 opened 2 years ago by james-tn
  0

• This library or kafka

  #667 opened 2 years ago by epa095
  0

• This repo is missing important files

  #662 opened 2 years ago by microsoft-github-policy-service
  0

• Structured streaming job hangs after a while

  #665 opened 2 years ago by mschou1306
  0

• Spark starts crashing when some of the eventhub partitions go down.

  #664 opened 2 years ago by pablo-statsig
  0

• Databricks Stream job gets stuck and stops processing stream data

  #663 opened 2 years ago by abhisheksingh077a
  0

• Azure Databricks job stops consuming event hub messages.

  #652 opened 2 years ago by ameydeshpande18
  2

• feature request: support authentication with managed service identity

  #660 opened 2 years ago by dgcaron
  0

• Is there an option to set the batch size?

  #626 opened 3 years ago by xavierjohn
  1

• Receive messages from Event Hub kafka timeout

  #643 opened 3 years ago by Scarlettliuyc
  3

• Add Batch Write with properties integration test

  #658 opened 2 years ago by barrotsteindev
  0

• Need help understanding behaviour of offset.

  #657 opened 2 years ago by dhanush1708
  0

• Spark can't deserialize the avro encoded by azure encoder and sent to Event Hub

  #644 opened 3 years ago by Kiran-G1
  2

• Spark streaming suddenly started consuming Kafka Data in EventHub from very beginning

  #651 opened 2 years ago by Guodong-Wang-prog
  3

• Partition Keys are displayed as null though they were produced.

  #648 opened 2 years ago by Kiran-G1
  0

• Read stream from checkpoint when the code is updated.

  #647 opened 2 years ago by udossa
  0

• NoSuchMethodException exception while using ServicePrincipal authentication to EventHub

  #625 opened 3 years ago by pchinta
  1

• Integrate AAD Authentication

  #646 opened 2 years ago by ms-nwiersch
  0

• Missing events during write to event hub, unable to catch exceptions

  #642 opened 3 years ago by Silverutm
  2

• Service Principal Authentication PySpark and Java Spring Boot App

  #640 opened 3 years ago by arrebnac
  0

• Bug setMaxEventsPerTrigger no effect

  #635 opened 3 years ago by RengarLee
  1

• [FEATURE REQUEST]: Support Spark .Net when use AAD Auth

  #629 opened 3 years ago by xinyeah
  0

• Task distribution uneven

  #633 opened 3 years ago by HongyuLi-ms
  0

• fetch data slowly when trigger size is greater than 5k records per partition

  #632 opened 3 years ago by HongyuLi-ms
  0

• Structured streaming fails for timeout on ClientConnection Pool

  #631 opened 3 years ago by alexz00
  0

• Emit time lag metrics to track how old is the data being processed and avoid data loss

  #628 opened 3 years ago by felipepessoto
  1