search

confluentinc / ide-sidecar

Sidecar application used by Confluent for VS Code, as a local proxy for Confluent Cloud, Confluent Platform and local Kafka clusters, to help users build streaming applications.
Apache License 2.0
3 stars 3 forks source link

Retry get topic after creating in create topic Kafka REST implementation #114

Closed rohitsanj closed 2 weeks ago

rohitsanj commented 3 weeks ago

We try to get the topic as soon as it is created in our internal Kafka REST implementation - https://github.com/confluentinc/ide-sidecar/blob/main/src/main/java/io/confluent/idesidecar/restapi/kafkarest/TopicManagerImpl.java#L53-L57, this has been shown to sometimes fail in our tests and adding a retry here will make the implementation more robust.

This is recommended in the Javadoc for UnknownTopicOrPartitionException as well, "This exception is retriable because the topic or partition might subsequently be created." (https://kafka.apache.org/20/javadoc/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.html)