We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 07614b0 commit e37817fCopy full SHA for e37817f
spec/protocol/message_spec.rb
@@ -0,0 +1,16 @@
1
+describe Kafka::Protocol::Message do
2
+ it "encodes and decodes messages" do
3
+ message = Kafka::Protocol::Message.new(
4
+ value: "yolo",
5
+ key: "xx",
6
+ )
7
+
8
+ io = StringIO.new
9
+ encoder = Kafka::Protocol::Encoder.new(io)
10
+ message.encode(encoder)
11
+ data = StringIO.new(io.string)
12
+ decoder = Kafka::Protocol::Decoder.new(data)
13
14
+ expect(Kafka::Protocol::Message.decode(decoder)).to eq message
15
+ end
16
+end
0 commit comments