Class IngestionFailureEvent (1.138.0)
1.149.0 (latest)
1.148.0
1.147.0
1.145.0
1.143.1
1.142.0
1.141.5
1.140.2
1.139.4
1.138.0
1.137.1
1.136.1
1.135.0
1.134.2
1.133.1
1.132.2
1.131.0
1.130.0
1.129.6
1.127.3
1.126.6
1.125.13
1.123.18
1.122.2
1.121.1
1.120.24
1.119.1
1.118.0
1.117.0
1.116.4
1.115.5
public final class IngestionFailureEvent extends GeneratedMessageV3 implements IngestionFailureEventOrBuilder
Payload of the Platform Log entry sent when a failure is encountered while
ingesting.
Protobuf type google.pubsub.v1.IngestionFailureEvent
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Fields
AWS_MSK_FAILURE_FIELD_NUMBER
public static final int AWS_MSK_FAILURE_FIELD_NUMBER
Field Value
Type Description
int
AZURE_EVENT_HUBS_FAILURE_FIELD_NUMBER
public static final int AZURE_EVENT_HUBS_FAILURE_FIELD_NUMBER
Field Value
Type Description
int
CLOUD_STORAGE_FAILURE_FIELD_NUMBER
public static final int CLOUD_STORAGE_FAILURE_FIELD_NUMBER
Field Value
Type Description
int
CONFLUENT_CLOUD_FAILURE_FIELD_NUMBER
public static final int CONFLUENT_CLOUD_FAILURE_FIELD_NUMBER
Field Value
Type Description
int
ERROR_MESSAGE_FIELD_NUMBER
public static final int ERROR_MESSAGE_FIELD_NUMBER
Field Value
Type Description
int
TOPIC_FIELD_NUMBER
public static final int TOPIC_FIELD_NUMBER
Field Value
Type Description
int
Static Methods
getDefaultInstance()
public static IngestionFailureEvent getDefaultInstance ()
getDescriptor()
public static final Descriptors . Descriptor getDescriptor ()
newBuilder()
public static IngestionFailureEvent . Builder newBuilder ()
newBuilder(IngestionFailureEvent prototype)
public static IngestionFailureEvent . Builder newBuilder ( IngestionFailureEvent prototype )
public static IngestionFailureEvent parseDelimitedFrom ( InputStream input )
public static IngestionFailureEvent parseDelimitedFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(byte[] data)
public static IngestionFailureEvent parseFrom ( byte [] data )
Parameter
Name Description
databyte []
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static IngestionFailureEvent parseFrom ( byte [] data , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteString data)
public static IngestionFailureEvent parseFrom ( ByteString data )
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static IngestionFailureEvent parseFrom ( ByteString data , ExtensionRegistryLite extensionRegistry )
public static IngestionFailureEvent parseFrom ( CodedInputStream input )
public static IngestionFailureEvent parseFrom ( CodedInputStream input , ExtensionRegistryLite extensionRegistry )
public static IngestionFailureEvent parseFrom ( InputStream input )
public static IngestionFailureEvent parseFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteBuffer data)
public static IngestionFailureEvent parseFrom ( ByteBuffer data )
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static IngestionFailureEvent parseFrom ( ByteBuffer data , ExtensionRegistryLite extensionRegistry )
parser()
public static Parser<IngestionFailureEvent> parser ()
Methods
equals(Object obj)
public boolean equals ( Object obj )
Parameter
Name Description
objObject
Overrides
getAwsMskFailure()
public IngestionFailureEvent . AwsMskFailureReason getAwsMskFailure ()
Optional. Failure when ingesting from Amazon MSK.
.google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason aws_msk_failure = 4 [(.google.api.field_behavior) = OPTIONAL];
getAwsMskFailureOrBuilder()
public IngestionFailureEvent . AwsMskFailureReasonOrBuilder getAwsMskFailureOrBuilder ()
Optional. Failure when ingesting from Amazon MSK.
.google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason aws_msk_failure = 4 [(.google.api.field_behavior) = OPTIONAL];
getAzureEventHubsFailure()
public IngestionFailureEvent . AzureEventHubsFailureReason getAzureEventHubsFailure ()
Optional. Failure when ingesting from Azure Event Hubs.
.google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason azure_event_hubs_failure = 5 [(.google.api.field_behavior) = OPTIONAL];
getAzureEventHubsFailureOrBuilder()
public IngestionFailureEvent . AzureEventHubsFailureReasonOrBuilder getAzureEventHubsFailureOrBuilder ()
Optional. Failure when ingesting from Azure Event Hubs.
.google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason azure_event_hubs_failure = 5 [(.google.api.field_behavior) = OPTIONAL];
getCloudStorageFailure()
public IngestionFailureEvent . CloudStorageFailure getCloudStorageFailure ()
Optional. Failure when ingesting from Cloud Storage.
.google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure cloud_storage_failure = 3 [(.google.api.field_behavior) = OPTIONAL];
getCloudStorageFailureOrBuilder()
public IngestionFailureEvent . CloudStorageFailureOrBuilder getCloudStorageFailureOrBuilder ()
Optional. Failure when ingesting from Cloud Storage.
.google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure cloud_storage_failure = 3 [(.google.api.field_behavior) = OPTIONAL];
getConfluentCloudFailure()
public IngestionFailureEvent . ConfluentCloudFailureReason getConfluentCloudFailure ()
Optional. Failure when ingesting from Confluent Cloud.
.google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason confluent_cloud_failure = 6 [(.google.api.field_behavior) = OPTIONAL];
getConfluentCloudFailureOrBuilder()
public IngestionFailureEvent . ConfluentCloudFailureReasonOrBuilder getConfluentCloudFailureOrBuilder ()
Optional. Failure when ingesting from Confluent Cloud.
.google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason confluent_cloud_failure = 6 [(.google.api.field_behavior) = OPTIONAL];
getDefaultInstanceForType()
public IngestionFailureEvent getDefaultInstanceForType ()
getErrorMessage()
public String getErrorMessage ()
Required. Error details explaining why ingestion to Pub/Sub has failed.
string error_message = 2 [(.google.api.field_behavior) = REQUIRED];
Returns
Type Description
String The errorMessage.
getErrorMessageBytes()
public ByteString getErrorMessageBytes ()
Required. Error details explaining why ingestion to Pub/Sub has failed.
string error_message = 2 [(.google.api.field_behavior) = REQUIRED];
Returns
Type Description
ByteString The bytes for errorMessage.
getFailureCase()
public IngestionFailureEvent . FailureCase getFailureCase ()
getParserForType()
public Parser<IngestionFailureEvent> getParserForType ()
Overrides
getSerializedSize()
public int getSerializedSize ()
Returns
Type Description
int
Overrides
getTopic()
Required. Name of the import topic. Format is:
projects/{project_name}/topics/{topic_name}.
string topic = 1 [(.google.api.field_behavior) = REQUIRED];
Returns
Type Description
String The topic.
getTopicBytes()
public ByteString getTopicBytes ()
Required. Name of the import topic. Format is:
projects/{project_name}/topics/{topic_name}.
string topic = 1 [(.google.api.field_behavior) = REQUIRED];
Returns
Type Description
ByteString The bytes for topic.
hasAwsMskFailure()
public boolean hasAwsMskFailure ()
Optional. Failure when ingesting from Amazon MSK.
.google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason aws_msk_failure = 4 [(.google.api.field_behavior) = OPTIONAL];
Returns
Type Description
boolean Whether the awsMskFailure field is set.
hasAzureEventHubsFailure()
public boolean hasAzureEventHubsFailure ()
Optional. Failure when ingesting from Azure Event Hubs.
.google.pubsub.v1.IngestionFailureEvent.AzureEventHubsFailureReason azure_event_hubs_failure = 5 [(.google.api.field_behavior) = OPTIONAL];
Returns
Type Description
boolean Whether the azureEventHubsFailure field is set.
hasCloudStorageFailure()
public boolean hasCloudStorageFailure ()
Optional. Failure when ingesting from Cloud Storage.
.google.pubsub.v1.IngestionFailureEvent.CloudStorageFailure cloud_storage_failure = 3 [(.google.api.field_behavior) = OPTIONAL];
Returns
Type Description
boolean Whether the cloudStorageFailure field is set.
hasConfluentCloudFailure()
public boolean hasConfluentCloudFailure ()
Optional. Failure when ingesting from Confluent Cloud.
.google.pubsub.v1.IngestionFailureEvent.ConfluentCloudFailureReason confluent_cloud_failure = 6 [(.google.api.field_behavior) = OPTIONAL];
Returns
Type Description
boolean Whether the confluentCloudFailure field is set.
hashCode()
Returns
Type Description
int
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Overrides
isInitialized()
public final boolean isInitialized ()
Overrides
newBuilderForType()
public IngestionFailureEvent . Builder newBuilderForType ()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected IngestionFailureEvent . Builder newBuilderForType ( GeneratedMessageV3 . BuilderParent parent )
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance ( GeneratedMessageV3 . UnusedPrivateParameter unused )
Returns
Type Description
Object
Overrides
toBuilder()
public IngestionFailureEvent . Builder toBuilder ()
writeTo(CodedOutputStream output)
public void writeTo ( CodedOutputStream output )
Overrides
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2026-03-14 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2026-03-14 UTC."],[],[]]
