diff --git a/google-cloud-dialogflow-cx/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SessionsClient.java b/google-cloud-dialogflow-cx/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SessionsClient.java
index 9597e0e6e..49d178e9d 100644
--- a/google-cloud-dialogflow-cx/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SessionsClient.java
+++ b/google-cloud-dialogflow-cx/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SessionsClient.java
@@ -241,6 +241,7 @@ public final UnaryCallable<DetectIntentRequest, DetectIntentResponse> detectInte
    *           .setQueryParams(QueryParameters.newBuilder().build())
    *           .setQueryInput(QueryInput.newBuilder().build())
    *           .setOutputAudioConfig(OutputAudioConfig.newBuilder().build())
+   *           .setEnablePartialResponse(true)
    *           .build();
    *   bidiStream.send(request);
    *   for (StreamingDetectIntentResponse response : bidiStream) {
diff --git a/google-cloud-dialogflow-cx/src/test/java/com/google/cloud/dialogflow/cx/v3beta1/SessionsClientTest.java b/google-cloud-dialogflow-cx/src/test/java/com/google/cloud/dialogflow/cx/v3beta1/SessionsClientTest.java
index e7ae72dac..24be9722c 100644
--- a/google-cloud-dialogflow-cx/src/test/java/com/google/cloud/dialogflow/cx/v3beta1/SessionsClientTest.java
+++ b/google-cloud-dialogflow-cx/src/test/java/com/google/cloud/dialogflow/cx/v3beta1/SessionsClientTest.java
@@ -90,6 +90,7 @@ public void detectIntentTest() throws Exception {
             .setQueryResult(QueryResult.newBuilder().build())
             .setOutputAudio(ByteString.EMPTY)
             .setOutputAudioConfig(OutputAudioConfig.newBuilder().build())
+            .setAllowCancellation(true)
             .build();
     mockSessions.addResponse(expectedResponse);
 
@@ -158,6 +159,7 @@ public void streamingDetectIntentTest() throws Exception {
             .setQueryParams(QueryParameters.newBuilder().build())
             .setQueryInput(QueryInput.newBuilder().build())
             .setOutputAudioConfig(OutputAudioConfig.newBuilder().build())
+            .setEnablePartialResponse(true)
             .build();
 
     MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>();
@@ -188,6 +190,7 @@ public void streamingDetectIntentExceptionTest() throws Exception {
             .setQueryParams(QueryParameters.newBuilder().build())
             .setQueryInput(QueryInput.newBuilder().build())
             .setOutputAudioConfig(OutputAudioConfig.newBuilder().build())
+            .setEnablePartialResponse(true)
             .build();
 
     MockStreamObserver<StreamingDetectIntentResponse> responseObserver = new MockStreamObserver<>();
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/Agent.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/Agent.java
index 32079a43a..48ef73d65 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/Agent.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/Agent.java
@@ -325,14 +325,16 @@ public com.google.protobuf.ByteString getDisplayNameBytes() {
    *
    *
    * <pre>
-   * Immutable. The default language of the agent as a language tag.
+   * Required. Immutable. The default language of the agent as a language tag.
    * See [Language
    * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
    * for a list of the currently supported language codes.
    * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
    * </pre>
    *
-   * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+   * <code>
+   * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+   * </code>
    *
    * @return The defaultLanguageCode.
    */
@@ -352,14 +354,16 @@ public java.lang.String getDefaultLanguageCode() {
    *
    *
    * <pre>
-   * Immutable. The default language of the agent as a language tag.
+   * Required. Immutable. The default language of the agent as a language tag.
    * See [Language
    * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
    * for a list of the currently supported language codes.
    * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
    * </pre>
    *
-   * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+   * <code>
+   * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+   * </code>
    *
    * @return The bytes for defaultLanguageCode.
    */
@@ -1566,14 +1570,16 @@ public Builder setDisplayNameBytes(com.google.protobuf.ByteString value) {
      *
      *
      * <pre>
-     * Immutable. The default language of the agent as a language tag.
+     * Required. Immutable. The default language of the agent as a language tag.
      * See [Language
      * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
      * for a list of the currently supported language codes.
      * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
      * </pre>
      *
-     * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+     * <code>
+     * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+     * </code>
      *
      * @return The defaultLanguageCode.
      */
@@ -1592,14 +1598,16 @@ public java.lang.String getDefaultLanguageCode() {
      *
      *
      * <pre>
-     * Immutable. The default language of the agent as a language tag.
+     * Required. Immutable. The default language of the agent as a language tag.
      * See [Language
      * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
      * for a list of the currently supported language codes.
      * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
      * </pre>
      *
-     * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+     * <code>
+     * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+     * </code>
      *
      * @return The bytes for defaultLanguageCode.
      */
@@ -1618,14 +1626,16 @@ public com.google.protobuf.ByteString getDefaultLanguageCodeBytes() {
      *
      *
      * <pre>
-     * Immutable. The default language of the agent as a language tag.
+     * Required. Immutable. The default language of the agent as a language tag.
      * See [Language
      * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
      * for a list of the currently supported language codes.
      * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
      * </pre>
      *
-     * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+     * <code>
+     * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+     * </code>
      *
      * @param value The defaultLanguageCode to set.
      * @return This builder for chaining.
@@ -1643,14 +1653,16 @@ public Builder setDefaultLanguageCode(java.lang.String value) {
      *
      *
      * <pre>
-     * Immutable. The default language of the agent as a language tag.
+     * Required. Immutable. The default language of the agent as a language tag.
      * See [Language
      * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
      * for a list of the currently supported language codes.
      * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
      * </pre>
      *
-     * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+     * <code>
+     * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+     * </code>
      *
      * @return This builder for chaining.
      */
@@ -1664,14 +1676,16 @@ public Builder clearDefaultLanguageCode() {
      *
      *
      * <pre>
-     * Immutable. The default language of the agent as a language tag.
+     * Required. Immutable. The default language of the agent as a language tag.
      * See [Language
      * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
      * for a list of the currently supported language codes.
      * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
      * </pre>
      *
-     * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+     * <code>
+     * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+     * </code>
      *
      * @param value The bytes for defaultLanguageCode to set.
      * @return This builder for chaining.
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/AgentOrBuilder.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/AgentOrBuilder.java
index eb6478fb4..b455a0b2f 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/AgentOrBuilder.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/AgentOrBuilder.java
@@ -83,14 +83,16 @@ public interface AgentOrBuilder
    *
    *
    * <pre>
-   * Immutable. The default language of the agent as a language tag.
+   * Required. Immutable. The default language of the agent as a language tag.
    * See [Language
    * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
    * for a list of the currently supported language codes.
    * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
    * </pre>
    *
-   * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+   * <code>
+   * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+   * </code>
    *
    * @return The defaultLanguageCode.
    */
@@ -99,14 +101,16 @@ public interface AgentOrBuilder
    *
    *
    * <pre>
-   * Immutable. The default language of the agent as a language tag.
+   * Required. Immutable. The default language of the agent as a language tag.
    * See [Language
    * Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
    * for a list of the currently supported language codes.
    * This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
    * </pre>
    *
-   * <code>string default_language_code = 3 [(.google.api.field_behavior) = IMMUTABLE];</code>
+   * <code>
+   * string default_language_code = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+   * </code>
    *
    * @return The bytes for defaultLanguageCode.
    */
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/AgentProto.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/AgentProto.java
index 92b401a87..f507d8d8e 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/AgentProto.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/AgentProto.java
@@ -103,117 +103,117 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
           + "unning/operations.proto\032\033google/protobuf"
           + "/empty.proto\032 google/protobuf/field_mask"
           + ".proto\"8\n\024SpeechToTextSettings\022 \n\030enable"
-          + "_speech_adaptation\030\001 \001(\010\"\275\004\n\005Agent\022\014\n\004na"
-          + "me\030\001 \001(\t\022\031\n\014display_name\030\002 \001(\tB\003\340A\002\022\"\n\025d"
-          + "efault_language_code\030\003 \001(\tB\003\340A\005\022 \n\030suppo"
-          + "rted_language_codes\030\004 \003(\t\022\026\n\ttime_zone\030\005"
-          + " \001(\tB\003\340A\002\022\023\n\013description\030\006 \001(\t\022\022\n\navatar"
-          + "_uri\030\007 \001(\t\022Y\n\027speech_to_text_settings\030\r "
-          + "\001(\01328.google.cloud.dialogflow.cx.v3beta1"
-          + ".SpeechToTextSettings\022:\n\nstart_flow\030\020 \001("
-          + "\tB&\340A\005\372A \n\036dialogflow.googleapis.com/Flo"
-          + "w\022J\n\021security_settings\030\021 \001(\tB/\372A,\n*dialo"
-          + "gflow.googleapis.com/SecuritySettings\022\"\n"
-          + "\032enable_stackdriver_logging\030\022 \001(\010\022\037\n\027ena"
-          + "ble_spell_correction\030\024 \001(\010:\\\352AY\n\037dialogf"
-          + "low.googleapis.com/Agent\0226projects/{proj"
-          + "ect}/locations/{location}/agents/{agent}"
-          + "\"s\n\021ListAgentsRequest\0227\n\006parent\030\001 \001(\tB\'\340"
-          + "A\002\372A!\022\037dialogflow.googleapis.com/Agent\022\021"
-          + "\n\tpage_size\030\002 \001(\005\022\022\n\npage_token\030\003 \001(\t\"h\n"
-          + "\022ListAgentsResponse\0229\n\006agents\030\001 \003(\0132).go"
-          + "ogle.cloud.dialogflow.cx.v3beta1.Agent\022\027"
-          + "\n\017next_page_token\030\002 \001(\t\"H\n\017GetAgentReque"
-          + "st\0225\n\004name\030\001 \001(\tB\'\340A\002\372A!\n\037dialogflow.goo"
-          + "gleapis.com/Agent\"\214\001\n\022CreateAgentRequest"
-          + "\0227\n\006parent\030\001 \001(\tB\'\340A\002\372A!\022\037dialogflow.goo"
-          + "gleapis.com/Agent\022=\n\005agent\030\002 \001(\0132).googl"
-          + "e.cloud.dialogflow.cx.v3beta1.AgentB\003\340A\002"
-          + "\"\204\001\n\022UpdateAgentRequest\022=\n\005agent\030\001 \001(\0132)"
+          + "_speech_adaptation\030\001 \001(\010\"\300\004\n\005Agent\022\014\n\004na"
+          + "me\030\001 \001(\t\022\031\n\014display_name\030\002 \001(\tB\003\340A\002\022%\n\025d"
+          + "efault_language_code\030\003 \001(\tB\006\340A\002\340A\005\022 \n\030su"
+          + "pported_language_codes\030\004 \003(\t\022\026\n\ttime_zon"
+          + "e\030\005 \001(\tB\003\340A\002\022\023\n\013description\030\006 \001(\t\022\022\n\nava"
+          + "tar_uri\030\007 \001(\t\022Y\n\027speech_to_text_settings"
+          + "\030\r \001(\01328.google.cloud.dialogflow.cx.v3be"
+          + "ta1.SpeechToTextSettings\022:\n\nstart_flow\030\020"
+          + " \001(\tB&\340A\005\372A \n\036dialogflow.googleapis.com/"
+          + "Flow\022J\n\021security_settings\030\021 \001(\tB/\372A,\n*di"
+          + "alogflow.googleapis.com/SecuritySettings"
+          + "\022\"\n\032enable_stackdriver_logging\030\022 \001(\010\022\037\n\027"
+          + "enable_spell_correction\030\024 \001(\010:\\\352AY\n\037dial"
+          + "ogflow.googleapis.com/Agent\0226projects/{p"
+          + "roject}/locations/{location}/agents/{age"
+          + "nt}\"s\n\021ListAgentsRequest\0227\n\006parent\030\001 \001(\t"
+          + "B\'\340A\002\372A!\022\037dialogflow.googleapis.com/Agen"
+          + "t\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_token\030\003 \001(\t"
+          + "\"h\n\022ListAgentsResponse\0229\n\006agents\030\001 \003(\0132)"
           + ".google.cloud.dialogflow.cx.v3beta1.Agen"
-          + "tB\003\340A\002\022/\n\013update_mask\030\002 \001(\0132\032.google.pro"
-          + "tobuf.FieldMask\"K\n\022DeleteAgentRequest\0225\n"
-          + "\004name\030\001 \001(\tB\'\340A\002\372A!\n\037dialogflow.googleap"
-          + "is.com/Agent\"\247\001\n\022ExportAgentRequest\0225\n\004n"
-          + "ame\030\001 \001(\tB\'\340A\002\372A!\n\037dialogflow.googleapis"
-          + ".com/Agent\022\026\n\tagent_uri\030\002 \001(\tB\003\340A\001\022B\n\013en"
-          + "vironment\030\005 \001(\tB-\340A\001\372A\'\n%dialogflow.goog"
-          + "leapis.com/Environment\"L\n\023ExportAgentRes"
-          + "ponse\022\023\n\tagent_uri\030\001 \001(\tH\000\022\027\n\ragent_cont"
-          + "ent\030\002 \001(\014H\000B\007\n\005agent\"\253\002\n\023RestoreAgentReq"
-          + "uest\0225\n\004name\030\001 \001(\tB\'\340A\002\372A!\n\037dialogflow.g"
-          + "oogleapis.com/Agent\022\023\n\tagent_uri\030\002 \001(\tH\000"
-          + "\022\027\n\ragent_content\030\003 \001(\014H\000\022]\n\016restore_opt"
-          + "ion\030\005 \001(\0162E.google.cloud.dialogflow.cx.v"
-          + "3beta1.RestoreAgentRequest.RestoreOption"
-          + "\"G\n\rRestoreOption\022\036\n\032RESTORE_OPTION_UNSP"
-          + "ECIFIED\020\000\022\010\n\004KEEP\020\001\022\014\n\010FALLBACK\020\002B\007\n\005age"
-          + "nt\"d\n\024ValidateAgentRequest\0225\n\004name\030\001 \001(\t"
-          + "B\'\340A\002\372A!\n\037dialogflow.googleapis.com/Agen"
-          + "t\022\025\n\rlanguage_code\030\002 \001(\t\"\177\n\037GetAgentVali"
-          + "dationResultRequest\022E\n\004name\030\001 \001(\tB7\340A\002\372A"
-          + "1\n/dialogflow.googleapis.com/AgentValida"
-          + "tionResult\022\025\n\rlanguage_code\030\002 \001(\t\"\377\001\n\025Ag"
-          + "entValidationResult\022\014\n\004name\030\001 \001(\t\022Y\n\027flo"
-          + "w_validation_results\030\002 \003(\01328.google.clou"
-          + "d.dialogflow.cx.v3beta1.FlowValidationRe"
-          + "sult:}\352Az\n/dialogflow.googleapis.com/Age"
-          + "ntValidationResult\022Gprojects/{project}/l"
-          + "ocations/{location}/agents/{agent}/valid"
-          + "ationResult2\221\017\n\006Agents\022\275\001\n\nListAgents\0225."
-          + "google.cloud.dialogflow.cx.v3beta1.ListA"
-          + "gentsRequest\0326.google.cloud.dialogflow.c"
-          + "x.v3beta1.ListAgentsResponse\"@\202\323\344\223\0021\022//v"
-          + "3beta1/{parent=projects/*/locations/*}/a"
-          + "gents\332A\006parent\022\252\001\n\010GetAgent\0223.google.clo"
-          + "ud.dialogflow.cx.v3beta1.GetAgentRequest"
-          + "\032).google.cloud.dialogflow.cx.v3beta1.Ag"
-          + "ent\">\202\323\344\223\0021\022//v3beta1/{name=projects/*/l"
-          + "ocations/*/agents/*}\332A\004name\022\277\001\n\013CreateAg"
-          + "ent\0226.google.cloud.dialogflow.cx.v3beta1"
-          + ".CreateAgentRequest\032).google.cloud.dialo"
-          + "gflow.cx.v3beta1.Agent\"M\202\323\344\223\0028\"//v3beta1"
-          + "/{parent=projects/*/locations/*}/agents:"
-          + "\005agent\332A\014parent,agent\022\312\001\n\013UpdateAgent\0226."
-          + "google.cloud.dialogflow.cx.v3beta1.Updat"
-          + "eAgentRequest\032).google.cloud.dialogflow."
-          + "cx.v3beta1.Agent\"X\202\323\344\223\002>25/v3beta1/{agen"
-          + "t.name=projects/*/locations/*/agents/*}:"
-          + "\005agent\332A\021agent,update_mask\022\235\001\n\013DeleteAge"
-          + "nt\0226.google.cloud.dialogflow.cx.v3beta1."
-          + "DeleteAgentRequest\032\026.google.protobuf.Emp"
-          + "ty\">\202\323\344\223\0021*//v3beta1/{name=projects/*/lo"
-          + "cations/*/agents/*}\332A\004name\022\327\001\n\013ExportAge"
-          + "nt\0226.google.cloud.dialogflow.cx.v3beta1."
-          + "ExportAgentRequest\032\035.google.longrunning."
-          + "Operation\"q\202\323\344\223\002;\"6/v3beta1/{name=projec"
-          + "ts/*/locations/*/agents/*}:export:\001*\312A-\n"
-          + "\023ExportAgentResponse\022\026google.protobuf.St"
-          + "ruct\022\334\001\n\014RestoreAgent\0227.google.cloud.dia"
-          + "logflow.cx.v3beta1.RestoreAgentRequest\032\035"
-          + ".google.longrunning.Operation\"t\202\323\344\223\002<\"7/"
-          + "v3beta1/{name=projects/*/locations/*/age"
-          + "nts/*}:restore:\001*\312A/\n\025google.protobuf.Em"
-          + "pty\022\026google.protobuf.Struct\022\311\001\n\rValidate"
-          + "Agent\0228.google.cloud.dialogflow.cx.v3bet"
-          + "a1.ValidateAgentRequest\0329.google.cloud.d"
-          + "ialogflow.cx.v3beta1.AgentValidationResu"
-          + "lt\"C\202\323\344\223\002=\"8/v3beta1/{name=projects/*/lo"
-          + "cations/*/agents/*}:validate:\001*\022\353\001\n\030GetA"
-          + "gentValidationResult\022C.google.cloud.dial"
-          + "ogflow.cx.v3beta1.GetAgentValidationResu"
-          + "ltRequest\0329.google.cloud.dialogflow.cx.v"
-          + "3beta1.AgentValidationResult\"O\202\323\344\223\002B\022@/v"
-          + "3beta1/{name=projects/*/locations/*/agen"
-          + "ts/*/validationResult}\332A\004name\032x\312A\031dialog"
-          + "flow.googleapis.com\322AYhttps://www.google"
-          + "apis.com/auth/cloud-platform,https://www"
-          + ".googleapis.com/auth/dialogflowB\251\001\n&com."
-          + "google.cloud.dialogflow.cx.v3beta1B\nAgen"
-          + "tProtoP\001ZDgoogle.golang.org/genproto/goo"
-          + "gleapis/cloud/dialogflow/cx/v3beta1;cx\370\001"
-          + "\001\242\002\002DF\252\002\"Google.Cloud.Dialogflow.Cx.V3Be"
-          + "ta1b\006proto3"
+          + "t\022\027\n\017next_page_token\030\002 \001(\t\"H\n\017GetAgentRe"
+          + "quest\0225\n\004name\030\001 \001(\tB\'\340A\002\372A!\n\037dialogflow."
+          + "googleapis.com/Agent\"\214\001\n\022CreateAgentRequ"
+          + "est\0227\n\006parent\030\001 \001(\tB\'\340A\002\372A!\022\037dialogflow."
+          + "googleapis.com/Agent\022=\n\005agent\030\002 \001(\0132).go"
+          + "ogle.cloud.dialogflow.cx.v3beta1.AgentB\003"
+          + "\340A\002\"\204\001\n\022UpdateAgentRequest\022=\n\005agent\030\001 \001("
+          + "\0132).google.cloud.dialogflow.cx.v3beta1.A"
+          + "gentB\003\340A\002\022/\n\013update_mask\030\002 \001(\0132\032.google."
+          + "protobuf.FieldMask\"K\n\022DeleteAgentRequest"
+          + "\0225\n\004name\030\001 \001(\tB\'\340A\002\372A!\n\037dialogflow.googl"
+          + "eapis.com/Agent\"\247\001\n\022ExportAgentRequest\0225"
+          + "\n\004name\030\001 \001(\tB\'\340A\002\372A!\n\037dialogflow.googlea"
+          + "pis.com/Agent\022\026\n\tagent_uri\030\002 \001(\tB\003\340A\001\022B\n"
+          + "\013environment\030\005 \001(\tB-\340A\001\372A\'\n%dialogflow.g"
+          + "oogleapis.com/Environment\"L\n\023ExportAgent"
+          + "Response\022\023\n\tagent_uri\030\001 \001(\tH\000\022\027\n\ragent_c"
+          + "ontent\030\002 \001(\014H\000B\007\n\005agent\"\253\002\n\023RestoreAgent"
+          + "Request\0225\n\004name\030\001 \001(\tB\'\340A\002\372A!\n\037dialogflo"
+          + "w.googleapis.com/Agent\022\023\n\tagent_uri\030\002 \001("
+          + "\tH\000\022\027\n\ragent_content\030\003 \001(\014H\000\022]\n\016restore_"
+          + "option\030\005 \001(\0162E.google.cloud.dialogflow.c"
+          + "x.v3beta1.RestoreAgentRequest.RestoreOpt"
+          + "ion\"G\n\rRestoreOption\022\036\n\032RESTORE_OPTION_U"
+          + "NSPECIFIED\020\000\022\010\n\004KEEP\020\001\022\014\n\010FALLBACK\020\002B\007\n\005"
+          + "agent\"d\n\024ValidateAgentRequest\0225\n\004name\030\001 "
+          + "\001(\tB\'\340A\002\372A!\n\037dialogflow.googleapis.com/A"
+          + "gent\022\025\n\rlanguage_code\030\002 \001(\t\"\177\n\037GetAgentV"
+          + "alidationResultRequest\022E\n\004name\030\001 \001(\tB7\340A"
+          + "\002\372A1\n/dialogflow.googleapis.com/AgentVal"
+          + "idationResult\022\025\n\rlanguage_code\030\002 \001(\t\"\377\001\n"
+          + "\025AgentValidationResult\022\014\n\004name\030\001 \001(\t\022Y\n\027"
+          + "flow_validation_results\030\002 \003(\01328.google.c"
+          + "loud.dialogflow.cx.v3beta1.FlowValidatio"
+          + "nResult:}\352Az\n/dialogflow.googleapis.com/"
+          + "AgentValidationResult\022Gprojects/{project"
+          + "}/locations/{location}/agents/{agent}/va"
+          + "lidationResult2\221\017\n\006Agents\022\275\001\n\nListAgents"
+          + "\0225.google.cloud.dialogflow.cx.v3beta1.Li"
+          + "stAgentsRequest\0326.google.cloud.dialogflo"
+          + "w.cx.v3beta1.ListAgentsResponse\"@\202\323\344\223\0021\022"
+          + "//v3beta1/{parent=projects/*/locations/*"
+          + "}/agents\332A\006parent\022\252\001\n\010GetAgent\0223.google."
+          + "cloud.dialogflow.cx.v3beta1.GetAgentRequ"
+          + "est\032).google.cloud.dialogflow.cx.v3beta1"
+          + ".Agent\">\202\323\344\223\0021\022//v3beta1/{name=projects/"
+          + "*/locations/*/agents/*}\332A\004name\022\277\001\n\013Creat"
+          + "eAgent\0226.google.cloud.dialogflow.cx.v3be"
+          + "ta1.CreateAgentRequest\032).google.cloud.di"
+          + "alogflow.cx.v3beta1.Agent\"M\202\323\344\223\0028\"//v3be"
+          + "ta1/{parent=projects/*/locations/*}/agen"
+          + "ts:\005agent\332A\014parent,agent\022\312\001\n\013UpdateAgent"
+          + "\0226.google.cloud.dialogflow.cx.v3beta1.Up"
+          + "dateAgentRequest\032).google.cloud.dialogfl"
+          + "ow.cx.v3beta1.Agent\"X\202\323\344\223\002>25/v3beta1/{a"
+          + "gent.name=projects/*/locations/*/agents/"
+          + "*}:\005agent\332A\021agent,update_mask\022\235\001\n\013Delete"
+          + "Agent\0226.google.cloud.dialogflow.cx.v3bet"
+          + "a1.DeleteAgentRequest\032\026.google.protobuf."
+          + "Empty\">\202\323\344\223\0021*//v3beta1/{name=projects/*"
+          + "/locations/*/agents/*}\332A\004name\022\327\001\n\013Export"
+          + "Agent\0226.google.cloud.dialogflow.cx.v3bet"
+          + "a1.ExportAgentRequest\032\035.google.longrunni"
+          + "ng.Operation\"q\202\323\344\223\002;\"6/v3beta1/{name=pro"
+          + "jects/*/locations/*/agents/*}:export:\001*\312"
+          + "A-\n\023ExportAgentResponse\022\026google.protobuf"
+          + ".Struct\022\334\001\n\014RestoreAgent\0227.google.cloud."
+          + "dialogflow.cx.v3beta1.RestoreAgentReques"
+          + "t\032\035.google.longrunning.Operation\"t\202\323\344\223\002<"
+          + "\"7/v3beta1/{name=projects/*/locations/*/"
+          + "agents/*}:restore:\001*\312A/\n\025google.protobuf"
+          + ".Empty\022\026google.protobuf.Struct\022\311\001\n\rValid"
+          + "ateAgent\0228.google.cloud.dialogflow.cx.v3"
+          + "beta1.ValidateAgentRequest\0329.google.clou"
+          + "d.dialogflow.cx.v3beta1.AgentValidationR"
+          + "esult\"C\202\323\344\223\002=\"8/v3beta1/{name=projects/*"
+          + "/locations/*/agents/*}:validate:\001*\022\353\001\n\030G"
+          + "etAgentValidationResult\022C.google.cloud.d"
+          + "ialogflow.cx.v3beta1.GetAgentValidationR"
+          + "esultRequest\0329.google.cloud.dialogflow.c"
+          + "x.v3beta1.AgentValidationResult\"O\202\323\344\223\002B\022"
+          + "@/v3beta1/{name=projects/*/locations/*/a"
+          + "gents/*/validationResult}\332A\004name\032x\312A\031dia"
+          + "logflow.googleapis.com\322AYhttps://www.goo"
+          + "gleapis.com/auth/cloud-platform,https://"
+          + "www.googleapis.com/auth/dialogflowB\251\001\n&c"
+          + "om.google.cloud.dialogflow.cx.v3beta1B\nA"
+          + "gentProtoP\001ZDgoogle.golang.org/genproto/"
+          + "googleapis/cloud/dialogflow/cx/v3beta1;c"
+          + "x\370\001\001\242\002\002DF\252\002\"Google.Cloud.Dialogflow.Cx.V"
+          + "3Beta1b\006proto3"
     };
     descriptor =
         com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/DetectIntentResponse.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/DetectIntentResponse.java
index c144fbed4..c84bebdc1 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/DetectIntentResponse.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/DetectIntentResponse.java
@@ -40,6 +40,7 @@ private DetectIntentResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> b
   private DetectIntentResponse() {
     responseId_ = "";
     outputAudio_ = com.google.protobuf.ByteString.EMPTY;
+    responseType_ = 0;
   }
 
   @java.lang.Override
@@ -115,6 +116,18 @@ private DetectIntentResponse(
                 outputAudioConfig_ = subBuilder.buildPartial();
               }
 
+              break;
+            }
+          case 48:
+            {
+              int rawValue = input.readEnum();
+
+              responseType_ = rawValue;
+              break;
+            }
+          case 56:
+            {
+              allowCancellation_ = input.readBool();
               break;
             }
           default:
@@ -151,6 +164,169 @@ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
             com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.Builder.class);
   }
 
+  /**
+   *
+   *
+   * <pre>
+   * Represents different DetectIntentResponse types.
+   * </pre>
+   *
+   * Protobuf enum {@code google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType}
+   */
+  public enum ResponseType implements com.google.protobuf.ProtocolMessageEnum {
+    /**
+     *
+     *
+     * <pre>
+     * Not specified. This should never happen.
+     * </pre>
+     *
+     * <code>RESPONSE_TYPE_UNSPECIFIED = 0;</code>
+     */
+    RESPONSE_TYPE_UNSPECIFIED(0),
+    /**
+     *
+     *
+     * <pre>
+     * Partial response. e.g. Aggregated responses in a Fulfillment that enables
+     * `return_partial_response` can be returned as partial response.
+     * WARNING: partial response is not eligible for barge-in.
+     * </pre>
+     *
+     * <code>PARTIAL = 1;</code>
+     */
+    PARTIAL(1),
+    /**
+     *
+     *
+     * <pre>
+     * Final response.
+     * </pre>
+     *
+     * <code>FINAL = 2;</code>
+     */
+    FINAL(2),
+    UNRECOGNIZED(-1),
+    ;
+
+    /**
+     *
+     *
+     * <pre>
+     * Not specified. This should never happen.
+     * </pre>
+     *
+     * <code>RESPONSE_TYPE_UNSPECIFIED = 0;</code>
+     */
+    public static final int RESPONSE_TYPE_UNSPECIFIED_VALUE = 0;
+    /**
+     *
+     *
+     * <pre>
+     * Partial response. e.g. Aggregated responses in a Fulfillment that enables
+     * `return_partial_response` can be returned as partial response.
+     * WARNING: partial response is not eligible for barge-in.
+     * </pre>
+     *
+     * <code>PARTIAL = 1;</code>
+     */
+    public static final int PARTIAL_VALUE = 1;
+    /**
+     *
+     *
+     * <pre>
+     * Final response.
+     * </pre>
+     *
+     * <code>FINAL = 2;</code>
+     */
+    public static final int FINAL_VALUE = 2;
+
+    public final int getNumber() {
+      if (this == UNRECOGNIZED) {
+        throw new java.lang.IllegalArgumentException(
+            "Can't get the number of an unknown enum value.");
+      }
+      return value;
+    }
+
+    /**
+     * @param value The numeric wire value of the corresponding enum entry.
+     * @return The enum associated with the given numeric wire value.
+     * @deprecated Use {@link #forNumber(int)} instead.
+     */
+    @java.lang.Deprecated
+    public static ResponseType valueOf(int value) {
+      return forNumber(value);
+    }
+
+    /**
+     * @param value The numeric wire value of the corresponding enum entry.
+     * @return The enum associated with the given numeric wire value.
+     */
+    public static ResponseType forNumber(int value) {
+      switch (value) {
+        case 0:
+          return RESPONSE_TYPE_UNSPECIFIED;
+        case 1:
+          return PARTIAL;
+        case 2:
+          return FINAL;
+        default:
+          return null;
+      }
+    }
+
+    public static com.google.protobuf.Internal.EnumLiteMap<ResponseType> internalGetValueMap() {
+      return internalValueMap;
+    }
+
+    private static final com.google.protobuf.Internal.EnumLiteMap<ResponseType> internalValueMap =
+        new com.google.protobuf.Internal.EnumLiteMap<ResponseType>() {
+          public ResponseType findValueByNumber(int number) {
+            return ResponseType.forNumber(number);
+          }
+        };
+
+    public final com.google.protobuf.Descriptors.EnumValueDescriptor getValueDescriptor() {
+      if (this == UNRECOGNIZED) {
+        throw new java.lang.IllegalStateException(
+            "Can't get the descriptor of an unrecognized enum value.");
+      }
+      return getDescriptor().getValues().get(ordinal());
+    }
+
+    public final com.google.protobuf.Descriptors.EnumDescriptor getDescriptorForType() {
+      return getDescriptor();
+    }
+
+    public static final com.google.protobuf.Descriptors.EnumDescriptor getDescriptor() {
+      return com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.getDescriptor()
+          .getEnumTypes()
+          .get(0);
+    }
+
+    private static final ResponseType[] VALUES = values();
+
+    public static ResponseType valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+      if (desc.getType() != getDescriptor()) {
+        throw new java.lang.IllegalArgumentException("EnumValueDescriptor is not for this type.");
+      }
+      if (desc.getIndex() == -1) {
+        return UNRECOGNIZED;
+      }
+      return VALUES[desc.getIndex()];
+    }
+
+    private final int value;
+
+    private ResponseType(int value) {
+      this.value = value;
+    }
+
+    // @@protoc_insertion_point(enum_scope:google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType)
+  }
+
   public static final int RESPONSE_ID_FIELD_NUMBER = 1;
   private volatile java.lang.Object responseId_;
   /**
@@ -326,6 +502,68 @@ public com.google.cloud.dialogflow.cx.v3beta1.OutputAudioConfig getOutputAudioCo
     return getOutputAudioConfig();
   }
 
+  public static final int RESPONSE_TYPE_FIELD_NUMBER = 6;
+  private int responseType_;
+  /**
+   *
+   *
+   * <pre>
+   * Response type.
+   * </pre>
+   *
+   * <code>.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+   * </code>
+   *
+   * @return The enum numeric value on the wire for responseType.
+   */
+  @java.lang.Override
+  public int getResponseTypeValue() {
+    return responseType_;
+  }
+  /**
+   *
+   *
+   * <pre>
+   * Response type.
+   * </pre>
+   *
+   * <code>.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+   * </code>
+   *
+   * @return The responseType.
+   */
+  @java.lang.Override
+  public com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType
+      getResponseType() {
+    @SuppressWarnings("deprecation")
+    com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType result =
+        com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType.valueOf(
+            responseType_);
+    return result == null
+        ? com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType.UNRECOGNIZED
+        : result;
+  }
+
+  public static final int ALLOW_CANCELLATION_FIELD_NUMBER = 7;
+  private boolean allowCancellation_;
+  /**
+   *
+   *
+   * <pre>
+   * Indicates whether the partial response can be cancelled when a later
+   * response arrives. e.g. if the agent specified some music as partial
+   * response, it can be cancelled.
+   * </pre>
+   *
+   * <code>bool allow_cancellation = 7;</code>
+   *
+   * @return The allowCancellation.
+   */
+  @java.lang.Override
+  public boolean getAllowCancellation() {
+    return allowCancellation_;
+  }
+
   private byte memoizedIsInitialized = -1;
 
   @java.lang.Override
@@ -352,6 +590,15 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
     if (outputAudioConfig_ != null) {
       output.writeMessage(5, getOutputAudioConfig());
     }
+    if (responseType_
+        != com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType
+            .RESPONSE_TYPE_UNSPECIFIED
+            .getNumber()) {
+      output.writeEnum(6, responseType_);
+    }
+    if (allowCancellation_ != false) {
+      output.writeBool(7, allowCancellation_);
+    }
     unknownFields.writeTo(output);
   }
 
@@ -373,6 +620,15 @@ public int getSerializedSize() {
     if (outputAudioConfig_ != null) {
       size += com.google.protobuf.CodedOutputStream.computeMessageSize(5, getOutputAudioConfig());
     }
+    if (responseType_
+        != com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType
+            .RESPONSE_TYPE_UNSPECIFIED
+            .getNumber()) {
+      size += com.google.protobuf.CodedOutputStream.computeEnumSize(6, responseType_);
+    }
+    if (allowCancellation_ != false) {
+      size += com.google.protobuf.CodedOutputStream.computeBoolSize(7, allowCancellation_);
+    }
     size += unknownFields.getSerializedSize();
     memoizedSize = size;
     return size;
@@ -399,6 +655,8 @@ public boolean equals(final java.lang.Object obj) {
     if (hasOutputAudioConfig()) {
       if (!getOutputAudioConfig().equals(other.getOutputAudioConfig())) return false;
     }
+    if (responseType_ != other.responseType_) return false;
+    if (getAllowCancellation() != other.getAllowCancellation()) return false;
     if (!unknownFields.equals(other.unknownFields)) return false;
     return true;
   }
@@ -422,6 +680,10 @@ public int hashCode() {
       hash = (37 * hash) + OUTPUT_AUDIO_CONFIG_FIELD_NUMBER;
       hash = (53 * hash) + getOutputAudioConfig().hashCode();
     }
+    hash = (37 * hash) + RESPONSE_TYPE_FIELD_NUMBER;
+    hash = (53 * hash) + responseType_;
+    hash = (37 * hash) + ALLOW_CANCELLATION_FIELD_NUMBER;
+    hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getAllowCancellation());
     hash = (29 * hash) + unknownFields.hashCode();
     memoizedHashCode = hash;
     return hash;
@@ -584,6 +846,10 @@ public Builder clear() {
         outputAudioConfig_ = null;
         outputAudioConfigBuilder_ = null;
       }
+      responseType_ = 0;
+
+      allowCancellation_ = false;
+
       return this;
     }
 
@@ -623,6 +889,8 @@ public com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse buildPartial(
       } else {
         result.outputAudioConfig_ = outputAudioConfigBuilder_.build();
       }
+      result.responseType_ = responseType_;
+      result.allowCancellation_ = allowCancellation_;
       onBuilt();
       return result;
     }
@@ -686,6 +954,12 @@ public Builder mergeFrom(com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResp
       if (other.hasOutputAudioConfig()) {
         mergeOutputAudioConfig(other.getOutputAudioConfig());
       }
+      if (other.responseType_ != 0) {
+        setResponseTypeValue(other.getResponseTypeValue());
+      }
+      if (other.getAllowCancellation() != false) {
+        setAllowCancellation(other.getAllowCancellation());
+      }
       this.mergeUnknownFields(other.unknownFields);
       onChanged();
       return this;
@@ -1286,6 +1560,170 @@ public Builder clearOutputAudioConfig() {
       return outputAudioConfigBuilder_;
     }
 
+    private int responseType_ = 0;
+    /**
+     *
+     *
+     * <pre>
+     * Response type.
+     * </pre>
+     *
+     * <code>
+     * .google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+     * </code>
+     *
+     * @return The enum numeric value on the wire for responseType.
+     */
+    @java.lang.Override
+    public int getResponseTypeValue() {
+      return responseType_;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Response type.
+     * </pre>
+     *
+     * <code>
+     * .google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+     * </code>
+     *
+     * @param value The enum numeric value on the wire for responseType to set.
+     * @return This builder for chaining.
+     */
+    public Builder setResponseTypeValue(int value) {
+
+      responseType_ = value;
+      onChanged();
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Response type.
+     * </pre>
+     *
+     * <code>
+     * .google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+     * </code>
+     *
+     * @return The responseType.
+     */
+    @java.lang.Override
+    public com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType
+        getResponseType() {
+      @SuppressWarnings("deprecation")
+      com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType result =
+          com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType.valueOf(
+              responseType_);
+      return result == null
+          ? com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType.UNRECOGNIZED
+          : result;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Response type.
+     * </pre>
+     *
+     * <code>
+     * .google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+     * </code>
+     *
+     * @param value The responseType to set.
+     * @return This builder for chaining.
+     */
+    public Builder setResponseType(
+        com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType value) {
+      if (value == null) {
+        throw new NullPointerException();
+      }
+
+      responseType_ = value.getNumber();
+      onChanged();
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Response type.
+     * </pre>
+     *
+     * <code>
+     * .google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+     * </code>
+     *
+     * @return This builder for chaining.
+     */
+    public Builder clearResponseType() {
+
+      responseType_ = 0;
+      onChanged();
+      return this;
+    }
+
+    private boolean allowCancellation_;
+    /**
+     *
+     *
+     * <pre>
+     * Indicates whether the partial response can be cancelled when a later
+     * response arrives. e.g. if the agent specified some music as partial
+     * response, it can be cancelled.
+     * </pre>
+     *
+     * <code>bool allow_cancellation = 7;</code>
+     *
+     * @return The allowCancellation.
+     */
+    @java.lang.Override
+    public boolean getAllowCancellation() {
+      return allowCancellation_;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Indicates whether the partial response can be cancelled when a later
+     * response arrives. e.g. if the agent specified some music as partial
+     * response, it can be cancelled.
+     * </pre>
+     *
+     * <code>bool allow_cancellation = 7;</code>
+     *
+     * @param value The allowCancellation to set.
+     * @return This builder for chaining.
+     */
+    public Builder setAllowCancellation(boolean value) {
+
+      allowCancellation_ = value;
+      onChanged();
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Indicates whether the partial response can be cancelled when a later
+     * response arrives. e.g. if the agent specified some music as partial
+     * response, it can be cancelled.
+     * </pre>
+     *
+     * <code>bool allow_cancellation = 7;</code>
+     *
+     * @return This builder for chaining.
+     */
+    public Builder clearAllowCancellation() {
+
+      allowCancellation_ = false;
+      onChanged();
+      return this;
+    }
+
     @java.lang.Override
     public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
       return super.setUnknownFields(unknownFields);
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/DetectIntentResponseOrBuilder.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/DetectIntentResponseOrBuilder.java
index 0acc80768..73ed305fe 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/DetectIntentResponseOrBuilder.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/DetectIntentResponseOrBuilder.java
@@ -141,4 +141,46 @@ public interface DetectIntentResponseOrBuilder
    * <code>.google.cloud.dialogflow.cx.v3beta1.OutputAudioConfig output_audio_config = 5;</code>
    */
   com.google.cloud.dialogflow.cx.v3beta1.OutputAudioConfigOrBuilder getOutputAudioConfigOrBuilder();
+
+  /**
+   *
+   *
+   * <pre>
+   * Response type.
+   * </pre>
+   *
+   * <code>.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+   * </code>
+   *
+   * @return The enum numeric value on the wire for responseType.
+   */
+  int getResponseTypeValue();
+  /**
+   *
+   *
+   * <pre>
+   * Response type.
+   * </pre>
+   *
+   * <code>.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType response_type = 6;
+   * </code>
+   *
+   * @return The responseType.
+   */
+  com.google.cloud.dialogflow.cx.v3beta1.DetectIntentResponse.ResponseType getResponseType();
+
+  /**
+   *
+   *
+   * <pre>
+   * Indicates whether the partial response can be cancelled when a later
+   * response arrives. e.g. if the agent specified some music as partial
+   * response, it can be cancelled.
+   * </pre>
+   *
+   * <code>bool allow_cancellation = 7;</code>
+   *
+   * @return The allowCancellation.
+   */
+  boolean getAllowCancellation();
 }
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/Fulfillment.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/Fulfillment.java
index f45b0543c..935d8967e 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/Fulfillment.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/Fulfillment.java
@@ -140,6 +140,11 @@ private Fulfillment(
                       extensionRegistry));
               break;
             }
+          case 64:
+            {
+              returnPartialResponses_ = input.readBool();
+              break;
+            }
           default:
             {
               if (!parseUnknownField(input, unknownFields, extensionRegistry, tag)) {
@@ -5150,6 +5155,32 @@ public com.google.protobuf.ByteString getWebhookBytes() {
     }
   }
 
+  public static final int RETURN_PARTIAL_RESPONSES_FIELD_NUMBER = 8;
+  private boolean returnPartialResponses_;
+  /**
+   *
+   *
+   * <pre>
+   * Whether Dialogflow should return currently queued fulfillment response
+   * messages in streaming APIs. If a webhook is specified, it happens before
+   * Dialogflow invokes webhook.
+   * Warning:
+   * 1) This flag only affects streaming API. Responses are still queued
+   * and returned once in non-streaming API.
+   * 2) The flag can be enabled in any fulfillment but only the first 3 partial
+   * responses will be returned. You may only want to apply it to fulfillments
+   * that have slow webhooks.
+   * </pre>
+   *
+   * <code>bool return_partial_responses = 8;</code>
+   *
+   * @return The returnPartialResponses.
+   */
+  @java.lang.Override
+  public boolean getReturnPartialResponses() {
+    return returnPartialResponses_;
+  }
+
   public static final int TAG_FIELD_NUMBER = 3;
   private volatile java.lang.Object tag_;
   /**
@@ -5398,6 +5429,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
     for (int i = 0; i < conditionalCases_.size(); i++) {
       output.writeMessage(5, conditionalCases_.get(i));
     }
+    if (returnPartialResponses_ != false) {
+      output.writeBool(8, returnPartialResponses_);
+    }
     unknownFields.writeTo(output);
   }
 
@@ -5423,6 +5457,9 @@ public int getSerializedSize() {
     for (int i = 0; i < conditionalCases_.size(); i++) {
       size += com.google.protobuf.CodedOutputStream.computeMessageSize(5, conditionalCases_.get(i));
     }
+    if (returnPartialResponses_ != false) {
+      size += com.google.protobuf.CodedOutputStream.computeBoolSize(8, returnPartialResponses_);
+    }
     size += unknownFields.getSerializedSize();
     memoizedSize = size;
     return size;
@@ -5441,6 +5478,7 @@ public boolean equals(final java.lang.Object obj) {
 
     if (!getMessagesList().equals(other.getMessagesList())) return false;
     if (!getWebhook().equals(other.getWebhook())) return false;
+    if (getReturnPartialResponses() != other.getReturnPartialResponses()) return false;
     if (!getTag().equals(other.getTag())) return false;
     if (!getSetParameterActionsList().equals(other.getSetParameterActionsList())) return false;
     if (!getConditionalCasesList().equals(other.getConditionalCasesList())) return false;
@@ -5461,6 +5499,8 @@ public int hashCode() {
     }
     hash = (37 * hash) + WEBHOOK_FIELD_NUMBER;
     hash = (53 * hash) + getWebhook().hashCode();
+    hash = (37 * hash) + RETURN_PARTIAL_RESPONSES_FIELD_NUMBER;
+    hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getReturnPartialResponses());
     hash = (37 * hash) + TAG_FIELD_NUMBER;
     hash = (53 * hash) + getTag().hashCode();
     if (getSetParameterActionsCount() > 0) {
@@ -5636,6 +5676,8 @@ public Builder clear() {
       }
       webhook_ = "";
 
+      returnPartialResponses_ = false;
+
       tag_ = "";
 
       if (setParameterActionsBuilder_ == null) {
@@ -5688,6 +5730,7 @@ public com.google.cloud.dialogflow.cx.v3beta1.Fulfillment buildPartial() {
         result.messages_ = messagesBuilder_.build();
       }
       result.webhook_ = webhook_;
+      result.returnPartialResponses_ = returnPartialResponses_;
       result.tag_ = tag_;
       if (setParameterActionsBuilder_ == null) {
         if (((bitField0_ & 0x00000002) != 0)) {
@@ -5788,6 +5831,9 @@ public Builder mergeFrom(com.google.cloud.dialogflow.cx.v3beta1.Fulfillment othe
         webhook_ = other.webhook_;
         onChanged();
       }
+      if (other.getReturnPartialResponses() != false) {
+        setReturnPartialResponses(other.getReturnPartialResponses());
+      }
       if (!other.getTag().isEmpty()) {
         tag_ = other.tag_;
         onChanged();
@@ -6354,6 +6400,82 @@ public Builder setWebhookBytes(com.google.protobuf.ByteString value) {
       return this;
     }
 
+    private boolean returnPartialResponses_;
+    /**
+     *
+     *
+     * <pre>
+     * Whether Dialogflow should return currently queued fulfillment response
+     * messages in streaming APIs. If a webhook is specified, it happens before
+     * Dialogflow invokes webhook.
+     * Warning:
+     * 1) This flag only affects streaming API. Responses are still queued
+     * and returned once in non-streaming API.
+     * 2) The flag can be enabled in any fulfillment but only the first 3 partial
+     * responses will be returned. You may only want to apply it to fulfillments
+     * that have slow webhooks.
+     * </pre>
+     *
+     * <code>bool return_partial_responses = 8;</code>
+     *
+     * @return The returnPartialResponses.
+     */
+    @java.lang.Override
+    public boolean getReturnPartialResponses() {
+      return returnPartialResponses_;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Whether Dialogflow should return currently queued fulfillment response
+     * messages in streaming APIs. If a webhook is specified, it happens before
+     * Dialogflow invokes webhook.
+     * Warning:
+     * 1) This flag only affects streaming API. Responses are still queued
+     * and returned once in non-streaming API.
+     * 2) The flag can be enabled in any fulfillment but only the first 3 partial
+     * responses will be returned. You may only want to apply it to fulfillments
+     * that have slow webhooks.
+     * </pre>
+     *
+     * <code>bool return_partial_responses = 8;</code>
+     *
+     * @param value The returnPartialResponses to set.
+     * @return This builder for chaining.
+     */
+    public Builder setReturnPartialResponses(boolean value) {
+
+      returnPartialResponses_ = value;
+      onChanged();
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Whether Dialogflow should return currently queued fulfillment response
+     * messages in streaming APIs. If a webhook is specified, it happens before
+     * Dialogflow invokes webhook.
+     * Warning:
+     * 1) This flag only affects streaming API. Responses are still queued
+     * and returned once in non-streaming API.
+     * 2) The flag can be enabled in any fulfillment but only the first 3 partial
+     * responses will be returned. You may only want to apply it to fulfillments
+     * that have slow webhooks.
+     * </pre>
+     *
+     * <code>bool return_partial_responses = 8;</code>
+     *
+     * @return This builder for chaining.
+     */
+    public Builder clearReturnPartialResponses() {
+
+      returnPartialResponses_ = false;
+      onChanged();
+      return this;
+    }
+
     private java.lang.Object tag_ = "";
     /**
      *
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/FulfillmentOrBuilder.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/FulfillmentOrBuilder.java
index 82858d573..30f9e6da2 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/FulfillmentOrBuilder.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/FulfillmentOrBuilder.java
@@ -104,6 +104,27 @@ public interface FulfillmentOrBuilder
    */
   com.google.protobuf.ByteString getWebhookBytes();
 
+  /**
+   *
+   *
+   * <pre>
+   * Whether Dialogflow should return currently queued fulfillment response
+   * messages in streaming APIs. If a webhook is specified, it happens before
+   * Dialogflow invokes webhook.
+   * Warning:
+   * 1) This flag only affects streaming API. Responses are still queued
+   * and returned once in non-streaming API.
+   * 2) The flag can be enabled in any fulfillment but only the first 3 partial
+   * responses will be returned. You may only want to apply it to fulfillments
+   * that have slow webhooks.
+   * </pre>
+   *
+   * <code>bool return_partial_responses = 8;</code>
+   *
+   * @return The returnPartialResponses.
+   */
+  boolean getReturnPartialResponses();
+
   /**
    *
    *
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/FulfillmentProto.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/FulfillmentProto.java
index da558718b..6cebb2050 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/FulfillmentProto.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/FulfillmentProto.java
@@ -61,34 +61,35 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
           + "cx.v3beta1\032\031google/api/resource.proto\0329g"
           + "oogle/cloud/dialogflow/cx/v3beta1/respon"
           + "se_message.proto\032\034google/protobuf/struct"
-          + ".proto\032\034google/api/annotations.proto\"\344\006\n"
+          + ".proto\032\034google/api/annotations.proto\"\206\007\n"
           + "\013Fulfillment\022E\n\010messages\030\001 \003(\01323.google."
           + "cloud.dialogflow.cx.v3beta1.ResponseMess"
           + "age\0227\n\007webhook\030\002 \001(\tB&\372A#\n!dialogflow.go"
-          + "ogleapis.com/Webhook\022\013\n\003tag\030\003 \001(\t\022a\n\025set"
-          + "_parameter_actions\030\004 \003(\0132B.google.cloud."
-          + "dialogflow.cx.v3beta1.Fulfillment.SetPar"
-          + "ameterAction\022[\n\021conditional_cases\030\005 \003(\0132"
-          + "@.google.cloud.dialogflow.cx.v3beta1.Ful"
-          + "fillment.ConditionalCases\032N\n\022SetParamete"
-          + "rAction\022\021\n\tparameter\030\001 \001(\t\022%\n\005value\030\002 \001("
-          + "\0132\026.google.protobuf.Value\032\267\003\n\020Conditiona"
-          + "lCases\022T\n\005cases\030\001 \003(\0132E.google.cloud.dia"
-          + "logflow.cx.v3beta1.Fulfillment.Condition"
-          + "alCases.Case\032\314\002\n\004Case\022\021\n\tcondition\030\001 \001(\t"
-          + "\022g\n\014case_content\030\002 \003(\0132Q.google.cloud.di"
-          + "alogflow.cx.v3beta1.Fulfillment.Conditio"
-          + "nalCases.Case.CaseContent\032\307\001\n\013CaseConten"
-          + "t\022F\n\007message\030\001 \001(\01323.google.cloud.dialog"
-          + "flow.cx.v3beta1.ResponseMessageH\000\022\\\n\020add"
-          + "itional_cases\030\002 \001(\0132@.google.cloud.dialo"
-          + "gflow.cx.v3beta1.Fulfillment.Conditional"
-          + "CasesH\000B\022\n\020cases_or_messageB\257\001\n&com.goog"
-          + "le.cloud.dialogflow.cx.v3beta1B\020Fulfillm"
-          + "entProtoP\001ZDgoogle.golang.org/genproto/g"
-          + "oogleapis/cloud/dialogflow/cx/v3beta1;cx"
-          + "\370\001\001\242\002\002DF\252\002\"Google.Cloud.Dialogflow.Cx.V3"
-          + "Beta1b\006proto3"
+          + "ogleapis.com/Webhook\022 \n\030return_partial_r"
+          + "esponses\030\010 \001(\010\022\013\n\003tag\030\003 \001(\t\022a\n\025set_param"
+          + "eter_actions\030\004 \003(\0132B.google.cloud.dialog"
+          + "flow.cx.v3beta1.Fulfillment.SetParameter"
+          + "Action\022[\n\021conditional_cases\030\005 \003(\0132@.goog"
+          + "le.cloud.dialogflow.cx.v3beta1.Fulfillme"
+          + "nt.ConditionalCases\032N\n\022SetParameterActio"
+          + "n\022\021\n\tparameter\030\001 \001(\t\022%\n\005value\030\002 \001(\0132\026.go"
+          + "ogle.protobuf.Value\032\267\003\n\020ConditionalCases"
+          + "\022T\n\005cases\030\001 \003(\0132E.google.cloud.dialogflo"
+          + "w.cx.v3beta1.Fulfillment.ConditionalCase"
+          + "s.Case\032\314\002\n\004Case\022\021\n\tcondition\030\001 \001(\t\022g\n\014ca"
+          + "se_content\030\002 \003(\0132Q.google.cloud.dialogfl"
+          + "ow.cx.v3beta1.Fulfillment.ConditionalCas"
+          + "es.Case.CaseContent\032\307\001\n\013CaseContent\022F\n\007m"
+          + "essage\030\001 \001(\01323.google.cloud.dialogflow.c"
+          + "x.v3beta1.ResponseMessageH\000\022\\\n\020additiona"
+          + "l_cases\030\002 \001(\0132@.google.cloud.dialogflow."
+          + "cx.v3beta1.Fulfillment.ConditionalCasesH"
+          + "\000B\022\n\020cases_or_messageB\257\001\n&com.google.clo"
+          + "ud.dialogflow.cx.v3beta1B\020FulfillmentPro"
+          + "toP\001ZDgoogle.golang.org/genproto/googlea"
+          + "pis/cloud/dialogflow/cx/v3beta1;cx\370\001\001\242\002\002"
+          + "DF\252\002\"Google.Cloud.Dialogflow.Cx.V3Beta1b"
+          + "\006proto3"
     };
     descriptor =
         com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
@@ -105,7 +106,12 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
         new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
             internal_static_google_cloud_dialogflow_cx_v3beta1_Fulfillment_descriptor,
             new java.lang.String[] {
-              "Messages", "Webhook", "Tag", "SetParameterActions", "ConditionalCases",
+              "Messages",
+              "Webhook",
+              "ReturnPartialResponses",
+              "Tag",
+              "SetParameterActions",
+              "ConditionalCases",
             });
     internal_static_google_cloud_dialogflow_cx_v3beta1_Fulfillment_SetParameterAction_descriptor =
         internal_static_google_cloud_dialogflow_cx_v3beta1_Fulfillment_descriptor
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/QueryParameters.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/QueryParameters.java
index 87afec3dc..76dd97b55 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/QueryParameters.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/QueryParameters.java
@@ -596,8 +596,9 @@ public com.google.protobuf.StructOrBuilder getParametersOrBuilder() {
    *
    * <pre>
    * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-   * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-   * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+   * page][QueryResult.current_page] in the session.
+   * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+   * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
    * If `current_page` is specified, the previous state of the session will be
    * ignored by Dialogflow, including the [previous
    * page][QueryResult.current_page] and the [previous session
@@ -628,8 +629,9 @@ public java.lang.String getCurrentPage() {
    *
    * <pre>
    * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-   * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-   * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+   * page][QueryResult.current_page] in the session.
+   * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+   * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
    * If `current_page` is specified, the previous state of the session will be
    * ignored by Dialogflow, including the [previous
    * page][QueryResult.current_page] and the [previous session
@@ -2743,8 +2745,9 @@ public com.google.protobuf.StructOrBuilder getParametersOrBuilder() {
      *
      * <pre>
      * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-     * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-     * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+     * page][QueryResult.current_page] in the session.
+     * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+     * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
      * If `current_page` is specified, the previous state of the session will be
      * ignored by Dialogflow, including the [previous
      * page][QueryResult.current_page] and the [previous session
@@ -2774,8 +2777,9 @@ public java.lang.String getCurrentPage() {
      *
      * <pre>
      * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-     * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-     * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+     * page][QueryResult.current_page] in the session.
+     * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+     * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
      * If `current_page` is specified, the previous state of the session will be
      * ignored by Dialogflow, including the [previous
      * page][QueryResult.current_page] and the [previous session
@@ -2805,8 +2809,9 @@ public com.google.protobuf.ByteString getCurrentPageBytes() {
      *
      * <pre>
      * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-     * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-     * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+     * page][QueryResult.current_page] in the session.
+     * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+     * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
      * If `current_page` is specified, the previous state of the session will be
      * ignored by Dialogflow, including the [previous
      * page][QueryResult.current_page] and the [previous session
@@ -2835,8 +2840,9 @@ public Builder setCurrentPage(java.lang.String value) {
      *
      * <pre>
      * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-     * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-     * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+     * page][QueryResult.current_page] in the session.
+     * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+     * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
      * If `current_page` is specified, the previous state of the session will be
      * ignored by Dialogflow, including the [previous
      * page][QueryResult.current_page] and the [previous session
@@ -2861,8 +2867,9 @@ public Builder clearCurrentPage() {
      *
      * <pre>
      * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-     * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-     * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+     * page][QueryResult.current_page] in the session.
+     * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+     * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
      * If `current_page` is specified, the previous state of the session will be
      * ignored by Dialogflow, including the [previous
      * page][QueryResult.current_page] and the [previous session
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/QueryParametersOrBuilder.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/QueryParametersOrBuilder.java
index 73e498ef7..bc5cc8da3 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/QueryParametersOrBuilder.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/QueryParametersOrBuilder.java
@@ -323,8 +323,9 @@ com.google.cloud.dialogflow.cx.v3beta1.SessionEntityTypeOrBuilder getSessionEnti
    *
    * <pre>
    * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-   * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-   * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+   * page][QueryResult.current_page] in the session.
+   * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+   * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
    * If `current_page` is specified, the previous state of the session will be
    * ignored by Dialogflow, including the [previous
    * page][QueryResult.current_page] and the [previous session
@@ -344,8 +345,9 @@ com.google.cloud.dialogflow.cx.v3beta1.SessionEntityTypeOrBuilder getSessionEnti
    *
    * <pre>
    * The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-   * page][QueryResult.current_page] in the session. Format: `projects/&lt;Project
-   * ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent ID&gt;/pages/&lt;page ID&gt;`.
+   * page][QueryResult.current_page] in the session.
+   * Format: `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/agents/&lt;Agent
+   * ID&gt;/flows/&lt;Flow ID&gt;/pages/&lt;Page ID&gt;`.
    * If `current_page` is specified, the previous state of the session will be
    * ignored by Dialogflow, including the [previous
    * page][QueryResult.current_page] and the [previous session
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SecuritySettings.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SecuritySettings.java
index 07be6275f..2ffd6a753 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SecuritySettings.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SecuritySettings.java
@@ -849,8 +849,10 @@ public int getRedactionScopeValue() {
    * settings.
    * If empty, we use the default DLP inspect config.
    * The template name will have one of the following formats:
-   * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-   * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+   * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+   * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+   * ID&gt;` OR
+   * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
    * </pre>
    *
    * <code>string inspect_template = 9;</code>
@@ -877,8 +879,10 @@ public java.lang.String getInspectTemplate() {
    * settings.
    * If empty, we use the default DLP inspect config.
    * The template name will have one of the following formats:
-   * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-   * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+   * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+   * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+   * ID&gt;` OR
+   * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
    * </pre>
    *
    * <code>string inspect_template = 9;</code>
@@ -2017,8 +2021,10 @@ public Builder clearRedactionScope() {
      * settings.
      * If empty, we use the default DLP inspect config.
      * The template name will have one of the following formats:
-     * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-     * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+     * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+     * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+     * ID&gt;` OR
+     * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
      * </pre>
      *
      * <code>string inspect_template = 9;</code>
@@ -2044,8 +2050,10 @@ public java.lang.String getInspectTemplate() {
      * settings.
      * If empty, we use the default DLP inspect config.
      * The template name will have one of the following formats:
-     * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-     * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+     * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+     * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+     * ID&gt;` OR
+     * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
      * </pre>
      *
      * <code>string inspect_template = 9;</code>
@@ -2071,8 +2079,10 @@ public com.google.protobuf.ByteString getInspectTemplateBytes() {
      * settings.
      * If empty, we use the default DLP inspect config.
      * The template name will have one of the following formats:
-     * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-     * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+     * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+     * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+     * ID&gt;` OR
+     * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
      * </pre>
      *
      * <code>string inspect_template = 9;</code>
@@ -2097,8 +2107,10 @@ public Builder setInspectTemplate(java.lang.String value) {
      * settings.
      * If empty, we use the default DLP inspect config.
      * The template name will have one of the following formats:
-     * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-     * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+     * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+     * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+     * ID&gt;` OR
+     * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
      * </pre>
      *
      * <code>string inspect_template = 9;</code>
@@ -2119,8 +2131,10 @@ public Builder clearInspectTemplate() {
      * settings.
      * If empty, we use the default DLP inspect config.
      * The template name will have one of the following formats:
-     * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-     * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+     * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+     * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+     * ID&gt;` OR
+     * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
      * </pre>
      *
      * <code>string inspect_template = 9;</code>
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SecuritySettingsOrBuilder.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SecuritySettingsOrBuilder.java
index ea33201d9..31bcdcca4 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SecuritySettingsOrBuilder.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SecuritySettingsOrBuilder.java
@@ -147,8 +147,10 @@ public interface SecuritySettingsOrBuilder
    * settings.
    * If empty, we use the default DLP inspect config.
    * The template name will have one of the following formats:
-   * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-   * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+   * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+   * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+   * ID&gt;` OR
+   * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
    * </pre>
    *
    * <code>string inspect_template = 9;</code>
@@ -164,8 +166,10 @@ public interface SecuritySettingsOrBuilder
    * settings.
    * If empty, we use the default DLP inspect config.
    * The template name will have one of the following formats:
-   * `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-   * `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+   * `projects/&lt;Project ID&gt;/inspectTemplates/&lt;Template ID&gt;` OR
+   * `projects/&lt;Project ID&gt;/locations/&lt;Location ID&gt;/inspectTemplates/&lt;Template
+   * ID&gt;` OR
+   * `organizations/&lt;Organization ID&gt;/inspectTemplates/&lt;Template ID&gt;`
    * </pre>
    *
    * <code>string inspect_template = 9;</code>
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SessionProto.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SessionProto.java
index 55e6d9afd..f3dffe0c4 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SessionProto.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/SessionProto.java
@@ -139,165 +139,170 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
           + "y_input\030\003 \001(\0132..google.cloud.dialogflow."
           + "cx.v3beta1.QueryInputB\003\340A\002\022R\n\023output_aud"
           + "io_config\030\004 \001(\01325.google.cloud.dialogflo"
-          + "w.cx.v3beta1.OutputAudioConfig\"\334\001\n\024Detec"
+          + "w.cx.v3beta1.OutputAudioConfig\"\235\003\n\024Detec"
           + "tIntentResponse\022\023\n\013response_id\030\001 \001(\t\022E\n\014"
           + "query_result\030\002 \001(\0132/.google.cloud.dialog"
           + "flow.cx.v3beta1.QueryResult\022\024\n\014output_au"
           + "dio\030\004 \001(\014\022R\n\023output_audio_config\030\005 \001(\01325"
           + ".google.cloud.dialogflow.cx.v3beta1.Outp"
-          + "utAudioConfig\"\300\002\n\034StreamingDetectIntentR"
-          + "equest\0227\n\007session\030\001 \001(\tB&\372A#\n!dialogflow"
-          + ".googleapis.com/Session\022I\n\014query_params\030"
-          + "\002 \001(\01323.google.cloud.dialogflow.cx.v3bet"
-          + "a1.QueryParameters\022H\n\013query_input\030\003 \001(\0132"
-          + "..google.cloud.dialogflow.cx.v3beta1.Que"
-          + "ryInputB\003\340A\002\022R\n\023output_audio_config\030\004 \001("
-          + "\01325.google.cloud.dialogflow.cx.v3beta1.O"
-          + "utputAudioConfig\"\345\001\n\035StreamingDetectInte"
-          + "ntResponse\022\\\n\022recognition_result\030\001 \001(\0132>"
-          + ".google.cloud.dialogflow.cx.v3beta1.Stre"
-          + "amingRecognitionResultH\000\022Z\n\026detect_inten"
-          + "t_response\030\002 \001(\01328.google.cloud.dialogfl"
-          + "ow.cx.v3beta1.DetectIntentResponseH\000B\n\n\010"
-          + "response\"\251\003\n\032StreamingRecognitionResult\022"
-          + "`\n\014message_type\030\001 \001(\0162J.google.cloud.dia"
-          + "logflow.cx.v3beta1.StreamingRecognitionR"
-          + "esult.MessageType\022\022\n\ntranscript\030\002 \001(\t\022\020\n"
-          + "\010is_final\030\003 \001(\010\022\022\n\nconfidence\030\004 \001(\002\022\021\n\ts"
-          + "tability\030\006 \001(\002\022L\n\020speech_word_info\030\007 \003(\013"
-          + "22.google.cloud.dialogflow.cx.v3beta1.Sp"
-          + "eechWordInfo\0224\n\021speech_end_offset\030\010 \001(\0132"
-          + "\031.google.protobuf.Duration\"X\n\013MessageTyp"
-          + "e\022\034\n\030MESSAGE_TYPE_UNSPECIFIED\020\000\022\016\n\nTRANS"
-          + "CRIPT\020\001\022\033\n\027END_OF_SINGLE_UTTERANCE\020\002\"\216\004\n"
-          + "\017QueryParameters\022\021\n\ttime_zone\030\001 \001(\t\022)\n\014g"
-          + "eo_location\030\002 \001(\0132\023.google.type.LatLng\022S"
-          + "\n\024session_entity_types\030\003 \003(\01325.google.cl"
-          + "oud.dialogflow.cx.v3beta1.SessionEntityT"
-          + "ype\022(\n\007payload\030\004 \001(\0132\027.google.protobuf.S"
-          + "truct\022+\n\nparameters\030\005 \001(\0132\027.google.proto"
-          + "buf.Struct\0229\n\014current_page\030\006 \001(\tB#\372A \n\036d"
-          + "ialogflow.googleapis.com/Page\022\027\n\017disable"
-          + "_webhook\030\007 \001(\010\022$\n\034analyze_query_text_sen"
-          + "timent\030\010 \001(\010\022`\n\017webhook_headers\030\n \003(\0132G."
-          + "google.cloud.dialogflow.cx.v3beta1.Query"
-          + "Parameters.WebhookHeadersEntry\0325\n\023Webhoo"
-          + "kHeadersEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001("
-          + "\t:\0028\001\"\364\002\n\nQueryInput\022=\n\004text\030\002 \001(\0132-.goo"
-          + "gle.cloud.dialogflow.cx.v3beta1.TextInpu"
-          + "tH\000\022A\n\006intent\030\003 \001(\0132/.google.cloud.dialo"
-          + "gflow.cx.v3beta1.IntentInputH\000\022?\n\005audio\030"
-          + "\005 \001(\0132..google.cloud.dialogflow.cx.v3bet"
-          + "a1.AudioInputH\000\022?\n\005event\030\006 \001(\0132..google."
-          + "cloud.dialogflow.cx.v3beta1.EventInputH\000"
-          + "\022=\n\004dtmf\030\007 \001(\0132-.google.cloud.dialogflow"
-          + ".cx.v3beta1.DtmfInputH\000\022\032\n\rlanguage_code"
-          + "\030\004 \001(\tB\003\340A\002B\007\n\005input\"\200\006\n\013QueryResult\022\016\n\004"
-          + "text\030\001 \001(\tH\000\022?\n\016trigger_intent\030\013 \001(\tB%\372A"
-          + "\"\n dialogflow.googleapis.com/IntentH\000\022\024\n"
-          + "\ntranscript\030\014 \001(\tH\000\022\027\n\rtrigger_event\030\016 \001"
-          + "(\tH\000\022\025\n\rlanguage_code\030\002 \001(\t\022+\n\nparameter"
-          + "s\030\003 \001(\0132\027.google.protobuf.Struct\022N\n\021resp"
-          + "onse_messages\030\004 \003(\01323.google.cloud.dialo"
-          + "gflow.cx.v3beta1.ResponseMessage\022,\n\020webh"
-          + "ook_statuses\030\r \003(\0132\022.google.rpc.Status\0221"
-          + "\n\020webhook_payloads\030\006 \003(\0132\027.google.protob"
-          + "uf.Struct\022>\n\014current_page\030\007 \001(\0132(.google"
-          + ".cloud.dialogflow.cx.v3beta1.Page\022>\n\006int"
-          + "ent\030\010 \001(\0132*.google.cloud.dialogflow.cx.v"
-          + "3beta1.IntentB\002\030\001\022\'\n\033intent_detection_co"
-          + "nfidence\030\t \001(\002B\002\030\001\0228\n\005match\030\017 \001(\0132).goog"
-          + "le.cloud.dialogflow.cx.v3beta1.Match\0220\n\017"
-          + "diagnostic_info\030\n \001(\0132\027.google.protobuf."
-          + "Struct\022^\n\031sentiment_analysis_result\030\021 \001("
-          + "\0132;.google.cloud.dialogflow.cx.v3beta1.S"
-          + "entimentAnalysisResultB\007\n\005query\"\036\n\tTextI"
-          + "nput\022\021\n\004text\030\001 \001(\tB\003\340A\002\"G\n\013IntentInput\0228"
-          + "\n\006intent\030\001 \001(\tB(\340A\002\372A\"\n dialogflow.googl"
-          + "eapis.com/Intent\"f\n\nAudioInput\022I\n\006config"
-          + "\030\001 \001(\01324.google.cloud.dialogflow.cx.v3be"
-          + "ta1.InputAudioConfigB\003\340A\002\022\r\n\005audio\030\002 \001(\014"
-          + "\"\033\n\nEventInput\022\r\n\005event\030\001 \001(\t\"1\n\tDtmfInp"
-          + "ut\022\016\n\006digits\030\001 \001(\t\022\024\n\014finish_digit\030\002 \001(\t"
-          + "\"\373\002\n\005Match\022:\n\006intent\030\001 \001(\0132*.google.clou"
-          + "d.dialogflow.cx.v3beta1.Intent\022\r\n\005event\030"
-          + "\006 \001(\t\022+\n\nparameters\030\002 \001(\0132\027.google.proto"
-          + "buf.Struct\022\026\n\016resolved_input\030\003 \001(\t\022G\n\nma"
-          + "tch_type\030\004 \001(\01623.google.cloud.dialogflow"
-          + ".cx.v3beta1.Match.MatchType\022\022\n\nconfidenc"
-          + "e\030\005 \001(\002\"\204\001\n\tMatchType\022\032\n\026MATCH_TYPE_UNSP"
-          + "ECIFIED\020\000\022\n\n\006INTENT\020\001\022\021\n\rDIRECT_INTENT\020\002"
-          + "\022\025\n\021PARAMETER_FILLING\020\003\022\014\n\010NO_MATCH\020\004\022\014\n"
-          + "\010NO_INPUT\020\005\022\t\n\005EVENT\020\006\"\345\001\n\022MatchIntentRe"
-          + "quest\022:\n\007session\030\001 \001(\tB)\340A\002\372A#\n!dialogfl"
-          + "ow.googleapis.com/Session\022I\n\014query_param"
-          + "s\030\002 \001(\01323.google.cloud.dialogflow.cx.v3b"
-          + "eta1.QueryParameters\022H\n\013query_input\030\003 \001("
-          + "\0132..google.cloud.dialogflow.cx.v3beta1.Q"
-          + "ueryInputB\003\340A\002\"\232\002\n\023MatchIntentResponse\022\016"
-          + "\n\004text\030\001 \001(\tH\000\022?\n\016trigger_intent\030\002 \001(\tB%"
-          + "\372A\"\n dialogflow.googleapis.com/IntentH\000\022"
-          + "\024\n\ntranscript\030\003 \001(\tH\000\022\027\n\rtrigger_event\030\006"
-          + " \001(\tH\000\022:\n\007matches\030\004 \003(\0132).google.cloud.d"
-          + "ialogflow.cx.v3beta1.Match\022>\n\014current_pa"
-          + "ge\030\005 \001(\0132(.google.cloud.dialogflow.cx.v3"
-          + "beta1.PageB\007\n\005query\"\372\001\n\024FulfillIntentReq"
-          + "uest\022T\n\024match_intent_request\030\001 \001(\01326.goo"
-          + "gle.cloud.dialogflow.cx.v3beta1.MatchInt"
-          + "entRequest\0228\n\005match\030\002 \001(\0132).google.cloud"
-          + ".dialogflow.cx.v3beta1.Match\022R\n\023output_a"
-          + "udio_config\030\003 \001(\01325.google.cloud.dialogf"
-          + "low.cx.v3beta1.OutputAudioConfig\"\335\001\n\025Ful"
-          + "fillIntentResponse\022\023\n\013response_id\030\001 \001(\t\022"
-          + "E\n\014query_result\030\002 \001(\0132/.google.cloud.dia"
-          + "logflow.cx.v3beta1.QueryResult\022\024\n\014output"
-          + "_audio\030\003 \001(\014\022R\n\023output_audio_config\030\004 \001("
-          + "\01325.google.cloud.dialogflow.cx.v3beta1.O"
-          + "utputAudioConfig\";\n\027SentimentAnalysisRes"
-          + "ult\022\r\n\005score\030\001 \001(\002\022\021\n\tmagnitude\030\002 \001(\0022\212\n"
-          + "\n\010Sessions\022\272\002\n\014DetectIntent\0227.google.clo"
-          + "ud.dialogflow.cx.v3beta1.DetectIntentReq"
-          + "uest\0328.google.cloud.dialogflow.cx.v3beta"
-          + "1.DetectIntentResponse\"\266\001\202\323\344\223\002\257\001\"J/v3bet"
-          + "a1/{session=projects/*/locations/*/agent"
-          + "s/*/sessions/*}:detectIntent:\001*Z^\"Y/v3be"
-          + "ta1/{session=projects/*/locations/*/agen"
-          + "ts/*/environments/*/sessions/*}:detectIn"
-          + "tent:\001*\022\242\001\n\025StreamingDetectIntent\022@.goog"
-          + "le.cloud.dialogflow.cx.v3beta1.Streaming"
-          + "DetectIntentRequest\032A.google.cloud.dialo"
+          + "utAudioConfig\022\\\n\rresponse_type\030\006 \001(\0162E.g"
+          + "oogle.cloud.dialogflow.cx.v3beta1.Detect"
+          + "IntentResponse.ResponseType\022\032\n\022allow_can"
+          + "cellation\030\007 \001(\010\"E\n\014ResponseType\022\035\n\031RESPO"
+          + "NSE_TYPE_UNSPECIFIED\020\000\022\013\n\007PARTIAL\020\001\022\t\n\005F"
+          + "INAL\020\002\"\341\002\n\034StreamingDetectIntentRequest\022"
+          + "7\n\007session\030\001 \001(\tB&\372A#\n!dialogflow.google"
+          + "apis.com/Session\022I\n\014query_params\030\002 \001(\01323"
+          + ".google.cloud.dialogflow.cx.v3beta1.Quer"
+          + "yParameters\022H\n\013query_input\030\003 \001(\0132..googl"
+          + "e.cloud.dialogflow.cx.v3beta1.QueryInput"
+          + "B\003\340A\002\022R\n\023output_audio_config\030\004 \001(\01325.goo"
+          + "gle.cloud.dialogflow.cx.v3beta1.OutputAu"
+          + "dioConfig\022\037\n\027enable_partial_response\030\005 \001"
+          + "(\010\"\345\001\n\035StreamingDetectIntentResponse\022\\\n\022"
+          + "recognition_result\030\001 \001(\0132>.google.cloud."
+          + "dialogflow.cx.v3beta1.StreamingRecogniti"
+          + "onResultH\000\022Z\n\026detect_intent_response\030\002 \001"
+          + "(\01328.google.cloud.dialogflow.cx.v3beta1."
+          + "DetectIntentResponseH\000B\n\n\010response\"\251\003\n\032S"
+          + "treamingRecognitionResult\022`\n\014message_typ"
+          + "e\030\001 \001(\0162J.google.cloud.dialogflow.cx.v3b"
+          + "eta1.StreamingRecognitionResult.MessageT"
+          + "ype\022\022\n\ntranscript\030\002 \001(\t\022\020\n\010is_final\030\003 \001("
+          + "\010\022\022\n\nconfidence\030\004 \001(\002\022\021\n\tstability\030\006 \001(\002"
+          + "\022L\n\020speech_word_info\030\007 \003(\01322.google.clou"
+          + "d.dialogflow.cx.v3beta1.SpeechWordInfo\0224"
+          + "\n\021speech_end_offset\030\010 \001(\0132\031.google.proto"
+          + "buf.Duration\"X\n\013MessageType\022\034\n\030MESSAGE_T"
+          + "YPE_UNSPECIFIED\020\000\022\016\n\nTRANSCRIPT\020\001\022\033\n\027END"
+          + "_OF_SINGLE_UTTERANCE\020\002\"\216\004\n\017QueryParamete"
+          + "rs\022\021\n\ttime_zone\030\001 \001(\t\022)\n\014geo_location\030\002 "
+          + "\001(\0132\023.google.type.LatLng\022S\n\024session_enti"
+          + "ty_types\030\003 \003(\01325.google.cloud.dialogflow"
+          + ".cx.v3beta1.SessionEntityType\022(\n\007payload"
+          + "\030\004 \001(\0132\027.google.protobuf.Struct\022+\n\nparam"
+          + "eters\030\005 \001(\0132\027.google.protobuf.Struct\0229\n\014"
+          + "current_page\030\006 \001(\tB#\372A \n\036dialogflow.goog"
+          + "leapis.com/Page\022\027\n\017disable_webhook\030\007 \001(\010"
+          + "\022$\n\034analyze_query_text_sentiment\030\010 \001(\010\022`"
+          + "\n\017webhook_headers\030\n \003(\0132G.google.cloud.d"
+          + "ialogflow.cx.v3beta1.QueryParameters.Web"
+          + "hookHeadersEntry\0325\n\023WebhookHeadersEntry\022"
+          + "\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"\364\002\n\nQuer"
+          + "yInput\022=\n\004text\030\002 \001(\0132-.google.cloud.dial"
+          + "ogflow.cx.v3beta1.TextInputH\000\022A\n\006intent\030"
+          + "\003 \001(\0132/.google.cloud.dialogflow.cx.v3bet"
+          + "a1.IntentInputH\000\022?\n\005audio\030\005 \001(\0132..google"
+          + ".cloud.dialogflow.cx.v3beta1.AudioInputH"
+          + "\000\022?\n\005event\030\006 \001(\0132..google.cloud.dialogfl"
+          + "ow.cx.v3beta1.EventInputH\000\022=\n\004dtmf\030\007 \001(\013"
+          + "2-.google.cloud.dialogflow.cx.v3beta1.Dt"
+          + "mfInputH\000\022\032\n\rlanguage_code\030\004 \001(\tB\003\340A\002B\007\n"
+          + "\005input\"\200\006\n\013QueryResult\022\016\n\004text\030\001 \001(\tH\000\022?"
+          + "\n\016trigger_intent\030\013 \001(\tB%\372A\"\n dialogflow."
+          + "googleapis.com/IntentH\000\022\024\n\ntranscript\030\014 "
+          + "\001(\tH\000\022\027\n\rtrigger_event\030\016 \001(\tH\000\022\025\n\rlangua"
+          + "ge_code\030\002 \001(\t\022+\n\nparameters\030\003 \001(\0132\027.goog"
+          + "le.protobuf.Struct\022N\n\021response_messages\030"
+          + "\004 \003(\01323.google.cloud.dialogflow.cx.v3bet"
+          + "a1.ResponseMessage\022,\n\020webhook_statuses\030\r"
+          + " \003(\0132\022.google.rpc.Status\0221\n\020webhook_payl"
+          + "oads\030\006 \003(\0132\027.google.protobuf.Struct\022>\n\014c"
+          + "urrent_page\030\007 \001(\0132(.google.cloud.dialogf"
+          + "low.cx.v3beta1.Page\022>\n\006intent\030\010 \001(\0132*.go"
+          + "ogle.cloud.dialogflow.cx.v3beta1.IntentB"
+          + "\002\030\001\022\'\n\033intent_detection_confidence\030\t \001(\002"
+          + "B\002\030\001\0228\n\005match\030\017 \001(\0132).google.cloud.dialo"
+          + "gflow.cx.v3beta1.Match\0220\n\017diagnostic_inf"
+          + "o\030\n \001(\0132\027.google.protobuf.Struct\022^\n\031sent"
+          + "iment_analysis_result\030\021 \001(\0132;.google.clo"
+          + "ud.dialogflow.cx.v3beta1.SentimentAnalys"
+          + "isResultB\007\n\005query\"\036\n\tTextInput\022\021\n\004text\030\001"
+          + " \001(\tB\003\340A\002\"G\n\013IntentInput\0228\n\006intent\030\001 \001(\t"
+          + "B(\340A\002\372A\"\n dialogflow.googleapis.com/Inte"
+          + "nt\"f\n\nAudioInput\022I\n\006config\030\001 \001(\01324.googl"
+          + "e.cloud.dialogflow.cx.v3beta1.InputAudio"
+          + "ConfigB\003\340A\002\022\r\n\005audio\030\002 \001(\014\"\033\n\nEventInput"
+          + "\022\r\n\005event\030\001 \001(\t\"1\n\tDtmfInput\022\016\n\006digits\030\001"
+          + " \001(\t\022\024\n\014finish_digit\030\002 \001(\t\"\373\002\n\005Match\022:\n\006"
+          + "intent\030\001 \001(\0132*.google.cloud.dialogflow.c"
+          + "x.v3beta1.Intent\022\r\n\005event\030\006 \001(\t\022+\n\nparam"
+          + "eters\030\002 \001(\0132\027.google.protobuf.Struct\022\026\n\016"
+          + "resolved_input\030\003 \001(\t\022G\n\nmatch_type\030\004 \001(\016"
+          + "23.google.cloud.dialogflow.cx.v3beta1.Ma"
+          + "tch.MatchType\022\022\n\nconfidence\030\005 \001(\002\"\204\001\n\tMa"
+          + "tchType\022\032\n\026MATCH_TYPE_UNSPECIFIED\020\000\022\n\n\006I"
+          + "NTENT\020\001\022\021\n\rDIRECT_INTENT\020\002\022\025\n\021PARAMETER_"
+          + "FILLING\020\003\022\014\n\010NO_MATCH\020\004\022\014\n\010NO_INPUT\020\005\022\t\n"
+          + "\005EVENT\020\006\"\345\001\n\022MatchIntentRequest\022:\n\007sessi"
+          + "on\030\001 \001(\tB)\340A\002\372A#\n!dialogflow.googleapis."
+          + "com/Session\022I\n\014query_params\030\002 \001(\01323.goog"
+          + "le.cloud.dialogflow.cx.v3beta1.QueryPara"
+          + "meters\022H\n\013query_input\030\003 \001(\0132..google.clo"
+          + "ud.dialogflow.cx.v3beta1.QueryInputB\003\340A\002"
+          + "\"\232\002\n\023MatchIntentResponse\022\016\n\004text\030\001 \001(\tH\000"
+          + "\022?\n\016trigger_intent\030\002 \001(\tB%\372A\"\n dialogflo"
+          + "w.googleapis.com/IntentH\000\022\024\n\ntranscript\030"
+          + "\003 \001(\tH\000\022\027\n\rtrigger_event\030\006 \001(\tH\000\022:\n\007matc"
+          + "hes\030\004 \003(\0132).google.cloud.dialogflow.cx.v"
+          + "3beta1.Match\022>\n\014current_page\030\005 \001(\0132(.goo"
+          + "gle.cloud.dialogflow.cx.v3beta1.PageB\007\n\005"
+          + "query\"\372\001\n\024FulfillIntentRequest\022T\n\024match_"
+          + "intent_request\030\001 \001(\01326.google.cloud.dial"
+          + "ogflow.cx.v3beta1.MatchIntentRequest\0228\n\005"
+          + "match\030\002 \001(\0132).google.cloud.dialogflow.cx"
+          + ".v3beta1.Match\022R\n\023output_audio_config\030\003 "
+          + "\001(\01325.google.cloud.dialogflow.cx.v3beta1"
+          + ".OutputAudioConfig\"\335\001\n\025FulfillIntentResp"
+          + "onse\022\023\n\013response_id\030\001 \001(\t\022E\n\014query_resul"
+          + "t\030\002 \001(\0132/.google.cloud.dialogflow.cx.v3b"
+          + "eta1.QueryResult\022\024\n\014output_audio\030\003 \001(\014\022R"
+          + "\n\023output_audio_config\030\004 \001(\01325.google.clo"
+          + "ud.dialogflow.cx.v3beta1.OutputAudioConf"
+          + "ig\";\n\027SentimentAnalysisResult\022\r\n\005score\030\001"
+          + " \001(\002\022\021\n\tmagnitude\030\002 \001(\0022\212\n\n\010Sessions\022\272\002\n"
+          + "\014DetectIntent\0227.google.cloud.dialogflow."
+          + "cx.v3beta1.DetectIntentRequest\0328.google."
+          + "cloud.dialogflow.cx.v3beta1.DetectIntent"
+          + "Response\"\266\001\202\323\344\223\002\257\001\"J/v3beta1/{session=pr"
+          + "ojects/*/locations/*/agents/*/sessions/*"
+          + "}:detectIntent:\001*Z^\"Y/v3beta1/{session=p"
+          + "rojects/*/locations/*/agents/*/environme"
+          + "nts/*/sessions/*}:detectIntent:\001*\022\242\001\n\025St"
+          + "reamingDetectIntent\022@.google.cloud.dialo"
           + "gflow.cx.v3beta1.StreamingDetectIntentRe"
-          + "sponse\"\000(\0010\001\022\265\002\n\013MatchIntent\0226.google.cl"
-          + "oud.dialogflow.cx.v3beta1.MatchIntentReq"
-          + "uest\0327.google.cloud.dialogflow.cx.v3beta"
-          + "1.MatchIntentResponse\"\264\001\202\323\344\223\002\255\001\"I/v3beta"
-          + "1/{session=projects/*/locations/*/agents"
-          + "/*/sessions/*}:matchIntent:\001*Z]\"X/v3beta"
-          + "1/{session=projects/*/locations/*/agents"
-          + "/*/environments/*/sessions/*}:matchInten"
-          + "t:\001*\022\351\002\n\rFulfillIntent\0228.google.cloud.di"
-          + "alogflow.cx.v3beta1.FulfillIntentRequest"
-          + "\0329.google.cloud.dialogflow.cx.v3beta1.Fu"
-          + "lfillIntentResponse\"\342\001\202\323\344\223\002\333\001\"`/v3beta1/"
-          + "{match_intent_request.session=projects/*"
-          + "/locations/*/agents/*/sessions/*}:fulfil"
-          + "lIntent:\001*Zt\"o/v3beta1/{match_intent_req"
-          + "uest.session=projects/*/locations/*/agen"
-          + "ts/*/environments/*/sessions/*}:fulfillI"
-          + "ntent:\001*\032x\312A\031dialogflow.googleapis.com\322A"
-          + "Yhttps://www.googleapis.com/auth/cloud-p"
-          + "latform,https://www.googleapis.com/auth/"
-          + "dialogflowB\203\003\n&com.google.cloud.dialogfl"
-          + "ow.cx.v3beta1B\014SessionProtoP\001ZDgoogle.go"
-          + "lang.org/genproto/googleapis/cloud/dialo"
-          + "gflow/cx/v3beta1;cx\370\001\001\242\002\002DF\252\002\"Google.Clo"
-          + "ud.Dialogflow.Cx.V3Beta1\352A\324\001\n!dialogflow"
-          + ".googleapis.com/Session\022Iprojects/{proje"
-          + "ct}/locations/{location}/agents/{agent}/"
-          + "sessions/{session}\022dprojects/{project}/l"
-          + "ocations/{location}/agents/{agent}/envir"
-          + "onments/{environment}/sessions/{session}"
-          + "b\006proto3"
+          + "quest\032A.google.cloud.dialogflow.cx.v3bet"
+          + "a1.StreamingDetectIntentResponse\"\000(\0010\001\022\265"
+          + "\002\n\013MatchIntent\0226.google.cloud.dialogflow"
+          + ".cx.v3beta1.MatchIntentRequest\0327.google."
+          + "cloud.dialogflow.cx.v3beta1.MatchIntentR"
+          + "esponse\"\264\001\202\323\344\223\002\255\001\"I/v3beta1/{session=pro"
+          + "jects/*/locations/*/agents/*/sessions/*}"
+          + ":matchIntent:\001*Z]\"X/v3beta1/{session=pro"
+          + "jects/*/locations/*/agents/*/environment"
+          + "s/*/sessions/*}:matchIntent:\001*\022\351\002\n\rFulfi"
+          + "llIntent\0228.google.cloud.dialogflow.cx.v3"
+          + "beta1.FulfillIntentRequest\0329.google.clou"
+          + "d.dialogflow.cx.v3beta1.FulfillIntentRes"
+          + "ponse\"\342\001\202\323\344\223\002\333\001\"`/v3beta1/{match_intent_"
+          + "request.session=projects/*/locations/*/a"
+          + "gents/*/sessions/*}:fulfillIntent:\001*Zt\"o"
+          + "/v3beta1/{match_intent_request.session=p"
+          + "rojects/*/locations/*/agents/*/environme"
+          + "nts/*/sessions/*}:fulfillIntent:\001*\032x\312A\031d"
+          + "ialogflow.googleapis.com\322AYhttps://www.g"
+          + "oogleapis.com/auth/cloud-platform,https:"
+          + "//www.googleapis.com/auth/dialogflowB\203\003\n"
+          + "&com.google.cloud.dialogflow.cx.v3beta1B"
+          + "\014SessionProtoP\001ZDgoogle.golang.org/genpr"
+          + "oto/googleapis/cloud/dialogflow/cx/v3bet"
+          + "a1;cx\370\001\001\242\002\002DF\252\002\"Google.Cloud.Dialogflow."
+          + "Cx.V3Beta1\352A\324\001\n!dialogflow.googleapis.co"
+          + "m/Session\022Iprojects/{project}/locations/"
+          + "{location}/agents/{agent}/sessions/{sess"
+          + "ion}\022dprojects/{project}/locations/{loca"
+          + "tion}/agents/{agent}/environments/{envir"
+          + "onment}/sessions/{session}b\006proto3"
     };
     descriptor =
         com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
@@ -332,7 +337,12 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
         new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
             internal_static_google_cloud_dialogflow_cx_v3beta1_DetectIntentResponse_descriptor,
             new java.lang.String[] {
-              "ResponseId", "QueryResult", "OutputAudio", "OutputAudioConfig",
+              "ResponseId",
+              "QueryResult",
+              "OutputAudio",
+              "OutputAudioConfig",
+              "ResponseType",
+              "AllowCancellation",
             });
     internal_static_google_cloud_dialogflow_cx_v3beta1_StreamingDetectIntentRequest_descriptor =
         getDescriptor().getMessageTypes().get(2);
@@ -340,7 +350,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
         new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
             internal_static_google_cloud_dialogflow_cx_v3beta1_StreamingDetectIntentRequest_descriptor,
             new java.lang.String[] {
-              "Session", "QueryParams", "QueryInput", "OutputAudioConfig",
+              "Session", "QueryParams", "QueryInput", "OutputAudioConfig", "EnablePartialResponse",
             });
     internal_static_google_cloud_dialogflow_cx_v3beta1_StreamingDetectIntentResponse_descriptor =
         getDescriptor().getMessageTypes().get(3);
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/StreamingDetectIntentRequest.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/StreamingDetectIntentRequest.java
index d75112211..715452505 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/StreamingDetectIntentRequest.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/StreamingDetectIntentRequest.java
@@ -147,6 +147,11 @@ private StreamingDetectIntentRequest(
                 outputAudioConfig_ = subBuilder.buildPartial();
               }
 
+              break;
+            }
+          case 40:
+            {
+              enablePartialResponse_ = input.readBool();
               break;
             }
           default:
@@ -411,6 +416,27 @@ public com.google.cloud.dialogflow.cx.v3beta1.OutputAudioConfig getOutputAudioCo
     return getOutputAudioConfig();
   }
 
+  public static final int ENABLE_PARTIAL_RESPONSE_FIELD_NUMBER = 5;
+  private boolean enablePartialResponse_;
+  /**
+   *
+   *
+   * <pre>
+   * Enable partial detect intent response. If this flag is not enabled,
+   * response stream still contains only one final `DetectIntentResponse` even
+   * if some `Fulfillment`s in the agent have been configured to return partial
+   * responses.
+   * </pre>
+   *
+   * <code>bool enable_partial_response = 5;</code>
+   *
+   * @return The enablePartialResponse.
+   */
+  @java.lang.Override
+  public boolean getEnablePartialResponse() {
+    return enablePartialResponse_;
+  }
+
   private byte memoizedIsInitialized = -1;
 
   @java.lang.Override
@@ -437,6 +463,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
     if (outputAudioConfig_ != null) {
       output.writeMessage(4, getOutputAudioConfig());
     }
+    if (enablePartialResponse_ != false) {
+      output.writeBool(5, enablePartialResponse_);
+    }
     unknownFields.writeTo(output);
   }
 
@@ -458,6 +487,9 @@ public int getSerializedSize() {
     if (outputAudioConfig_ != null) {
       size += com.google.protobuf.CodedOutputStream.computeMessageSize(4, getOutputAudioConfig());
     }
+    if (enablePartialResponse_ != false) {
+      size += com.google.protobuf.CodedOutputStream.computeBoolSize(5, enablePartialResponse_);
+    }
     size += unknownFields.getSerializedSize();
     memoizedSize = size;
     return size;
@@ -487,6 +519,7 @@ public boolean equals(final java.lang.Object obj) {
     if (hasOutputAudioConfig()) {
       if (!getOutputAudioConfig().equals(other.getOutputAudioConfig())) return false;
     }
+    if (getEnablePartialResponse() != other.getEnablePartialResponse()) return false;
     if (!unknownFields.equals(other.unknownFields)) return false;
     return true;
   }
@@ -512,6 +545,8 @@ public int hashCode() {
       hash = (37 * hash) + OUTPUT_AUDIO_CONFIG_FIELD_NUMBER;
       hash = (53 * hash) + getOutputAudioConfig().hashCode();
     }
+    hash = (37 * hash) + ENABLE_PARTIAL_RESPONSE_FIELD_NUMBER;
+    hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getEnablePartialResponse());
     hash = (29 * hash) + unknownFields.hashCode();
     memoizedHashCode = hash;
     return hash;
@@ -701,6 +736,8 @@ public Builder clear() {
         outputAudioConfig_ = null;
         outputAudioConfigBuilder_ = null;
       }
+      enablePartialResponse_ = false;
+
       return this;
     }
 
@@ -746,6 +783,7 @@ public com.google.cloud.dialogflow.cx.v3beta1.StreamingDetectIntentRequest build
       } else {
         result.outputAudioConfig_ = outputAudioConfigBuilder_.build();
       }
+      result.enablePartialResponse_ = enablePartialResponse_;
       onBuilt();
       return result;
     }
@@ -812,6 +850,9 @@ public Builder mergeFrom(
       if (other.hasOutputAudioConfig()) {
         mergeOutputAudioConfig(other.getOutputAudioConfig());
       }
+      if (other.getEnablePartialResponse() != false) {
+        setEnablePartialResponse(other.getEnablePartialResponse());
+      }
       this.mergeUnknownFields(other.unknownFields);
       onChanged();
       return this;
@@ -1601,6 +1642,67 @@ public Builder clearOutputAudioConfig() {
       return outputAudioConfigBuilder_;
     }
 
+    private boolean enablePartialResponse_;
+    /**
+     *
+     *
+     * <pre>
+     * Enable partial detect intent response. If this flag is not enabled,
+     * response stream still contains only one final `DetectIntentResponse` even
+     * if some `Fulfillment`s in the agent have been configured to return partial
+     * responses.
+     * </pre>
+     *
+     * <code>bool enable_partial_response = 5;</code>
+     *
+     * @return The enablePartialResponse.
+     */
+    @java.lang.Override
+    public boolean getEnablePartialResponse() {
+      return enablePartialResponse_;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Enable partial detect intent response. If this flag is not enabled,
+     * response stream still contains only one final `DetectIntentResponse` even
+     * if some `Fulfillment`s in the agent have been configured to return partial
+     * responses.
+     * </pre>
+     *
+     * <code>bool enable_partial_response = 5;</code>
+     *
+     * @param value The enablePartialResponse to set.
+     * @return This builder for chaining.
+     */
+    public Builder setEnablePartialResponse(boolean value) {
+
+      enablePartialResponse_ = value;
+      onChanged();
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Enable partial detect intent response. If this flag is not enabled,
+     * response stream still contains only one final `DetectIntentResponse` even
+     * if some `Fulfillment`s in the agent have been configured to return partial
+     * responses.
+     * </pre>
+     *
+     * <code>bool enable_partial_response = 5;</code>
+     *
+     * @return This builder for chaining.
+     */
+    public Builder clearEnablePartialResponse() {
+
+      enablePartialResponse_ = false;
+      onChanged();
+      return this;
+    }
+
     @java.lang.Override
     public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
       return super.setUnknownFields(unknownFields);
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/StreamingDetectIntentRequestOrBuilder.java b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/StreamingDetectIntentRequestOrBuilder.java
index e9bed50d9..a4aff0f31 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/StreamingDetectIntentRequestOrBuilder.java
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/java/com/google/cloud/dialogflow/cx/v3beta1/StreamingDetectIntentRequestOrBuilder.java
@@ -186,4 +186,20 @@ public interface StreamingDetectIntentRequestOrBuilder
    * <code>.google.cloud.dialogflow.cx.v3beta1.OutputAudioConfig output_audio_config = 4;</code>
    */
   com.google.cloud.dialogflow.cx.v3beta1.OutputAudioConfigOrBuilder getOutputAudioConfigOrBuilder();
+
+  /**
+   *
+   *
+   * <pre>
+   * Enable partial detect intent response. If this flag is not enabled,
+   * response stream still contains only one final `DetectIntentResponse` even
+   * if some `Fulfillment`s in the agent have been configured to return partial
+   * responses.
+   * </pre>
+   *
+   * <code>bool enable_partial_response = 5;</code>
+   *
+   * @return The enablePartialResponse.
+   */
+  boolean getEnablePartialResponse();
 }
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/agent.proto b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/agent.proto
index 1824e0b25..64bc6293a 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/agent.proto
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/agent.proto
@@ -159,12 +159,15 @@ message Agent {
   // Required. The human-readable name of the agent, unique within the location.
   string display_name = 2 [(google.api.field_behavior) = REQUIRED];
 
-  // Immutable. The default language of the agent as a language tag.
+  // Required. Immutable. The default language of the agent as a language tag.
   // See [Language
   // Support](https://cloud.google.com/dialogflow/cx/docs/reference/language)
   // for a list of the currently supported language codes.
   // This field cannot be set by the [Agents.UpdateAgent][google.cloud.dialogflow.cx.v3beta1.Agents.UpdateAgent] method.
-  string default_language_code = 3 [(google.api.field_behavior) = IMMUTABLE];
+  string default_language_code = 3 [
+    (google.api.field_behavior) = REQUIRED,
+    (google.api.field_behavior) = IMMUTABLE
+  ];
 
   // The list of all languages supported by the agent (except for the
   // `default_language_code`).
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/fulfillment.proto b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/fulfillment.proto
index 74d9e8224..e81e8d5a6 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/fulfillment.proto
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/fulfillment.proto
@@ -95,6 +95,17 @@ message Fulfillment {
                         type: "dialogflow.googleapis.com/Webhook"
                       }];
 
+  // Whether Dialogflow should return currently queued fulfillment response
+  // messages in streaming APIs. If a webhook is specified, it happens before
+  // Dialogflow invokes webhook.
+  // Warning:
+  // 1) This flag only affects streaming API. Responses are still queued
+  // and returned once in non-streaming API.
+  // 2) The flag can be enabled in any fulfillment but only the first 3 partial
+  // responses will be returned. You may only want to apply it to fulfillments
+  // that have slow webhooks.
+  bool return_partial_responses = 8;
+
   // The tag used by the webhook to identify which fulfillment is being called.
   // This field is required if `webhook` is specified.
   string tag = 3;
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/security_settings.proto b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/security_settings.proto
index d05ae1fab..8b149f13a 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/security_settings.proto
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/security_settings.proto
@@ -226,8 +226,10 @@ message SecuritySettings {
   // If empty, we use the default DLP inspect config.
   //
   // The template name will have one of the following formats:
-  // `projects/PROJECT_ID/inspectTemplates/TEMPLATE_ID` OR
-  // `organizations/ORGANIZATION_ID/inspectTemplates/TEMPLATE_ID`
+  // `projects/<Project ID>/inspectTemplates/<Template ID>` OR
+  // `projects/<Project ID>/locations/<Location ID>/inspectTemplates/<Template
+  // ID>` OR
+  // `organizations/<Organization ID>/inspectTemplates/<Template ID>`
   string inspect_template = 9;
 
   // Specifies how data is retained. Note that even if the data is
diff --git a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/session.proto b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/session.proto
index c5a35fe6b..ad2af93eb 100644
--- a/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/session.proto
+++ b/proto-google-cloud-dialogflow-cx-v3beta1/src/main/proto/google/cloud/dialogflow/cx/v3beta1/session.proto
@@ -147,6 +147,20 @@ message DetectIntentRequest {
 
 // The message returned from the DetectIntent method.
 message DetectIntentResponse {
+  // Represents different DetectIntentResponse types.
+  enum ResponseType {
+    // Not specified. This should never happen.
+    RESPONSE_TYPE_UNSPECIFIED = 0;
+
+    // Partial response. e.g. Aggregated responses in a Fulfillment that enables
+    // `return_partial_response` can be returned as partial response.
+    // WARNING: partial response is not eligible for barge-in.
+    PARTIAL = 1;
+
+    // Final response.
+    FINAL = 2;
+  }
+
   // Output only. The unique identifier of the response. It can be used to
   // locate a response in the training example set or for reporting issues.
   string response_id = 1;
@@ -169,6 +183,14 @@ message DetectIntentResponse {
 
   // The config used by the speech synthesizer to generate the output audio.
   OutputAudioConfig output_audio_config = 5;
+
+  // Response type.
+  ResponseType response_type = 6;
+
+  // Indicates whether the partial response can be cancelled when a later
+  // response arrives. e.g. if the agent specified some music as partial
+  // response, it can be cancelled.
+  bool allow_cancellation = 7;
 }
 
 // The top-level message sent by the client to the
@@ -229,6 +251,12 @@ message StreamingDetectIntentRequest {
 
   // Instructs the speech synthesizer how to generate the output audio.
   OutputAudioConfig output_audio_config = 4;
+
+  // Enable partial detect intent response. If this flag is not enabled,
+  // response stream still contains only one final `DetectIntentResponse` even
+  // if some `Fulfillment`s in the agent have been configured to return partial
+  // responses.
+  bool enable_partial_response = 5;
 }
 
 // The top-level message returned from the `StreamingDetectIntent` method.
@@ -408,8 +436,9 @@ message QueryParameters {
   google.protobuf.Struct parameters = 5;
 
   // The unique identifier of the [page][google.cloud.dialogflow.cx.v3beta1.Page] to override the [current
-  // page][QueryResult.current_page] in the session. Format: `projects/<Project
-  // ID>/locations/<Location ID>/agents/<Agent ID>/pages/<page ID>`.
+  // page][QueryResult.current_page] in the session.
+  // Format: `projects/<Project ID>/locations/<Location ID>/agents/<Agent
+  // ID>/flows/<Flow ID>/pages/<Page ID>`.
   //
   // If `current_page` is specified, the previous state of the session will be
   // ignored by Dialogflow, including the [previous
diff --git a/synth.metadata b/synth.metadata
index ecf0c5872..36c7b7376 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,23 +4,23 @@
       "git": {
         "name": ".",
         "remote": "https://github.com/googleapis/java-dialogflow-cx.git",
-        "sha": "e52f20e59643b79b23b98f79fa255a4880472ce1"
+        "sha": "3209e54b870601bdc00ea16ca88f5c87ad811ce9"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "08c4eeb531c01ad031134dca94b18e3f7dd35902",
-        "internalRef": "378718217"
+        "sha": "ecc3ac67807074d85054694a0574d387c862502d",
+        "internalRef": "378978212"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "08c4eeb531c01ad031134dca94b18e3f7dd35902",
-        "internalRef": "378718217"
+        "sha": "ecc3ac67807074d85054694a0574d387c862502d",
+        "internalRef": "378978212"
       }
     },
     {