Sha256: f388bea1ca10a12f9bda2706140ac1dc3061f5aa955fc9781de0ff7e73069ebb

Contents?: true

Size: 235 Bytes

Versions: 19

Compression:

Stored size: 235 Bytes

Contents

# frozen_string_literal: true

module Sbmt
  module KafkaConsumer
    module Serialization
      class NullDeserializer < BaseDeserializer
        def call(message)
          message.raw_payload
        end
      end
    end
  end
end

Version data entries

19 entries across 19 versions & 1 rubygems

Version Path
sbmt-kafka_consumer-3.3.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-3.2.2 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-3.2.1 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-3.2.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-3.1.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.8.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-3.0.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.7.1 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.7.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.6.1 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.6.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.5.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.4.1 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.4.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.3.1 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.3.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.2.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.1.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb
sbmt-kafka_consumer-2.0.0 lib/sbmt/kafka_consumer/serialization/null_deserializer.rb