Uses of Class
com.zendesk.maxwell.producer.AbstractProducer

Packages that use AbstractProducer

Package	Description
com.zendesk.maxwell	top level classes concerned with instantiating and running a Maxwell replicator.
com.zendesk.maxwell.bootstrap	bootstrapping outputs the current dataset into a stream.
com.zendesk.maxwell.monitoring	monitoring, diagnostics, and the HTTP server
com.zendesk.maxwell.producer	producers write to streams and sinks of various types.
com.zendesk.maxwell.replication	concerns the operation of the binlog replicator

Uses of AbstractProducer in com.zendesk.maxwell

Methods in com.zendesk.maxwell that return AbstractProducer

Modifier and Type	Method	Description
AbstractProducer	MaxwellContext.getProducer()	get or build an AbstractProducer based on settings in MaxwellContext.config

Uses of AbstractProducer in com.zendesk.maxwell.bootstrap

Methods in com.zendesk.maxwell.bootstrap with parameters of type AbstractProducer

Modifier and Type	Method	Description
void	SynchronousBootstrapper.completeBootstrap(BootstrapTask task, AbstractProducer producer)	Output a "bootstrap complete" row
void	SynchronousBootstrapper.performBootstrap(BootstrapTask task, AbstractProducer producer, Long currentSchemaID)	Perform bootstrap; query all rows from the table in question, and stream the results from the database into the producer.
void	SynchronousBootstrapper.startBootstrap(BootstrapTask task, AbstractProducer producer, Long currentSchemaID)	Orchestrates the bootstrap process.

Constructors in com.zendesk.maxwell.bootstrap with parameters of type AbstractProducer

Constructor	Description
BootstrapController(ConnectionPool maxwellConnectionPool, AbstractProducer producer, SynchronousBootstrapper bootstrapper, String clientID, boolean syncMode, Long currentSchemaID)	Instantiate a controller

Uses of AbstractProducer in com.zendesk.maxwell.monitoring

Methods in com.zendesk.maxwell.monitoring with parameters of type AbstractProducer

Modifier and Type	Method	Description
MaxwellHealthCheck	MaxwellHealthCheckFactory.createHealthCheck(AbstractProducer producer)

Constructors in com.zendesk.maxwell.monitoring with parameters of type AbstractProducer

Constructor	Description
MaxwellHealthCheck(AbstractProducer producer)

Uses of AbstractProducer in com.zendesk.maxwell.producer

Subclasses of AbstractProducer in com.zendesk.maxwell.producer

Modifier and Type	Class	Description
class	AbstractAsyncProducer
class	AbstractProfilingProducer
class	BufferedProducer
class	FileProducer
class	MaxwellBigQueryProducer
class	MaxwellKafkaProducer
class	MaxwellKinesisProducer
class	MaxwellPubsubProducer
class	MaxwellRedisProducer
class	MaxwellSNSProducer
class	MaxwellSQSProducer
class	NatsProducer
class	NoneProducer
class	ProfilerProducer
class	RabbitmqProducer
class	StdoutProducer

Methods in com.zendesk.maxwell.producer that return AbstractProducer

Modifier and Type	Method	Description
AbstractProducer	ProducerFactory.createProducer(MaxwellContext context)

Uses of AbstractProducer in com.zendesk.maxwell.replication

Constructors in com.zendesk.maxwell.replication with parameters of type AbstractProducer

Constructor	Description
BinlogConnectorReplicator(SchemaStore schemaStore, AbstractProducer producer, BootstrapController bootstrapper, MaxwellMysqlConfig mysqlConfig, Long replicaServerID, String maxwellSchemaDatabaseName, Metrics metrics, Position start, boolean stopOnEOF, String clientID, HeartbeatNotifier heartbeatNotifier, Scripting scripting, Filter filter, boolean ignoreMissingSchema, MaxwellOutputConfig outputConfig, float bufferMemoryUsage, int replicationReconnectionRetries, int binlogEventQueueSize)
BinlogConnectorReplicator(SchemaStore schemaStore, AbstractProducer producer, BootstrapController bootstrapper, MaxwellMysqlConfig mysqlConfig, Long replicaServerID, String maxwellSchemaDatabaseName, Metrics metrics, Position start, boolean stopOnEOF, String clientID, HeartbeatNotifier heartbeatNotifier, Scripting scripting, Filter filter, MaxwellOutputConfig outputConfig, float bufferMemoryUsage, int replicationReconnectionRetries)