<p>Query [id = 9e2b21d4-039a-4272-bcbf-010136588c7d, runId = 8acd600c-9bac-44d6-b216-3e7c8bb4b6af] terminated with exception: Timeout expired after 60000milliseconds while awaiting InitProducerId</p>


<pre><code>
      org.apache.spark.sql.streaming.StreamingQueryException: Timeout expired after 60000milliseconds while awaiting InitProducerId
=== Streaming Query ===
Identifier: [id = 9e2b21d4-039a-4272-bcbf-010136588c7d, runId = 8acd600c-9bac-44d6-b216-3e7c8bb4b6af]
Current Committed Offsets: {}
Current Available Offsets: {KafkaV2[Subscribe[topic-37]]: {&#34;topic-37&#34;:{&#34;0&#34;:5}}}

Current State: ACTIVE
Thread State: RUNNABLE

Logical Plan:
Project [value#5235]
+- StreamingDataSourceV2Relation [key#5234, value#5235, topic#5236, partition#5237, offset#5238L, timestamp#5239, timestampType#5240], org.apache.spark.sql.kafka010.KafkaSourceProvider$KafkaScan@277878f1, KafkaV2[Subscribe[topic-37]]

      at org.apache.spark.sql.execution.streaming.StreamExecution.org$apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.scala:353)
      at org.apache.spark.sql.execution.streaming.StreamExecution$$anon$1.run(StreamExecution.scala:244)
      Cause: org.apache.kafka.common.errors.TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId
      at
</code></pre>