diff --git a/gstlal-burst/bin/gstlal_ll_feature_extractor_pipe b/gstlal-burst/bin/gstlal_ll_feature_extractor_pipe
index f625c287f73e4d86c6bd31bc58b81f10b5174a73..c174148eb3383768084dcb2d59bd3ac32e02a4c0 100755
--- a/gstlal-burst/bin/gstlal_ll_feature_extractor_pipe
+++ b/gstlal-burst/bin/gstlal_ll_feature_extractor_pipe
@@ -422,7 +422,7 @@ if options.save_format == 'kafka':
 	all_fx_jobs = [(str(ii).zfill(4), channel_subset) for ii, channel_subset in enumerate(data_source_info.channel_subsets)]
 	for job_subset in groups(all_fx_jobs, options.num_agg_jobs):
 		jobs, channels = zip(*job_subset)
-		job_channel_options = {"jobs": jobs, "num-channels": len(channels)}
+		job_channel_options = {"jobs": jobs}
 		job_channel_options.update(aggregator_options)
 		agg_node = dagparts.DAGNode(aggregator_job, dag, [], opts = job_channel_options, output_files = {"rootdir": os.path.join(options.out_path, "aggregator")})