lib/fluent/plugin/in_cloudwatch_logs.rb in fluent-plugin-cloudwatch-logs-0.2.0 vs lib/fluent/plugin/in_cloudwatch_logs.rb in fluent-plugin-cloudwatch-logs-0.2.1

@@ -109,10 +109,10 @@
         log_group_name: @log_group_name,
         log_stream_name: log_stream_name
       }
       request[:next_token] = next_token if next_token
       response = @logs.get_log_events(request)
-      store_next_token(response.next_forward_token)
+      store_next_token(response.next_forward_token, log_stream_name)
 
       response.events
     end
 
     def describe_log_streams(log_streams = nil, next_token = nil)