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 caf0730 commit 817bc96Copy full SHA for 817bc96
src/Kafka/Producer.hs
@@ -117,7 +117,8 @@ newProducer pps = liftIO $ do
117
tc <- topicConf (TopicProps $ (ppTopicProps pps))
118
119
-- add default delivery report callback
120
- let Callback setCb = deliveryCallback (const mempty) in setCb kc
+ let Callback setDeliveryCallback = deliveryCallback (const mempty)
121
+ setDeliveryCallback kc
122
123
-- set callbacks
124
forM_ (ppCallbacks pps) (\(Callback setCb) -> setCb kc)
0 commit comments