spark-sql-kafka-offset-committer

spark-sql-kafka-offset-committer copied to clipboard

Hi there HeartSaVioR. You are a legend in this space for providing a library to commit offsets back to Kafka. I have various businesses that require monitoring of consumers and...

galakfryar

Getting exception while using `spark-sql-kafka-offset-committer` Version: ``` net.heartsavior.spark spark-sql-kafka-offset-committer_2.12 0.4.0-spark-3.0 ``` Error: 23/12/06 05:25:45 ERROR Utils: uncaught error in thread spark-listener-group-streams, stopping SparkContext java.lang.NoSuchMethodError: 'org.apache.spark.sql.connector.read.InputPartition org.apache.spark.sql.execution.datasources.v2.DataSourceRDDPartition.inputPartition()' at org.apache.spark.sql.kafka010.KafkaSourceInspector.$anonfun$extractSourceTopicsFromDataSourceV2$2(KafkaSourceInspector.scala:112) at scala.collection.TraversableLike.$anonfun$flatMap$1(TraversableLike.scala:293)...

kishoreraj05