diff --git a/lib/fluent/plugin/in_dynamodb_streams.rb b/lib/fluent/plugin/in_dynamodb_streams.rb
index a2f7ccf..f32ced2 100644
--- a/lib/fluent/plugin/in_dynamodb_streams.rb
+++ b/lib/fluent/plugin/in_dynamodb_streams.rb
@@ -1,3 +1,5 @@
+require 'fluent/input'
+
 module Fluent
   class DynamoDBStreamsInput < Input
     Fluent::Plugin.register_input('dynamodb_streams', self)