public static interface IngestionFailureEvent.AwsMskFailureReasonOrBuilder extends MessageOrBuilderImplements
MessageOrBuilderMethods
getApiViolationReason()
public abstract IngestionFailureEvent.ApiViolationReason getApiViolationReason()Optional. The Pub/Sub API limits prevented the desired message from being published.
.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason api_violation_reason = 5 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
IngestionFailureEvent.ApiViolationReason |
The apiViolationReason. |
getApiViolationReasonOrBuilder()
public abstract IngestionFailureEvent.ApiViolationReasonOrBuilder getApiViolationReasonOrBuilder()Optional. The Pub/Sub API limits prevented the desired message from being published.
.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason api_violation_reason = 5 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
IngestionFailureEvent.ApiViolationReasonOrBuilder |
|
getClusterArn()
public abstract String getClusterArn()Optional. The ARN of the cluster of the topic being ingested from.
string cluster_arn = 1 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
String |
The clusterArn. |
getClusterArnBytes()
public abstract ByteString getClusterArnBytes()Optional. The ARN of the cluster of the topic being ingested from.
string cluster_arn = 1 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for clusterArn. |
getKafkaTopic()
public abstract String getKafkaTopic()Optional. The name of the Kafka topic being ingested from.
string kafka_topic = 2 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
String |
The kafkaTopic. |
getKafkaTopicBytes()
public abstract ByteString getKafkaTopicBytes()Optional. The name of the Kafka topic being ingested from.
string kafka_topic = 2 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for kafkaTopic. |
getOffset()
public abstract long getOffset()Optional. The offset within the partition of the message that failed to be ingested.
int64 offset = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
long |
The offset. |
getPartitionId()
public abstract long getPartitionId()Optional. The partition ID of the message that failed to be ingested.
int64 partition_id = 3 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
long |
The partitionId. |
getReasonCase()
public abstract IngestionFailureEvent.AwsMskFailureReason.ReasonCase getReasonCase()| Returns | |
|---|---|
| Type | Description |
IngestionFailureEvent.AwsMskFailureReason.ReasonCase |
|
hasApiViolationReason()
public abstract boolean hasApiViolationReason()Optional. The Pub/Sub API limits prevented the desired message from being published.
.google.pubsub.v1.IngestionFailureEvent.ApiViolationReason api_violation_reason = 5 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
boolean |
Whether the apiViolationReason field is set. |