packages feed

hw-kafka-client 4.0.1 → 4.0.2

raw patch · 3 files changed

+6/−5 lines, 3 filesPVP: major bump suggested

API removals or changes: PVP suggests a major version bump

API changes (from Hackage documentation)

+ Kafka.Consumer: RdKafkaRespErrElectionNotNeeded :: RdKafkaRespErrT
+ Kafka.Consumer: RdKafkaRespErrEligibleLeadersNotAvailable :: RdKafkaRespErrT
+ Kafka.Consumer: RdKafkaRespErrGroupSubscribedToTopic :: RdKafkaRespErrT
+ Kafka.Consumer: RdKafkaRespErrInvalidRecord :: RdKafkaRespErrT
+ Kafka.Consumer: RdKafkaRespErrNoReassignmentInProgress :: RdKafkaRespErrT
+ Kafka.Consumer: RdKafkaRespErrUnstableOffsetCommit :: RdKafkaRespErrT
+ Kafka.Producer: RdKafkaRespErrElectionNotNeeded :: RdKafkaRespErrT
+ Kafka.Producer: RdKafkaRespErrEligibleLeadersNotAvailable :: RdKafkaRespErrT
+ Kafka.Producer: RdKafkaRespErrGroupSubscribedToTopic :: RdKafkaRespErrT
+ Kafka.Producer: RdKafkaRespErrInvalidRecord :: RdKafkaRespErrT
+ Kafka.Producer: RdKafkaRespErrNoReassignmentInProgress :: RdKafkaRespErrT
+ Kafka.Producer: RdKafkaRespErrUnstableOffsetCommit :: RdKafkaRespErrT
- Kafka.Producer: deliveryCallback :: (DeliveryReport -> IO ()) -> KafkaConf -> IO ()
+ Kafka.Producer: deliveryCallback :: (DeliveryReport -> IO ()) -> Callback
- Kafka.Producer.ProducerProperties: deliveryCallback :: (DeliveryReport -> IO ()) -> KafkaConf -> IO ()
+ Kafka.Producer.ProducerProperties: deliveryCallback :: (DeliveryReport -> IO ()) -> Callback

Files

hw-kafka-client.cabal view
@@ -1,7 +1,7 @@ cabal-version: 2.2  name:                   hw-kafka-client-version:                4.0.1+version:                4.0.2 synopsis:               Kafka bindings for Haskell description:            Apache Kafka bindings backed by the librdkafka C library.                         .
src/Kafka/Producer.hs view
@@ -117,7 +117,8 @@   tc <- topicConf (TopicProps $ (ppTopicProps pps))    -- add default delivery report callback-  deliveryCallback (const mempty) kc+  let Callback setDeliveryCallback = deliveryCallback (const mempty)+  setDeliveryCallback kc    -- set callbacks   forM_ (ppCallbacks pps) (\(Callback setCb) -> setCb kc)
src/Kafka/Producer/Callbacks.hs view
@@ -15,7 +15,7 @@ import           Kafka.Callbacks        as X import           Kafka.Consumer.Types   (Offset(..)) import           Kafka.Internal.RdKafka (RdKafkaMessageT(..), RdKafkaRespErrT(..), rdKafkaConfSetDrMsgCb)-import           Kafka.Internal.Setup   (KafkaConf(..), getRdKafkaConf)+import           Kafka.Internal.Setup   (KafkaConf(..), getRdKafkaConf, Callback(..)) import           Kafka.Internal.Shared  (kafkaRespErr, readTopic, readKey, readPayload) import           Kafka.Producer.Types   (ProducerRecord(..), DeliveryReport(..), ProducePartition(..)) import           Kafka.Types            (KafkaError(..), TopicName(..))@@ -27,8 +27,8 @@ --   callbacks. For callbacks to individual messsages see --   'Kafka.Producer.produceMessage\''./ ---deliveryCallback :: (DeliveryReport -> IO ()) -> KafkaConf -> IO ()-deliveryCallback callback kc = rdKafkaConfSetDrMsgCb (getRdKafkaConf kc) realCb+deliveryCallback :: (DeliveryReport -> IO ()) -> Callback+deliveryCallback callback = Callback $ \kc -> rdKafkaConfSetDrMsgCb (getRdKafkaConf kc) realCb   where     realCb :: t -> Ptr RdKafkaMessageT -> IO ()     realCb _ mptr =