chore(kafka): remove public comments

Signed-off-by: Jonas Beck <dev@jonasbeck.dk>
This commit is contained in:
Jonas Beck
2025-07-29 16:41:36 +02:00
parent a3ff3fba03
commit aa83cc0d50
3 changed files with 0 additions and 11 deletions
@@ -25,8 +25,6 @@ import { loggerServiceAdapter } from './LoggerServiceAdapter';
* KafkaConsumerClient
*
* This class creates the Kafka client that will be used to create the KafkaConsumingEventPublisher
*
* @public
*/
export class KafkaConsumerClient {
private readonly kafka: Kafka;
@@ -21,11 +21,8 @@ import { KafkaConsumerConfig } from './config';
type EventMetadata = EventParams['metadata'];
/**
*
* This class subscribes to Kafka topics and publishes events received to the registered subscriber.
* The message payload will be used as the event payload and passed to the subscribers.
*
* @public
*/
export class KafkaConsumingEventPublisher {
private readonly kafkaConsumer: Consumer;
@@ -17,18 +17,12 @@ import { Config, readDurationFromConfig } from '@backstage/config';
import { durationToMilliseconds } from '@backstage/types';
import { ConsumerConfig, ConsumerSubscribeTopics, KafkaConfig } from 'kafkajs';
/**
* @public
*/
export interface KafkaConsumerConfig {
backstageTopic: string;
consumerConfig: ConsumerConfig;
consumerSubscribeTopics: ConsumerSubscribeTopics;
}
/**
* @public
*/
export interface KafkaEventSourceConfig {
kafkaConfig: KafkaConfig;
kafkaConsumerConfigs: KafkaConsumerConfig[];