Add frozen_string_literal comment to all files

Author: tjwp

Gemfile

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 source "https://rubygems.org"
 
 gemspec

Rakefile

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "bundler/gem_tasks"
 require "rspec/core/rake_task"
 

benchmarks/message_encoding.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka"
 
 ready "message serialization" do

bin/console

@@ -1,4 +1,5 @@
 #!/usr/bin/env ruby
+# frozen_string_literal: true
 
 require "bundler/setup"
 require "kafka"

examples/consumer-group.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 $LOAD_PATH.unshift(File.expand_path("../../lib", __FILE__))
 
 require "kafka"

examples/firehose-consumer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 $LOAD_PATH.unshift(File.expand_path("../../lib", __FILE__))
 
 require "kafka"

examples/firehose-producer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 $LOAD_PATH.unshift(File.expand_path("../../lib", __FILE__))
 
 require "kafka"

examples/simple-consumer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 # Consumes lines from a Kafka partition and writes them to STDOUT.
 #
 # You need to define the environment variable KAFKA_BROKERS for this

examples/simple-producer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 # Reads lines from STDIN, writing them to Kafka.
 #
 # You need to define the environment variable KAFKA_BROKERS for this

examples/ssl-producer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 # Reads lines from STDIN, writing them to Kafka.
 
 $LOAD_PATH.unshift(File.expand_path("../../lib", __FILE__))

lib/kafka.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/version"
 
 module Kafka

lib/kafka/async_producer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "thread"
 
 module Kafka

lib/kafka/broker.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "logger"
 require "kafka/connection"
 require "kafka/protocol"

lib/kafka/broker_pool.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/broker"
 
 module Kafka

lib/kafka/broker_uri.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "uri"
 
 module Kafka

lib/kafka/client.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/ssl_context"
 require "kafka/cluster"
 require "kafka/producer"

lib/kafka/cluster.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/broker_pool"
 require "set"
 

lib/kafka/compression.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/snappy_codec"
 require "kafka/gzip_codec"
 require "kafka/lz4_codec"

lib/kafka/compressor.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/compression"
 
 module Kafka

lib/kafka/connection.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "stringio"
 require "kafka/socket_with_timeout"
 require "kafka/ssl_socket_with_timeout"

lib/kafka/connection_builder.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   class ConnectionBuilder
     def initialize(client_id:, logger:, instrumenter:, connect_timeout:, socket_timeout:, ssl_context:, sasl_authenticator:)

lib/kafka/consumer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/consumer_group"
 require "kafka/offset_manager"
 require "kafka/fetcher"

lib/kafka/consumer_group.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "set"
 require "kafka/round_robin_assignment_strategy"
 

lib/kafka/datadog.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 begin
   require "datadog/statsd"
 rescue LoadError

lib/kafka/fetch_operation.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/fetched_batch"
 
 module Kafka

lib/kafka/fetched_batch.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
 
   # An ordered sequence of messages fetched from a Kafka partition.

lib/kafka/fetched_message.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   class FetchedMessage
     # @return [String] the name of the topic that the message was written to.

lib/kafka/fetcher.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/fetch_operation"
 
 module Kafka

lib/kafka/gzip_codec.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   class GzipCodec
     def codec_id

lib/kafka/heartbeat.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   class Heartbeat
     def initialize(group:, interval:)

lib/kafka/instrumenter.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   class Instrumenter
     NAMESPACE = "kafka"

lib/kafka/lz4_codec.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   class LZ4Codec
     def codec_id

lib/kafka/message_buffer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/protocol/message"
 
 module Kafka

lib/kafka/offset_manager.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
 
   # Manages a consumer's position in partitions, figures out where to resume processing

lib/kafka/partitioner.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "zlib"
 
 module Kafka

lib/kafka/pause.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   # Manages the pause state of a partition.
   #

lib/kafka/pending_message.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   class PendingMessage
     attr_reader :value, :key, :topic, :partition, :partition_key, :create_time, :bytesize

lib/kafka/pending_message_queue.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
 
   class PendingMessageQueue

lib/kafka/produce_operation.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/protocol/message_set"
 
 module Kafka

lib/kafka/producer.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "set"
 require "kafka/partitioner"
 require "kafka/message_buffer"

lib/kafka/protocol.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
 
   # The protocol layer of the library.

lib/kafka/protocol/alter_configs_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/alter_configs_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class AlterConfigsResponse

lib/kafka/protocol/api_versions_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/api_versions_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/consumer_group_protocol.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class ConsumerGroupProtocol

lib/kafka/protocol/create_partitions_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/create_partitions_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/create_topics_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/create_topics_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/decoder.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/delete_topics_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/delete_topics_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/describe_configs_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/describe_configs_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class DescribeConfigsResponse

lib/kafka/protocol/encoder.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "stringio"
 
 module Kafka

lib/kafka/protocol/fetch_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
 

lib/kafka/protocol/fetch_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/protocol/message_set"
 
 module Kafka

lib/kafka/protocol/group_coordinator_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class GroupCoordinatorRequest

lib/kafka/protocol/group_coordinator_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class GroupCoordinatorResponse

lib/kafka/protocol/heartbeat_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class HeartbeatRequest

lib/kafka/protocol/heartbeat_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class HeartbeatResponse

lib/kafka/protocol/join_group_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 require "kafka/protocol/consumer_group_protocol"
 
 module Kafka

lib/kafka/protocol/join_group_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class JoinGroupResponse

lib/kafka/protocol/leave_group_request.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class LeaveGroupRequest

lib/kafka/protocol/leave_group_response.rb

@@ -1,3 +1,5 @@
+# frozen_string_literal: true
+
 module Kafka
   module Protocol
     class LeaveGroupResponse