[BEAM-11880] KafkaIO doesn’t work with Direct Runner on Python SDK

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Won't Fix
• Fix Version/s: Missing
• Component/s: cross-language, io-py-kafka, sdk-py-core
• Assignee: Unassigned
• Reporter: Nir Gazit
• Created: 26/Feb/21 22:39
• Updated: 13/Jan/22 21:49
• Resolved: 17/May/21 23:57

Description

When running a pipeline that reads from KAFKA it seems to be stuck in a loop resetting the offset all the time but never actually reading anything.