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

@@ -18,6 +18,7 @@ import qualified Kafka.Internal as Kafka
 import qualified Kafka.Metadata
 import qualified Kafka.Stats as Stats
 import qualified Kafka.Worker.Analytics as Analytics
+import qualified Kafka.Consumer.AssignmentStrategy as AssignmentStrategy
 import qualified Kafka.Worker.Fetcher as Fetcher
 import qualified Kafka.Worker.Partition as Partition
 import qualified Kafka.Worker.Settings as Settings
@@ -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")
                   ]
               )
             ++ case maybeStatsCallback of