Quote output plugin param name for consistency

confluentinc · Aug 29, 2016 · 5d87428 · 5d87428
1 parent ae9acb9
commit 5d87428
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client/replication.c b/client/replication.c
@@ -145,7 +145,7 @@ int replication_stream_check(replication_stream_t stream) {
  * starting from position stream->start_lsn. */
 int replication_stream_start(replication_stream_t stream, const char *error_policy) {
     PQExpBuffer query = createPQExpBuffer();
-    appendPQExpBuffer(query, "START_REPLICATION SLOT \"%s\" LOGICAL %X/%X (error_policy '%s')",
+    appendPQExpBuffer(query, "START_REPLICATION SLOT \"%s\" LOGICAL %X/%X (\"error_policy\" '%s')",
             stream->slot_name,
             (uint32) (stream->start_lsn >> 32), (uint32) stream->start_lsn,
             error_policy);