tripl-ai / arc-kafka-pipeline-plugin Goto Github PK

Can we add a feature allowing KafkaExtract & KafkaLoad to use an external schema registry? Or is there any workaround to integrate Spark Structured Streaming with the Confluent Schema Registry?

I am using kafkaload to push data to kafka which is running in container locally. Stage is successful but I dont see any messages in kafka..

{ "type": "KafkaLoad", "name": "write customer to kafka", "environments": [ "production", "test" ], "inputView": "customer_json", "bootstrapServers": "localhost:9092", "topic": "customer-updated" }