tokafka

Documentation

Index

• Variables
• func NewTo(parent charm.Command, fs *flag.FlagSet) (charm.Command, error)
• type To
  • func (t *To) Run(args []string) error

Variables

var ToSpec = &charm.Spec{
	Name:  "to-kafka",
	Usage: "to-kafka [options]",
	Short: "sync a Zed lake pool to a Kafka topic",
	Long: `
The "to-kafka" command syncs data from a Zed lake to a Kafka topic acting
as a source of Zed data for Kafka.
The Zed records are transcoded from Zed to Avro and synced
to the target Kafka topic.
The data pool must have the pool key "kafka.offset" sorted
in ascending order.

Only a single writer is allowed at any given time to the Kafka topic.
At start up, the to command queries the topic for its high-water mark
and continues replicating data from the source data pool at that offset
according to the kafka.offset value in the data pool.
`,
	New: NewTo,
}

Functions

func NewTo

func NewTo(parent charm.Command, fs *flag.FlagSet) (charm.Command, error)

Types

type To

type To struct {
	*root.Command
	// contains filtered or unexported fields
}

func (*To) Run

func (t *To) Run(args []string) error