converter

type Config struct {
	SourceKafka      kafka.Client
	DestKafka        kafka.Client
	NewTopic         string // output topic name
	Force            bool   // perform a null conversion even if the database version is current
	DryRun           bool   // do not publish new manifest
	SafetyInterval   time.Duration
	HotStartStorage  string
	DBVersionHistory []string
	UpgradeSteps     map[string]xform.Transformation
	Survive          func(object wire.ActiveObject, now time.Time) bool
}