AbsaOSS / AbsaOSS/spline-spark-agent

Getting error while connecting tryng to use Kafka dispatcher

Offen
#755 1 Kommentar 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
Vorherrschende Sprache
Scala
Sterne
210
Forks
102
Ø Merge
1 T. 1 Std.
Gemergte PRs (30 T.)
1

Beschreibung

I am trying to use Kafka dispatcher but getting below error in driver logs. I am using version 1.2.0 with spark 3.3.0

23/10/17 08:46:03 INFO SparkLineageInitializer: Initializing Spline Agent...
23/10/17 08:46:03 INFO SparkLineageInitializer: Spline Version: 1.2.0 (rev. f66d36f)
23/10/17 08:46:03 INFO SparkLineageInitializer: Init Type: AUTO (codeless)
23/10/17 08:46:03 INFO SparkLineageInitializer: Init Mode: ENABLED
23/10/17 08:46:03 ERROR DriverDaemon$: XXX Fatal uncaught exception. Terminating driver.
java.lang.NoClassDefFoundError: org/apache/kafka/clients/producer/Producer

Caused by: java.lang.ClassNotFoundException: org.apache.kafka.clients.producer.Producer

am I missing some configurations?

Beitragsleitfaden

Für dieses Repository ist kein Beitragsleitfaden indexiert

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.