.option('kafka.session.timeout.ms', 200000)
.option('group.max.session.timeout.ms', 7200000)

• kafka.session.timeout.ms: Specifies the timeout for detecting consumer failures.
• group.max.session.timeout.ms: Sets the maximum allowed session timeout for a consumer group.