diff --git a/src/analytics/kafka_processor.cc b/src/analytics/kafka_processor.cc
index 32d637e036e..3ef0cb0fe2f 100644
--- a/src/analytics/kafka_processor.cc
+++ b/src/analytics/kafka_processor.cc
@@ -536,7 +536,9 @@ KafkaProcessor::StartKafka(void) {
         ss << it->first;
         aggs.insert(make_pair(ss.str(),
                 new UVEAggregator(it->first, it->second,
-                        boost::bind(&RdKafka::KafkaConsumer::commitSync,
+                        boost::bind(static_cast<
+                            RdKafka::ErrorCode (RdKafka::KafkaConsumer::*)(RdKafka::Message*)>
+                            (&RdKafka::KafkaConsumer::commitSync),
                                     consumer, _1),
                         SandeshUVETypeMaps::kProxyPartitions)));
     }
diff --git a/src/analytics/uve_aggregator.h b/src/analytics/uve_aggregator.h
index 517d0b65fa2..509c75652ac 100644
--- a/src/analytics/uve_aggregator.h
+++ b/src/analytics/uve_aggregator.h
@@ -25,7 +25,7 @@ class UVEAggregator {
 public:
     static const uint64_t kCommitPeriod_us = 3600000000;
 
-    typedef boost::function<int32_t (RdKafka::Message *message)> commitCb;
+    typedef boost::function<RdKafka::ErrorCode (RdKafka::Message *message)> commitCb;
     UVEAggregator(const std::string& proxy, const std::string& conf,
             commitCb commit_cb, uint64_t partitions):
             topic_(proxy),