I know this is related to Kafka but it happens during the Spark Structured Streaming job that's why I am asking on this mailing list.
How would you debug this or get around this in Spark Structured Streaming? Any tips would be appreciated. Thanks.
java.lang.IllegalStateException: Cannot perform operation after producer has been closed