Package io.github.flink.gcp.connector.pubsub.deadletter

package io.github.flink.gcp.connector.pubsub.deadletter

Related Packages

Package	Description
io.github.flink.gcp.connector.pubsub	Google Cloud Pub/Sub connector for Apache Flink: an at-least-once sink with dynamic per-record topic destinations, and an at-least-once source consuming one or more subscriptions.
io.github.flink.gcp.connector.pubsub.sink
io.github.flink.gcp.connector.pubsub.source
io.github.flink.gcp.connector.pubsub.table

Classes

Class	Description
PubSubDeadLetterQueue	A DeadLetterQueue publishing every terminally failed element to a Pub/Sub topic, used through FailureHandler.sendToDeadLetterQueue(DeadLetterQueue).
PubSubDeadLetterQueue.Builder	Builder for PubSubDeadLetterQueue.