diff --git a/Network/Fluent/Conduit.hs b/Network/Fluent/Conduit.hs
--- a/Network/Fluent/Conduit.hs
+++ b/Network/Fluent/Conduit.hs
@@ -24,14 +24,14 @@
 import Network.Fluent.Logger ( FluentSettings, FluentLogger, newFluentLogger, closeFluentLogger, post )
 import Control.Monad.IO.Class ( liftIO )
 import Data.ByteString ( ByteString )
-import Data.Conduit ( MonadResource, GInfSink, bracketP, awaitForever )
+import Data.Conduit ( MonadResource, bracketP, awaitForever, Consumer )
 import Data.MessagePack ( Packable )
 
 -- | Stream all incoming pair ( label, data ) to the given Fluent.
 --
--- Since 0.1.0.0
+-- Since 0.2.0.0
 --
-sinkFluent :: (MonadResource m, Packable a) => FluentSettings -> GInfSink (ByteString, a) m
+sinkFluent :: (MonadResource m, Packable a) => FluentSettings -> Consumer (ByteString, a) m ()
 sinkFluent set = bracketP
                  (newFluentLogger set)
                  (liftIO . closeFluentLogger)
@@ -39,7 +39,7 @@
 
 -- | Stream all incoming pair ( label, data ) to the given Fluent logger.
 --
--- Since 0.1.0.0
+-- Since 0.2.0.0
 --
-sinkFluentWithLogger :: (MonadResource m, Packable a) => FluentLogger -> GInfSink (ByteString, a) m
+sinkFluentWithLogger :: (MonadResource m, Packable a) => FluentLogger -> Consumer (ByteString, a) m ()
 sinkFluentWithLogger logger = awaitForever $ liftIO . uncurry (post logger)
diff --git a/fluent-logger-conduit.cabal b/fluent-logger-conduit.cabal
--- a/fluent-logger-conduit.cabal
+++ b/fluent-logger-conduit.cabal
@@ -1,5 +1,5 @@
 name:                fluent-logger-conduit
-version:             0.1.0.0
+version:             0.2.0.0
 synopsis:            Conduit interface for fluent-logger
 description:         Conduit interface for fluent-logger
 license:             OtherLicense
@@ -21,6 +21,6 @@
   build-depends:       base ==4.*
                      , bytestring
                      , fluent-logger >=0.1 && <0.2
-                     , conduit >=0.5 && <0.6
+                     , conduit >= 1.0 && <1.1
                      , transformers >=0.2
                      , msgpack >=0.7.1 && <0.8