[IGNITE-18486] IgniteToKafkaCdcStreamer implicitely creates topic with wrong partitions number

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: extensions
• Labels: IEP-59 ise
• Ignite Flags: Docs Required, Release Notes Required
• Assignee: Unassigned
• Reporter: Sergey Korotkov
• Created: 29/Dec/22 08:22
• Updated: 29/Dec/22 09:14

Description

If Kafka topic specified in the IgniteToKafkaCdcStreamer's property is absent it's created implicitely with the default number of partitions (which is 1).

INFO [KafkaApi-1] Auto creation of topic ignite with 1 partitions and replication factor 1 is successful (kafka.server.KafkaApis)

So IgniteToKafkaCdcStreamer ignores the kafkaPartitions property in this case.

Looks like that IgniteToKafkaCdcStreamer should either refuse to work if topic is absent or create it respecting the kafkaPartitions property.