diff --git a/extensions/splunk/PutSplunkHTTP.h b/extensions/splunk/PutSplunkHTTP.h
index 7e8f0af4527..9e8360cd20b 100644
--- a/extensions/splunk/PutSplunkHTTP.h
+++ b/extensions/splunk/PutSplunkHTTP.h
@@ -48,6 +48,10 @@ class PutSplunkHTTP final : public SplunkHECProcessor {
   void onTrigger(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSession> &session) override;
   void initialize() override;
   void onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory> &sessionFactory) override;
+
+  bool isSingleThreaded() const override {
+    return false;
+  }
 };
 
 }  // namespace org::apache::nifi::minifi::extensions::splunk
diff --git a/extensions/splunk/QuerySplunkIndexingStatus.h b/extensions/splunk/QuerySplunkIndexingStatus.h
index a00c4d1ee89..7c9b3af1aa1 100644
--- a/extensions/splunk/QuerySplunkIndexingStatus.h
+++ b/extensions/splunk/QuerySplunkIndexingStatus.h
@@ -49,6 +49,10 @@ class QuerySplunkIndexingStatus final : public SplunkHECProcessor {
   void initialize() override;
   void onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory> &sessionFactory) override;
 
+  bool isSingleThreaded() const override {
+    return true;
+  }
+
  protected:
   uint32_t batch_size_ = 1000;
   std::chrono::milliseconds max_age_ = std::chrono::hours(1);
diff --git a/extensions/splunk/SplunkHECProcessor.h b/extensions/splunk/SplunkHECProcessor.h
index a6694e5aa4d..89c14f5c50c 100644
--- a/extensions/splunk/SplunkHECProcessor.h
+++ b/extensions/splunk/SplunkHECProcessor.h
@@ -44,10 +44,6 @@ class SplunkHECProcessor : public core::Processor {
   void initialize() override;
   void onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory> &sessionFactory) override;
 
-  bool isSingleThreaded() const override {
-    return true;
-  }
-
   core::annotation::Input getInputRequirement() const override {
     return core::annotation::Input::INPUT_REQUIRED;
   }