Use the type we created instead of extraprops

Extra props doesn't set things up correctly to use incremental_assign
and friends.

Author: omnibs

nri-kafka/src/Kafka/Worker/Internal.hs

@@ -14,6 +14,7 @@ import qualified Data.UUID.V4
 import qualified Dict
 import qualified GHC.Clock
 import qualified Kafka.Consumer as Consumer
+import qualified Kafka.Consumer.AssignmentStrategy as AssignmentStrategy
 import qualified Kafka.Internal as Kafka
 import qualified Kafka.Metadata
 import qualified Kafka.Stats as Stats
@@ -268,10 +269,10 @@ createConsumer
             ++ Consumer.logLevel logLevel
             ++ Consumer.setCallback (Consumer.rebalanceCallback rebalance)
             ++ Consumer.compression Consumer.Snappy
+            ++ Consumer.setAssignmentStrategy AssignmentStrategy.CooperativeSticky
             ++ Consumer.extraProps
               ( Dict.fromList
-                  [ ("max.poll.interval.ms", Text.fromInt (Settings.unMaxPollIntervalMs maxPollIntervalMs)),
-                    ("partition.assignment.strategy", "cooperative-sticky")
+                  [ ("max.poll.interval.ms", Text.fromInt (Settings.unMaxPollIntervalMs maxPollIntervalMs))
                   ]
               )
             ++ case maybeStatsCallback of