[FLINK-6928] Kafka sink: default topic should not need to exist

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.2.1, 1.3.0
• Component/s: Connectors / Kafka
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Erik van Oosten
• Created: 15/Jun/17 08:27
• Updated: 16/Dec/21 22:38

Description

When using a Kafka sink, the defaultTopic needs to exist even when it is never used. It would be nice if fetching partition information for the default topic would be delayed until the moment a topic is actually used.

Cause: FlinkKafkaProducerBase.open fetches partition information for the default topic.

In addition, it would be nice if we could signal that the defaultTopic is not needed by passing null. Currently, a value for the defaultTopic is required.