kafka

package

v0.4.7-debug Latest Latest Go to latest Published: Nov 25, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type KafkaService struct {
	// contains filtered or unexported fields
}

func NewKafkaService(kafkaAdmin client.KafkaAdmin, opts KafkaServiceOpts) *KafkaService

func (ks *KafkaService) ScanKafkaResources(clusterType kafkatypes.ClusterType) (*types.KafkaAdminClientInformation, error)

ScanKafkaResources scans all Kafka-related resources and populates the cluster information

type KafkaServiceOpts struct {
	AuthType   types.AuthType
	ClusterArn string
}