Skip to content

Commit e76d1d5

Browse files
committed
--wip-- [skip ci]
1 parent 95960ef commit e76d1d5

File tree

1 file changed

+18
-6
lines changed

1 file changed

+18
-6
lines changed

src/Kafka/Admin.hs

Lines changed: 18 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,26 @@
11
module Kafka.Admin where
22

33

4-
import Control.Monad
54
import Control.Monad.IO.Class
65

6+
import Kafka.Internal.RdKafka
7+
import Kafka.Internal.Setup
8+
79
import Kafka.Types
10+
import Kafka.Admin.AdminProperties
11+
12+
data KAdmin = KAdmin {
13+
adminKafka :: !Kafka
14+
, adminKafkaConfig :: !KafkaConf
15+
}
816

9-
{-
10-
-newKAdmin :: MonadIO m
17+
newKAdmin :: MonadIO m
1118
=> AdminProperties
12-
-> m (Either KafkaError KafkaAdmin)
13-
-
14-
- -}
19+
-> m (Either KafkaError KAdmin)
20+
newKAdmin properties = liftIO $ do
21+
kafkaConfig@(KafkaConf kafkaConf' _ _) <- kafkaConf ( KafkaProps $ adminProps properties)
22+
maybeKafka <- newRdKafkaT RdKafkaProducer kafkaConf'
23+
case maybeKafka of
24+
Left err -> pure $ Left $ KafkaError err
25+
Right kafka -> pure $ Right $ KAdmin (Kafka kafka) kafkaConfig
26+

0 commit comments

Comments
 (0)