File tree Expand file tree Collapse file tree 1 file changed +0
-4
lines changed Expand file tree Collapse file tree 1 file changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -78,8 +78,6 @@ def decode(data)
7878 end
7979
8080 it "sets offsets correctly for compressed messages with relative offsets" do
81- compressor = Kafka ::Compressor . new ( codec_name : :snappy , threshold : 1 , instrumenter : instrumenter )
82-
8381 message1 = Kafka ::Protocol ::Message . new ( value : "hello1" , offset : 0 )
8482 message2 = Kafka ::Protocol ::Message . new ( value : "hello2" , offset : 1 )
8583 message3 = Kafka ::Protocol ::Message . new ( value : "hello3" , offset : 2 )
@@ -102,8 +100,6 @@ def decode(data)
102100 end
103101
104102 it "keeps the predefined offsets for messages delivered in 0.9 format" do
105- compressor = Kafka ::Compressor . new ( codec_name : :snappy , threshold : 1 , instrumenter : instrumenter )
106-
107103 message1 = Kafka ::Protocol ::Message . new ( value : "hello1" , offset : 997 )
108104 message2 = Kafka ::Protocol ::Message . new ( value : "hello2" , offset : 999 )
109105 message3 = Kafka ::Protocol ::Message . new ( value : "hello3" , offset : 1000 )
You can’t perform that action at this time.
0 commit comments