kafka

package
v1.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 16, 2026 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Overview

Package kafka 实现 kafka binder：Topic/Consumer Group/Schema/Connect/ACL 管理。

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Kafka 

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

Kafka binder。

func New 

func New(appCtx context.Context, lang LangProvider, pool *sshpool.Pool) *Kafka

New 构造 kafka binder。

func (*Kafka) Cleanup 

func (k *Kafka) Cleanup()

Cleanup 关闭 kafka 客户端连接。

func (*Kafka) KafkaAlterTopicConfig 

func (k *Kafka) KafkaAlterTopicConfig(req kafka_svc.AlterTopicConfigRequest) (kafka_svc.TopicOperationResponse, error)

func (*Kafka) KafkaBrowseMessages 

func (k *Kafka) KafkaBrowseMessages(req kafka_svc.BrowseMessagesRequest) (kafka_svc.BrowseMessagesResponse, error)

func (*Kafka) KafkaCheckSchemaCompatibility 

func (k *Kafka) KafkaCheckSchemaCompatibility(req kafka_svc.CheckSchemaCompatibilityRequest) (kafka_svc.CheckSchemaCompatibilityResponse, error)

func (*Kafka) KafkaClusterOverview 

func (k *Kafka) KafkaClusterOverview(assetID int64) (kafka_svc.ClusterOverview, error)

func (*Kafka) KafkaCreateACL 

func (k *Kafka) KafkaCreateACL(req kafka_svc.CreateACLRequest) (kafka_svc.ACLMutationResponse, error)

func (*Kafka) KafkaCreateConnector 

func (k *Kafka) KafkaCreateConnector(req kafka_svc.ConnectorConfigRequest) (kafka_svc.ConnectorOperationResponse, error)

func (*Kafka) KafkaCreateTopic 

func (k *Kafka) KafkaCreateTopic(req kafka_svc.CreateTopicRequest) (kafka_svc.TopicOperationResponse, error)

func (*Kafka) KafkaDeleteACL 

func (k *Kafka) KafkaDeleteACL(req kafka_svc.DeleteACLRequest) (kafka_svc.ACLMutationResponse, error)

func (*Kafka) KafkaDeleteConnector 

func (k *Kafka) KafkaDeleteConnector(assetID int64, cluster string, name string) (kafka_svc.ConnectorOperationResponse, error)

func (*Kafka) KafkaDeleteConsumerGroup 

func (k *Kafka) KafkaDeleteConsumerGroup(assetID int64, group string) (kafka_svc.DeleteConsumerGroupResponse, error)

func (*Kafka) KafkaDeleteRecords 

func (k *Kafka) KafkaDeleteRecords(req kafka_svc.DeleteRecordsRequest) (kafka_svc.DeleteRecordsResponse, error)

func (*Kafka) KafkaDeleteSchema 

func (k *Kafka) KafkaDeleteSchema(req kafka_svc.DeleteSchemaRequest) (kafka_svc.DeleteSchemaResponse, error)

func (*Kafka) KafkaDeleteTopic 

func (k *Kafka) KafkaDeleteTopic(assetID int64, topic string) (kafka_svc.TopicOperationResponse, error)

func (*Kafka) KafkaGetBrokerConfig 

func (k *Kafka) KafkaGetBrokerConfig(assetID int64, brokerID int32) (kafka_svc.BrokerConfigResponse, error)

func (*Kafka) KafkaGetConnector 

func (k *Kafka) KafkaGetConnector(assetID int64, cluster string, name string) (kafka_svc.KafkaConnectorDetail, error)

func (*Kafka) KafkaGetConsumerGroup 

func (k *Kafka) KafkaGetConsumerGroup(assetID int64, group string) (kafka_svc.ConsumerGroupDetail, error)

func (*Kafka) KafkaGetSchema 

func (k *Kafka) KafkaGetSchema(assetID int64, subject string, version string) (kafka_svc.SchemaVersionDetail, error)

func (*Kafka) KafkaGetSchemaSubjectVersions 

func (k *Kafka) KafkaGetSchemaSubjectVersions(assetID int64, subject string) (kafka_svc.SchemaSubjectVersions, error)

func (*Kafka) KafkaGetTopic 

func (k *Kafka) KafkaGetTopic(assetID int64, topic string) (kafka_svc.TopicDetail, error)

func (*Kafka) KafkaIncreasePartitions 

func (k *Kafka) KafkaIncreasePartitions(req kafka_svc.IncreasePartitionsRequest) (kafka_svc.TopicOperationResponse, error)

func (*Kafka) KafkaListACLs 

func (k *Kafka) KafkaListACLs(req kafka_svc.ListACLsRequest) (kafka_svc.ListACLsResponse, error)

func (*Kafka) KafkaListBrokers 

func (k *Kafka) KafkaListBrokers(assetID int64) ([]kafka_svc.Broker, error)

func (*Kafka) KafkaListClusterConfigs 

func (k *Kafka) KafkaListClusterConfigs(assetID int64) (kafka_svc.ClusterConfigsResponse, error)

func (*Kafka) KafkaListConnectClusters 

func (k *Kafka) KafkaListConnectClusters(assetID int64) ([]kafka_svc.KafkaConnectCluster, error)

func (*Kafka) KafkaListConnectors 

func (k *Kafka) KafkaListConnectors(req kafka_svc.ListConnectorsRequest) ([]kafka_svc.KafkaConnectorSummary, error)

func (*Kafka) KafkaListConsumerGroups 

func (k *Kafka) KafkaListConsumerGroups(assetID int64) ([]kafka_svc.ConsumerGroup, error)

func (*Kafka) KafkaListSchemaSubjects 

func (k *Kafka) KafkaListSchemaSubjects(assetID int64) ([]string, error)

func (*Kafka) KafkaListTopics 

func (k *Kafka) KafkaListTopics(req kafka_svc.ListTopicsRequest) (kafka_svc.ListTopicsResponse, error)

func (*Kafka) KafkaPauseConnector 

func (k *Kafka) KafkaPauseConnector(assetID int64, cluster string, name string) (kafka_svc.ConnectorOperationResponse, error)

func (*Kafka) KafkaProduceMessage 

func (k *Kafka) KafkaProduceMessage(req kafka_svc.ProduceMessageRequest) (kafka_svc.ProduceMessageResponse, error)

func (*Kafka) KafkaRegisterSchema 

func (k *Kafka) KafkaRegisterSchema(req kafka_svc.RegisterSchemaRequest) (kafka_svc.RegisterSchemaResponse, error)

func (*Kafka) KafkaResetConsumerGroupOffset 

func (k *Kafka) KafkaResetConsumerGroupOffset(req kafka_svc.ResetConsumerGroupOffsetRequest) (kafka_svc.ResetConsumerGroupOffsetResponse, error)

func (*Kafka) KafkaRestartConnector 

func (k *Kafka) KafkaRestartConnector(req kafka_svc.RestartConnectorRequest) (kafka_svc.ConnectorOperationResponse, error)

func (*Kafka) KafkaResumeConnector 

func (k *Kafka) KafkaResumeConnector(assetID int64, cluster string, name string) (kafka_svc.ConnectorOperationResponse, error)

func (*Kafka) KafkaUpdateConnectorConfig 

func (k *Kafka) KafkaUpdateConnectorConfig(req kafka_svc.ConnectorConfigRequest) (kafka_svc.ConnectorOperationResponse, error)

func (*Kafka) Service 

func (k *Kafka) Service() *kafka_svc.Service

Service 返回底层 kafka 服务，供 ai binder 在 chat ctx 中注入。

func (*Kafka) Startup 

func (k *Kafka) Startup(ctx context.Context)

Startup 保存 Wails ctx。

type LangProvider 

type LangProvider interface {
	Lang() string
}

LangProvider 由 system binder 实现。

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.