Método foreach() con errores de Spark Streaming.
Estoy intentando escribir datos extraídos de Kafka en una tabla de Bigquery cada 120 segundos. Me gustaría realizar algunas operaciones adicionales que, según la documentación, deberían ser posibles dentro del método .foreach() o foreachBatch(). Como prueba, quería imprimir un mensaje simple cada vez que se extraen datos de Kafka y . . . Read more