diff --git a/src/main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java b/src/main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java
index 4e484f5c5..9181248bb 100644
--- a/src/main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java
+++ b/src/main/java/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapper.java
@@ -25,7 +25,8 @@ public class ClickHouseDataTypeMapper {
         dataTypesMap.put(new MutablePair(Schema.INT16_SCHEMA.type(), null), ClickHouseDataType.Int16);
         dataTypesMap.put(new MutablePair(Schema.INT8_SCHEMA.type(), null), ClickHouseDataType.Int8);
         dataTypesMap.put(new MutablePair(Schema.INT32_SCHEMA.type(), null), ClickHouseDataType.Int32);
-        dataTypesMap.put(new MutablePair(Schema.INT64_SCHEMA.type(), null), ClickHouseDataType.Int64);
+        
+        dataTypesMap.put(new MutablePair(Schema.INT64_SCHEMA.type(), null), ClickHouseDataType.Int256);
 
         // Float
          dataTypesMap.put(new MutablePair(Schema.FLOAT32_SCHEMA.type(), null), ClickHouseDataType.Float32);
diff --git a/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java b/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java
index 464b58cd7..69d9298fa 100644
--- a/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java
+++ b/src/test/com/altinity/clickhouse/sink/connector/converters/ClickHouseDataTypeMapperTest.java
@@ -26,6 +26,9 @@ public void getClickHouseDataType() {
         chDataType = ClickHouseDataTypeMapper.getClickHouseDataType(Schema.INT32_SCHEMA.type(), Date.SCHEMA_NAME);
         Assert.assertTrue(chDataType.name().equalsIgnoreCase("Date32"));
 
+        chDataType = ClickHouseDataTypeMapper.getClickHouseDataType(Schema.INT64_SCHEMA.type(), null);
+        Assert.assertTrue(chDataType.name().equalsIgnoreCase("INT256"));
+
 
     }
 }