diff --git a/src/http/ngx_http.c b/src/http/ngx_http.c
index 7f2b4225a..2ce563e5b 100644
--- a/src/http/ngx_http.c
+++ b/src/http/ngx_http.c
@@ -314,6 +314,10 @@ ngx_http_block(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
         }
     }
 
+    if (ngx_http_init_filters(cf) != NGX_OK) {
+        return NGX_CONF_ERROR;
+    }
+
     if (ngx_http_variables_init_vars(cf) != NGX_OK) {
         return NGX_CONF_ERROR;
     }
diff --git a/src/http/ngx_http.h b/src/http/ngx_http.h
index 4fb6b17ea..c9d4a975c 100644
--- a/src/http/ngx_http.h
+++ b/src/http/ngx_http.h
@@ -172,6 +172,8 @@ char *ngx_http_merge_types(ngx_conf_t *cf, ngx_array_t **keys,
 ngx_int_t ngx_http_set_default_types(ngx_conf_t *cf, ngx_array_t **types,
     ngx_str_t *default_type);
 
+char *ngx_http_init_filters(ngx_conf_t *cf);
+
 #if (NGX_HTTP_DEGRADATION)
 ngx_uint_t  ngx_http_degraded(ngx_http_request_t *);
 #endif
diff --git a/src/http/ngx_http_core_module.c b/src/http/ngx_http_core_module.c
index c75ddb849..abe37f718 100644
--- a/src/http/ngx_http_core_module.c
+++ b/src/http/ngx_http_core_module.c
@@ -1845,6 +1845,8 @@ ngx_http_send_response(ngx_http_request_t *r, ngx_uint_t status,
 ngx_int_t
 ngx_http_send_header(ngx_http_request_t *r)
 {
+    ngx_http_core_main_conf_t  *cmcf;
+
     if (r->post_action) {
         return NGX_OK;
     }
@@ -1860,7 +1862,9 @@ ngx_http_send_header(ngx_http_request_t *r)
         r->headers_out.status_line.len = 0;
     }
 
-    return ngx_http_top_header_filter(r);
+    cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
+
+    return cmcf->top_header_filter(r);
 }
 
 
@@ -1898,15 +1902,18 @@ ngx_http_send_early_hints(ngx_http_request_t *r)
 ngx_int_t
 ngx_http_output_filter(ngx_http_request_t *r, ngx_chain_t *in)
 {
-    ngx_int_t          rc;
-    ngx_connection_t  *c;
+    ngx_int_t                   rc;
+    ngx_connection_t           *c;
+    ngx_http_core_main_conf_t  *cmcf;
 
     c = r->connection;
 
+    cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
+
     ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0,
                    "http output filter \"%V?%V\"", &r->uri, &r->args);
 
-    rc = ngx_http_top_body_filter(r, in);
+    rc = cmcf->top_body_filter(r, in);
 
     if (rc == NGX_ERROR) {
         /* NGX_ERROR may be returned by any filter */
@@ -5406,3 +5413,22 @@ ngx_http_core_pool_size(ngx_conf_t *cf, void *post, void *data)
 
     return NGX_CONF_OK;
 }
+
+
+char *
+ngx_http_init_filters(ngx_conf_t *cf)
+{
+    ngx_http_core_main_conf_t  *cmcf;
+
+    cmcf = ngx_http_conf_get_module_main_conf(cf, ngx_http_core_module);
+
+    cmcf->top_header_filter = ngx_http_top_header_filter;
+    cmcf->top_body_filter = ngx_http_top_body_filter;
+    cmcf->top_request_body_filter = ngx_http_top_request_body_filter;
+
+    ngx_http_top_header_filter = NULL;
+    ngx_http_top_body_filter = NULL;
+    ngx_http_top_request_body_filter = NULL;
+
+    return NGX_CONF_OK;
+}
diff --git a/src/http/ngx_http_core_module.h b/src/http/ngx_http_core_module.h
index 9be565373..28024c4dc 100644
--- a/src/http/ngx_http_core_module.h
+++ b/src/http/ngx_http_core_module.h
@@ -64,6 +64,13 @@ typedef struct ngx_http_location_tree_node_s  ngx_http_location_tree_node_t;
 typedef struct ngx_http_core_loc_conf_s  ngx_http_core_loc_conf_t;
 
 
+typedef ngx_int_t (*ngx_http_output_header_filter_pt)(ngx_http_request_t *r);
+typedef ngx_int_t (*ngx_http_output_body_filter_pt)
+    (ngx_http_request_t *r, ngx_chain_t *chain);
+typedef ngx_int_t (*ngx_http_request_body_filter_pt)
+    (ngx_http_request_t *r, ngx_chain_t *chain);
+
+
 typedef struct {
     struct sockaddr           *sockaddr;
     socklen_t                  socklen;
@@ -175,6 +182,10 @@ typedef struct {
     ngx_array_t               *ports;
 
     ngx_http_phase_t           phases[NGX_HTTP_LOG_PHASE + 1];
+
+    ngx_http_output_header_filter_pt  top_header_filter;
+    ngx_http_output_body_filter_pt    top_body_filter;
+    ngx_http_request_body_filter_pt   top_request_body_filter;
 } ngx_http_core_main_conf_t;
 
 
@@ -524,13 +535,6 @@ ngx_int_t ngx_http_named_location(ngx_http_request_t *r, ngx_str_t *name);
 ngx_http_cleanup_t *ngx_http_cleanup_add(ngx_http_request_t *r, size_t size);
 
 
-typedef ngx_int_t (*ngx_http_output_header_filter_pt)(ngx_http_request_t *r);
-typedef ngx_int_t (*ngx_http_output_body_filter_pt)
-    (ngx_http_request_t *r, ngx_chain_t *chain);
-typedef ngx_int_t (*ngx_http_request_body_filter_pt)
-    (ngx_http_request_t *r, ngx_chain_t *chain);
-
-
 ngx_int_t ngx_http_output_filter(ngx_http_request_t *r, ngx_chain_t *chain);
 ngx_int_t ngx_http_write_filter(ngx_http_request_t *r, ngx_chain_t *chain);
 ngx_int_t ngx_http_request_body_save_filter(ngx_http_request_t *r,
diff --git a/src/http/ngx_http_request_body.c b/src/http/ngx_http_request_body.c
index 93c69220c..d449f64c4 100644
--- a/src/http/ngx_http_request_body.c
+++ b/src/http/ngx_http_request_body.c
@@ -1000,11 +1000,12 @@ ngx_http_request_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
 static ngx_int_t
 ngx_http_request_body_length_filter(ngx_http_request_t *r, ngx_chain_t *in)
 {
-    size_t                     size;
-    ngx_int_t                  rc;
-    ngx_buf_t                 *b;
-    ngx_chain_t               *cl, *tl, *out, **ll;
-    ngx_http_request_body_t   *rb;
+    size_t                      size;
+    ngx_int_t                   rc;
+    ngx_buf_t                  *b;
+    ngx_chain_t                *cl, *tl, *out, **ll;
+    ngx_http_request_body_t    *rb;
+    ngx_http_core_main_conf_t  *cmcf;
 
     rb = r->request_body;
 
@@ -1075,7 +1076,9 @@ ngx_http_request_body_length_filter(ngx_http_request_t *r, ngx_chain_t *in)
         ll = &tl->next;
     }
 
-    rc = ngx_http_top_request_body_filter(r, out);
+    cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
+
+    rc = cmcf->top_request_body_filter(r, out);
 
     ngx_chain_update_chains(r->pool, &rb->free, &rb->busy, &out,
                             (ngx_buf_tag_t) &ngx_http_read_client_request_body);
@@ -1087,13 +1090,14 @@ ngx_http_request_body_length_filter(ngx_http_request_t *r, ngx_chain_t *in)
 static ngx_int_t
 ngx_http_request_body_chunked_filter(ngx_http_request_t *r, ngx_chain_t *in)
 {
-    size_t                     size;
-    ngx_int_t                  rc;
-    ngx_buf_t                 *b;
-    ngx_chain_t               *cl, *out, *tl, **ll;
-    ngx_http_request_body_t   *rb;
-    ngx_http_core_loc_conf_t  *clcf;
-    ngx_http_core_srv_conf_t  *cscf;
+    size_t                      size;
+    ngx_int_t                   rc;
+    ngx_buf_t                  *b;
+    ngx_chain_t                *cl, *out, *tl, **ll;
+    ngx_http_request_body_t    *rb;
+    ngx_http_core_loc_conf_t   *clcf;
+    ngx_http_core_srv_conf_t   *cscf;
+    ngx_http_core_main_conf_t  *cmcf;
 
     rb = r->request_body;
 
@@ -1259,7 +1263,9 @@ ngx_http_request_body_chunked_filter(ngx_http_request_t *r, ngx_chain_t *in)
         }
     }
 
-    rc = ngx_http_top_request_body_filter(r, out);
+    cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
+
+    rc = cmcf->top_request_body_filter(r, out);
 
     ngx_chain_update_chains(r->pool, &rb->free, &rb->busy, &out,
                             (ngx_buf_tag_t) &ngx_http_read_client_request_body);
diff --git a/src/http/v2/ngx_http_v2.c b/src/http/v2/ngx_http_v2.c
index 49ea25ede..71da1e5b1 100644
--- a/src/http/v2/ngx_http_v2.c
+++ b/src/http/v2/ngx_http_v2.c
@@ -3898,15 +3898,16 @@ failed:
 ngx_int_t
 ngx_http_v2_read_request_body(ngx_http_request_t *r)
 {
-    off_t                      len;
-    size_t                     size;
-    ngx_buf_t                 *buf;
-    ngx_int_t                  rc;
-    ngx_http_v2_stream_t      *stream;
-    ngx_http_v2_srv_conf_t    *h2scf;
-    ngx_http_request_body_t   *rb;
-    ngx_http_core_loc_conf_t  *clcf;
-    ngx_http_v2_connection_t  *h2c;
+    off_t                       len;
+    size_t                      size;
+    ngx_buf_t                  *buf;
+    ngx_int_t                   rc;
+    ngx_http_v2_stream_t       *stream;
+    ngx_http_v2_srv_conf_t     *h2scf;
+    ngx_http_request_body_t    *rb;
+    ngx_http_core_loc_conf_t   *clcf;
+    ngx_http_v2_connection_t   *h2c;
+    ngx_http_core_main_conf_t  *cmcf;
 
     stream = r->stream;
     rb = r->request_body;
@@ -3921,7 +3922,9 @@ ngx_http_v2_read_request_body(ngx_http_request_t *r)
 
     /* set rb->filter_need_buffering */
 
-    rc = ngx_http_top_request_body_filter(r, NULL);
+    cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
+
+    rc = cmcf->top_request_body_filter(r, NULL);
 
     if (rc != NGX_OK) {
         stream->skip_data = 1;
@@ -4175,11 +4178,12 @@ ngx_http_v2_process_request_body(ngx_http_request_t *r, u_char *pos,
 static ngx_int_t
 ngx_http_v2_filter_request_body(ngx_http_request_t *r)
 {
-    ngx_buf_t                 *b, *buf;
-    ngx_int_t                  rc;
-    ngx_chain_t               *cl;
-    ngx_http_request_body_t   *rb;
-    ngx_http_core_loc_conf_t  *clcf;
+    ngx_buf_t                  *b, *buf;
+    ngx_int_t                   rc;
+    ngx_chain_t                *cl;
+    ngx_http_request_body_t    *rb;
+    ngx_http_core_loc_conf_t   *clcf;
+    ngx_http_core_main_conf_t  *cmcf;
 
     rb = r->request_body;
     buf = rb->buf;
@@ -4255,7 +4259,9 @@ ngx_http_v2_filter_request_body(ngx_http_request_t *r)
 
 update:
 
-    rc = ngx_http_top_request_body_filter(r, cl);
+    cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
+
+    rc = cmcf->top_request_body_filter(r, cl);
 
     ngx_chain_update_chains(r->pool, &rb->free, &rb->busy, &cl,
                             (ngx_buf_tag_t) &ngx_http_v2_filter_request_body);
diff --git a/src/http/v3/ngx_http_v3_request.c b/src/http/v3/ngx_http_v3_request.c
index 6865e1466..03461a73f 100644
--- a/src/http/v3/ngx_http_v3_request.c
+++ b/src/http/v3/ngx_http_v3_request.c
@@ -1494,18 +1494,19 @@ ngx_http_v3_do_read_client_request_body(ngx_http_request_t *r)
 static ngx_int_t
 ngx_http_v3_request_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
 {
-    off_t                      max;
-    size_t                     size;
-    u_char                    *p;
-    ngx_int_t                  rc;
-    ngx_buf_t                 *b;
-    ngx_uint_t                 last;
-    ngx_chain_t               *cl, *out, *tl, **ll;
-    ngx_http_v3_session_t     *h3c;
-    ngx_http_request_body_t   *rb;
-    ngx_http_core_loc_conf_t  *clcf;
-    ngx_http_core_srv_conf_t  *cscf;
-    ngx_http_v3_parse_data_t  *st;
+    off_t                       max;
+    size_t                      size;
+    u_char                     *p;
+    ngx_int_t                   rc;
+    ngx_buf_t                  *b;
+    ngx_uint_t                  last;
+    ngx_chain_t                *cl, *out, *tl, **ll;
+    ngx_http_v3_session_t      *h3c;
+    ngx_http_request_body_t    *rb;
+    ngx_http_core_loc_conf_t   *clcf;
+    ngx_http_core_srv_conf_t   *cscf;
+    ngx_http_v3_parse_data_t   *st;
+    ngx_http_core_main_conf_t  *cmcf;
 
     rb = r->request_body;
     st = &r->v3_parse->body;
@@ -1723,7 +1724,9 @@ done:
         rb->rest = (off_t) cscf->large_client_header_buffers.size;
     }
 
-    rc = ngx_http_top_request_body_filter(r, out);
+    cmcf = ngx_http_get_module_main_conf(r, ngx_http_core_module);
+
+    rc = cmcf->top_request_body_filter(r, out);
 
     ngx_chain_update_chains(r->pool, &rb->free, &rb->busy, &out,
                             (ngx_buf_tag_t) &ngx_http_read_client_request_body);
diff --git a/src/stream/ngx_stream.c b/src/stream/ngx_stream.c
index b6eeb23af..7c3b99ba6 100644
--- a/src/stream/ngx_stream.c
+++ b/src/stream/ngx_stream.c
@@ -257,6 +257,10 @@ ngx_stream_block(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
         }
     }
 
+    if (ngx_stream_init_filters(cf) != NGX_OK) {
+        return NGX_CONF_ERROR;
+    }
+
     if (ngx_stream_variables_init_vars(cf) != NGX_OK) {
         return NGX_CONF_ERROR;
     }
diff --git a/src/stream/ngx_stream.h b/src/stream/ngx_stream.h
index dc05dc5ba..62a7fc1ef 100644
--- a/src/stream/ngx_stream.h
+++ b/src/stream/ngx_stream.h
@@ -97,6 +97,8 @@ typedef ngx_int_t (*ngx_stream_phase_handler_pt)(ngx_stream_session_t *s,
     ngx_stream_phase_handler_t *ph);
 typedef ngx_int_t (*ngx_stream_handler_pt)(ngx_stream_session_t *s);
 typedef void (*ngx_stream_content_handler_pt)(ngx_stream_session_t *s);
+typedef ngx_int_t (*ngx_stream_filter_pt)(ngx_stream_session_t *s,
+    ngx_chain_t *chain, ngx_uint_t from_upstream);
 
 
 struct ngx_stream_phase_handler_s {
@@ -138,6 +140,8 @@ typedef struct {
     ngx_array_t                   *ports;
 
     ngx_stream_phase_t             phases[NGX_STREAM_LOG_PHASE + 1];
+
+    ngx_stream_filter_pt           top_filter;
 } ngx_stream_core_main_conf_t;
 
 
@@ -363,6 +367,8 @@ ngx_int_t ngx_stream_validate_host(ngx_str_t *host, ngx_pool_t *pool,
 ngx_int_t ngx_stream_find_virtual_server(ngx_stream_session_t *s,
     ngx_str_t *host, ngx_stream_core_srv_conf_t **cscfp);
 
+char *ngx_stream_init_filters(ngx_conf_t *cf);
+
 void ngx_stream_init_connection(ngx_connection_t *c);
 void ngx_stream_session_handler(ngx_event_t *rev);
 void ngx_stream_finalize_session(ngx_stream_session_t *s, ngx_uint_t rc);
@@ -373,10 +379,6 @@ extern ngx_uint_t    ngx_stream_max_module;
 extern ngx_module_t  ngx_stream_core_module;
 
 
-typedef ngx_int_t (*ngx_stream_filter_pt)(ngx_stream_session_t *s,
-    ngx_chain_t *chain, ngx_uint_t from_upstream);
-
-
 extern ngx_stream_filter_pt  ngx_stream_top_filter;
 
 
diff --git a/src/stream/ngx_stream_core_module.c b/src/stream/ngx_stream_core_module.c
index a09c7c634..9ba341131 100644
--- a/src/stream/ngx_stream_core_module.c
+++ b/src/stream/ngx_stream_core_module.c
@@ -1502,3 +1502,18 @@ ngx_stream_core_resolver(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
 
     return NGX_CONF_OK;
 }
+
+
+char *
+ngx_stream_init_filters(ngx_conf_t *cf)
+{
+    ngx_stream_core_main_conf_t  *cmcf;
+
+    cmcf = ngx_stream_conf_get_module_main_conf(cf, ngx_stream_core_module);
+
+    cmcf->top_filter = ngx_stream_top_filter;
+
+    ngx_stream_top_filter = NULL;
+
+    return NGX_CONF_OK;
+}
diff --git a/src/stream/ngx_stream_proxy_module.c b/src/stream/ngx_stream_proxy_module.c
index 300bdf681..2e5cc6ea3 100644
--- a/src/stream/ngx_stream_proxy_module.c
+++ b/src/stream/ngx_stream_proxy_module.c
@@ -1729,6 +1729,7 @@ ngx_stream_proxy_process(ngx_stream_session_t *s, ngx_uint_t from_upstream,
     ngx_log_handler_pt            handler;
     ngx_stream_upstream_t        *u;
     ngx_stream_proxy_srv_conf_t  *pscf;
+    ngx_stream_core_main_conf_t  *cmcf;
 
     u = s->upstream;
 
@@ -1777,6 +1778,8 @@ ngx_stream_proxy_process(ngx_stream_session_t *s, ngx_uint_t from_upstream,
         send_action = "proxying and sending to upstream";
     }
 
+    cmcf = ngx_stream_get_module_main_conf(s, ngx_stream_core_module);
+
     for ( ;; ) {
 
         if (do_write && dst) {
@@ -1784,7 +1787,7 @@ ngx_stream_proxy_process(ngx_stream_session_t *s, ngx_uint_t from_upstream,
             if (*out || *busy || dst->buffered) {
                 c->log->action = send_action;
 
-                rc = ngx_stream_top_filter(s, *out, from_upstream);
+                rc = cmcf->top_filter(s, *out, from_upstream);
 
                 if (rc == NGX_ERROR) {
                     ngx_stream_proxy_finalize(s, NGX_STREAM_OK);
diff --git a/src/stream/ngx_stream_return_module.c b/src/stream/ngx_stream_return_module.c
index 9301b025a..993d7a664 100644
--- a/src/stream/ngx_stream_return_module.c
+++ b/src/stream/ngx_stream_return_module.c
@@ -133,9 +133,10 @@ ngx_stream_return_handler(ngx_stream_session_t *s)
 static void
 ngx_stream_return_write_handler(ngx_event_t *ev)
 {
-    ngx_connection_t         *c;
-    ngx_stream_session_t     *s;
-    ngx_stream_return_ctx_t  *ctx;
+    ngx_connection_t             *c;
+    ngx_stream_session_t         *s;
+    ngx_stream_return_ctx_t      *ctx;
+    ngx_stream_core_main_conf_t  *cmcf;
 
     c = ev->data;
     s = c->data;
@@ -146,9 +147,11 @@ ngx_stream_return_write_handler(ngx_event_t *ev)
         return;
     }
 
+    cmcf = ngx_stream_get_module_main_conf(s, ngx_stream_core_module);
+
     ctx = ngx_stream_get_module_ctx(s, ngx_stream_return_module);
 
-    if (ngx_stream_top_filter(s, ctx->out, 1) == NGX_ERROR) {
+    if (cmcf->top_filter(s, ctx->out, 1) == NGX_ERROR) {
         ngx_stream_finalize_session(s, NGX_STREAM_INTERNAL_SERVER_ERROR);
         return;
     }