Misc fixes

kafkaex · Dec 10, 2017 · ceb6917 · ceb6917
1 parent 9b44a37
commit ceb6917
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/lib/kafka_ex/server.ex b/lib/kafka_ex/server.ex
@@ -474,7 +474,7 @@ defmodule KafkaEx.Server do
           request.topic,
           request.partition
         )
-    
+
         case broker do
           nil ->
             Logger.error(fn ->
@@ -485,16 +485,16 @@ defmodule KafkaEx.Server do
             wire_request = request
             |> client_request(updated_state)
             |> module.create_request
-    
+
             response = broker
             |> NetworkClient.send_sync_request(
               wire_request,
               config_sync_timeout()
             )
             |> module.parse_response
-    
+
             state_out = State.increment_correlation_id(updated_state)
-    
+
             {response, state_out}
         end
       end

diff --git a/scripts/ci_tests.sh b/scripts/ci_tests.sh
@@ -25,5 +25,5 @@ then
   echo "First tests passed, skipping repeat"
 else
   echo "Repeating tests"
-  mix "$TEST_COMMAND" --include integration --include consumer_group --include server_0_p_9_p_0 
+  mix "$TEST_COMMAND" --include integration --include consumer_group --include server_0_p_9_p_0 --include server_0_p_8_p_0
 fi
diff --git a/test/integration/server0_p_8_p_0_test.exs b/test/integration/server0_p_8_p_0_test.exs
@@ -1,4 +1,4 @@
-defmodule KafkaEx.Server0P9P0.Test do
+defmodule KafkaEx.Server0P8P0.Test do
   use ExUnit.Case
   import TestHelper