Problema de Apache Beam con el Spark Runner al utilizar Kafka IO.
Estoy intentando probar KafkaIO para el Código de Apache Beam con un Runner de Spark. El código funciona bien con un Runner Directo. Sin embargo, si agrego la siguiente línea de código, arroja un error: Error: ERROR org.apache.spark.executor.Executor: Exception in task 0.0 in stage 2.0 (TID 0) java.lang.StackOverflowError at java.base/java.io.ObjectInputStream$BlockDataInputStream.readByte(ObjectInputStream.java:3307) . . . Read more