kafka

Documentation

Index

• type Connector
  • func NewKafkaConnector() *Connector
  • func (c *Connector) CloseConnection()
  • func (c *Connector) InitConnection(def *conf.DataSourceDefinition)

Types

type Connector

type Connector struct {
	abstract.ConfigurableConnector
	KafkaAdminClient     *kafka.AdminClient
	SchemaRegistryClient *srclient.SchemaRegistryClient
}

func NewKafkaConnector

func NewKafkaConnector() *Connector

NewKafkaConnector ... Factory

func (*Connector) CloseConnection

func (c *Connector) CloseConnection()

CloseConnection ... Disconnects and deallocates resources

func (*Connector) InitConnection

func (c *Connector) InitConnection(def *conf.DataSourceDefinition)

InitConnection ... Instantiate the connection with the remote service