Uses of Interface
io.debezium.heartbeat.HeartbeatErrorHandler
Packages that use HeartbeatErrorHandler
-
Uses of HeartbeatErrorHandler in io.debezium.config
Methods in io.debezium.config with parameters of type HeartbeatErrorHandlerModifier and TypeMethodDescriptionCommonConnectorConfig.createHeartbeat(io.debezium.spi.topic.TopicNamingStrategy topicNamingStrategy, SchemaNameAdjuster schemaNameAdjuster, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler) Deprecated. -
Uses of HeartbeatErrorHandler in io.debezium.heartbeat
Fields in io.debezium.heartbeat declared as HeartbeatErrorHandlerModifier and TypeFieldDescriptionstatic final HeartbeatErrorHandlerHeartbeatErrorHandler.DEFAULT_NOOP_ERRORHANDLERprivate final HeartbeatErrorHandlerDatabaseHeartbeatImpl.errorHandlerprivate final HeartbeatErrorHandlerHeartbeatFactory.errorHandlerMethods in io.debezium.heartbeat with parameters of type HeartbeatErrorHandlerModifier and TypeMethodDescriptionDatabaseHeartbeatFactory.getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) DebeziumHeartbeatFactory.getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) default Heartbeat.ScheduledHeartbeatDebeziumHeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) HeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) Create a heartbeat instance that can be scheduled with some delay based onCommonConnectorConfigConstructors in io.debezium.heartbeat with parameters of type HeartbeatErrorHandlerModifierConstructorDescriptionDatabaseHeartbeatImpl(JdbcConnection jdbcConnection, String heartBeatActionQuery, HeartbeatErrorHandler errorHandler) HeartbeatFactory(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, SchemaNameAdjuster schemaNameAdjuster, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler) Deprecated.
HeartbeatFactoryinstead.