diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/convert/ColumnReader.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/convert/ColumnReader.java
index 67371c072..512eba128 100644
--- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/convert/ColumnReader.java
+++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/convert/ColumnReader.java
@@ -67,9 +67,12 @@ public class ColumnReader {
 		if (type.equals(DataType.text()) || type.equals(DataType.ascii()) || type.equals(DataType.varchar())) {
 			return row.getString(i);
 		}
-		if (type.equals(DataType.cint()) || type.equals(DataType.varint())) {
+		if (type.equals(DataType.cint())) {
 			return new Integer(row.getInt(i));
 		}
+		if (type.equals(DataType.varint())) {
+			return row.getVarint(i);
+		}
 		if (type.equals(DataType.cdouble())) {
 			return new Double(row.getDouble(i));
 		}