adapter

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

type Packet struct {
	EventName string
	Payload   []byte
	Offset    int64
}

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

type SourceConfig struct {
	Sources map[string]SourceInfo `json:"sources"`
}

type SourceInfo struct {
	Hosts       []string `json:"hosts"`
	Topic       string   `json:"topic"`
	GroupId     string   `json:"groupId"`
	WorkerCount *int     `json:"worker_count,omitempty"`
}

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