Function getTopicResolver

worker/src/common/kafka-topic-resolver.ts:95–100

(config?: TopicResolverConfig)

 * Get or create the singleton topic resolver
 */
export function getTopicResolver(config?: TopicResolverConfig): KafkaTopicResolver {
  if (!resolver) {
    resolver = new KafkaTopicResolver(config);
  }
  return resolver;
}

/**
 * Reset the singleton (useful for testing)