fraud_detection.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [],
   "source": [
    "from kafka import KafkaConsumer\n",
    "from kafka import TopicPartition\n",
    "from datetime import datetime\n",
    "import pandas as pd\n",
    "from cassandra.cluster import Cluster\n",
    "import json\n",
    "from botocore.vendored import requests\n",
    "import findspark\n",
    "findspark.init()\n",
    "import pyspark.sql \n",
    "from pyspark.context import SparkContext\n",
    "from pyspark.sql.session import SparkSession\n",
    "from pyspark.ml.classification import LogisticRegression\n",
    "from pyspark.ml.feature import HashingTF, Tokenizer\n",
    "from pyspark.ml import Pipeline, PipelineModel\n",
    "from pyspark.sql import SQLContext\n",
    "from pyspark.sql import SparkSession\n",
    "from pyspark.ml import Pipeline, PipelineModel\n",
    "from pyspark.ml.feature import OneHotEncoder, StringIndexer, VectorAssembler\n",
    "from pyspark.ml.classification import LogisticRegression\n",
    "import pandas as pd\n",
    "import time\n",
    "from cassandra.cluster import Cluster\n",
    "import numpy as np\n",
    "from pyspark.sql.types import *"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 2,
   "metadata": {},
   "outputs": [],
   "source": [
    "# #------------------------------- SPARK CONTEXT -------------------------------\n",
    "sc = SparkContext('local')\n",
    "spark = SparkSession(sc)\n",
    "spark = SparkSession.builder.appName('CC_Fraud').getOrCreate()\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 3,
   "metadata": {},
   "outputs": [],
   "source": [
    "def MachineLearningModelLoading():\n",
    "\tpath = r\"C:\\Users\\saritajoshi\\Documents\\Repos\\Credit-Card-Fraud-Detection-Spark\\model\"\n",
    "\tnewmodel = PipelineModel.load(path)\n",
    "\treturn newmodel\n",
    "\t\n",
    "newmodel = MachineLearningModelLoading()\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": 4,
   "metadata": {},
   "outputs": [],
   "source": [
    "# feature_columns = [col for col in df.columns if col != \"is_fraud\"]\n",
    "# assembler = VectorAssembler(inputCols=feature_columns, outputCol=\"features\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 5,
   "metadata": {},
   "outputs": [],
   "source": [
    "def predicting_status(data_all,newmodel):\n",
    "\tselect_cols = ['amt', 'lat', 'long', 'city_pop', 'unix_time','merch_lat', 'merch_long','merchant_label','category_label', 'gender_label', 'job_label'] #all numeric\n",
    "\tdata = data_all.select(select_cols)\n",
    "\tpred1 = newmodel.transform(data)\n",
    "\treturn pred1.select(\"prediction\")\n",
    "\n",
    "# df = spark.read.json(sc.parallelize([dd]))\n",
    "# res = predicting_status(df, newmodel)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 6,
   "metadata": {},
   "outputs": [],
   "source": [
    "cluster = Cluster()\n",
    "session = cluster.connect()\n",
    "\n",
    "session.execute(\"CREATE KEYSPACE IF NOT EXISTS bigdata WITH replication = {'class':'SimpleStrategy', 'replication_factor' : 3}\")\n",
    "session.set_keyspace(\"bigdata\")\n",
    "\n",
    "#session.execute(\"DROP TABLE testing\")\n",
    "# session.execute(\"CREATE TABLE IF NOT EXISTS testing (txn_id varchar PRIMARY KEY,cc_no bigint ,txn_time varchar, year smallint, month smallint, day smallint, hour smallint, minute smallint,amount double, cc_provider int, merchant varchar,merchant_index smallint, country_name varchar, country_code varchar,country_index smallint, age int, marital_status varchar,marital_status_index smallint,gender varchar,gender_index smallint,loan varchar,loan_index smallint, status varchar,status_index smallint)\")\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 7,
   "metadata": {},
   "outputs": [],
   "source": [
    "topic_name = 'transaction_data'\n",
    "keyspace = 'bigdata'\n",
    "table = 'transaction_data'"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 8,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2726, timestamp=1715387551529, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-06 22:09:51\", \"cc_num\": 4451438912406400, \"merchant\": \"fraud_Hirthe-Beier\", \"category\": \"health_fitness\", \"amt\": 85.81, \"first\": \"Cheryl\", \"last\": \"Morgan\", \"gender\": \"F\", \"street\": \"7535 Amanda Manors Suite 293\", \"city\": \"Norman\", \"state\": \"AR\", \"zip\": 71960, \"lat\": 34.4596, \"long\": -93.6743, \"city_pop\": 1383, \"job\": \"Manufacturing engineer\", \"dob\": \"1999-09-11\", \"trans_num\": \"ee533fe651486dd4f7e1e1097b4d7bb9\", \"unix_time\": 1386367791, \"merch_lat\": 34.770419, \"merch_long\": -93.430473, \"is_fraud\": 0, \"merchant_label\": 260, \"category_label\": 5, \"gender_label\": 0, \"job_label\": 283}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2727, timestamp=1715387551530, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-15 22:18:40\", \"cc_num\": 676102124465, \"merchant\": \"fraud_Price Inc\", \"category\": \"shopping_net\", \"amt\": 2.12, \"first\": \"Natasha\", \"last\": \"Mclaughlin\", \"gender\": \"F\", \"street\": \"8699 Lindsay Ford Apt. 486\", \"city\": \"Napa\", \"state\": \"CA\", \"zip\": 94558, \"lat\": 38.4549, \"long\": -122.2564, \"city_pop\": 94014, \"job\": \"Airline pilot\", \"dob\": \"1985-08-21\", \"trans_num\": \"84ff4aaf80a8be3a1091918916c861b4\", \"unix_time\": 1355609920, \"merch_lat\": 38.516014, \"merch_long\": -121.454026, \"is_fraud\": 0, \"merchant_label\": 487, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 21}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=606, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2728, timestamp=1715387551533, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-07 02:03:33\", \"cc_num\": 3583093681934489, \"merchant\": \"fraud_Mohr-Bayer\", \"category\": \"shopping_net\", \"amt\": 28.74, \"first\": \"Hannah\", \"last\": \"Knight\", \"gender\": \"F\", \"street\": \"0900 Beverly Landing\", \"city\": \"Louisville\", \"state\": \"KY\", \"zip\": 40209, \"lat\": 38.1901, \"long\": -85.7519, \"city_pop\": 736284, \"job\": \"Education officer, museum\", \"dob\": \"1961-09-13\", \"trans_num\": \"b033bf85db686c0e2cd79a06406a48f9\", \"unix_time\": 1341626613, \"merch_lat\": 38.718779, \"merch_long\": -86.132571, \"is_fraud\": 0, \"merchant_label\": 430, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 145}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=619, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2729, timestamp=1715387551534, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-22 16:45:54\", \"cc_num\": 342351256941125, \"merchant\": \"fraud_Ledner, Hartmann and Feest\", \"category\": \"health_fitness\", \"amt\": 167.96, \"first\": \"Rebecca\", \"last\": \"Obrien\", \"gender\": \"F\", \"street\": \"5619 Mendoza Inlet\", \"city\": \"Juliette\", \"state\": \"GA\", \"zip\": 31046, \"lat\": 33.1194, \"long\": -83.8235, \"city_pop\": 3343, \"job\": \"Theatre manager\", \"dob\": \"1990-06-08\", \"trans_num\": \"0795b336608f69f03252554dbf71aa41\", \"unix_time\": 1358873154, \"merch_lat\": 33.899817, \"merch_long\": -84.606492, \"is_fraud\": 0, \"merchant_label\": 380, \"category_label\": 5, \"gender_label\": 0, \"job_label\": 466}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2730, timestamp=1715387551535, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-28 22:26:27\", \"cc_num\": 4862293128558, \"merchant\": \"fraud_Beier LLC\", \"category\": \"entertainment\", \"amt\": 24.57, \"first\": \"Elizabeth\", \"last\": \"Payne\", \"gender\": \"F\", \"street\": \"897 Daugherty Mission\", \"city\": \"Grassflat\", \"state\": \"PA\", \"zip\": 16839, \"lat\": 41.0036, \"long\": -78.1104, \"city_pop\": 489, \"job\": \"Pension scheme manager\", \"dob\": \"1956-09-15\", \"trans_num\": \"382e068ad976b653116adffce8aab79d\", \"unix_time\": 1359411987, \"merch_lat\": 40.73209, \"merch_long\": -77.42354399999999, \"is_fraud\": 0, \"merchant_label\": 40, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 332}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2731, timestamp=1715387551536, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-11 18:56:02\", \"cc_num\": 3518234918950662, \"merchant\": \"fraud_Langworth LLC\", \"category\": \"personal_care\", \"amt\": 9.37, \"first\": \"Barbara\", \"last\": \"Lowe\", \"gender\": \"F\", \"street\": \"67210 Lori Creek\", \"city\": \"Sherman\", \"state\": \"TX\", \"zip\": 75092, \"lat\": 33.6372, \"long\": -96.6184, \"city_pop\": 46563, \"job\": \"Systems developer\", \"dob\": \"1970-09-11\", \"trans_num\": \"e25ea1614a805364e7a0ba71f7ce80bf\", \"unix_time\": 1339440962, \"merch_lat\": 34.207427, \"merch_long\": -95.727467, \"is_fraud\": 0, \"merchant_label\": 371, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 447}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=605, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2732, timestamp=1715387551538, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-16 18:24:33\", \"cc_num\": 36913587729122, \"merchant\": \"fraud_Zemlak, Tillman and Cremin\", \"category\": \"personal_care\", \"amt\": 27.51, \"first\": \"Ana\", \"last\": \"Mccormick\", \"gender\": \"F\", \"street\": \"4503 Patricia Route\", \"city\": \"Meridian\", \"state\": \"ID\", \"zip\": 83646, \"lat\": 43.6498, \"long\": -116.4306, \"city_pop\": 84106, \"job\": \"Intelligence analyst\", \"dob\": \"1971-02-11\", \"trans_num\": \"26037d15484e3b83c58d03b2ff752091\", \"unix_time\": 1339871073, \"merch_lat\": 43.320849, \"merch_long\": -117.025215, \"is_fraud\": 0, \"merchant_label\": 689, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 252}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=627, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2733, timestamp=1715387551540, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-15 06:32:53\", \"cc_num\": 4642255475285942, \"merchant\": \"fraud_Berge LLC\", \"category\": \"gas_transport\", \"amt\": 40.69, \"first\": \"Sabrina\", \"last\": \"Johnson\", \"gender\": \"F\", \"street\": \"320 Nicholson Orchard\", \"city\": \"Thompson\", \"state\": \"UT\", \"zip\": 84540, \"lat\": 38.9999, \"long\": -109.615, \"city_pop\": 46, \"job\": \"Surveyor, minerals\", \"dob\": \"1987-04-23\", \"trans_num\": \"a4175153839f7f94a149c9771e664fff\", \"unix_time\": 1352961173, \"merch_lat\": 39.657491, \"merch_long\": -110.552449, \"is_fraud\": 0, \"merchant_label\": 43, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 443}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=608, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2734, timestamp=1715387554545, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-21 14:20:37\", \"cc_num\": 4800395067176717, \"merchant\": \"fraud_Abshire PLC\", \"category\": \"entertainment\", \"amt\": 17.35, \"first\": \"Daniel\", \"last\": \"Owens\", \"gender\": \"M\", \"street\": \"88794 Mandy Lodge Apt. 874\", \"city\": \"Howells\", \"state\": \"NE\", \"zip\": 68641, \"lat\": 41.6964, \"long\": -96.9858, \"city_pop\": 1063, \"job\": \"Research scientist (maths)\", \"dob\": \"1928-04-02\", \"trans_num\": \"bf08ae5434bb7fe3b6be0274a563d4f8\", \"unix_time\": 1327155637, \"merch_lat\": 42.263528, \"merch_long\": -97.144974, \"is_fraud\": 0, \"merchant_label\": 3, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 395}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=619, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2735, timestamp=1715387554546, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-09 14:03:15\", \"cc_num\": 3568255211412877, \"merchant\": \"fraud_Larkin Ltd\", \"category\": \"kids_pets\", \"amt\": 8.44, \"first\": \"Timothy\", \"last\": \"Gomez\", \"gender\": \"M\", \"street\": \"707 Anthony Causeway\", \"city\": \"Leo\", \"state\": \"IN\", \"zip\": 46765, \"lat\": 41.2249, \"long\": -85.0301, \"city_pop\": 5341, \"job\": \"Biomedical engineer\", \"dob\": \"1994-11-24\", \"trans_num\": \"5edc9863723f7265420e7fd6516f191b\", \"unix_time\": 1365516195, \"merch_lat\": 40.856401, \"merch_long\": -85.865142, \"is_fraud\": 0, \"merchant_label\": 373, \"category_label\": 7, \"gender_label\": 1, \"job_label\": 47}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=598, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2736, timestamp=1715387554547, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-11 21:58:36\", \"cc_num\": 4658117080136, \"merchant\": \"fraud_Heaney-Marquardt\", \"category\": \"entertainment\", \"amt\": 1.62, \"first\": \"Dwayne\", \"last\": \"Martinez\", \"gender\": \"M\", \"street\": \"490 Baldwin Alley Apt. 468\", \"city\": \"Crownpoint\", \"state\": \"NM\", \"zip\": 87313, \"lat\": 35.7206, \"long\": -108.0271, \"city_pop\": 5662, \"job\": \"IT consultant\", \"dob\": \"1989-04-08\", \"trans_num\": \"83a887f4a99d1358603df4c4de4f4591\", \"unix_time\": 1370987916, \"merch_lat\": 35.323926, \"merch_long\": -108.87107, \"is_fraud\": 0, \"merchant_label\": 236, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 239}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2737, timestamp=1715387557554, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-05-20 19:46:28\", \"cc_num\": 3576431665303017, \"merchant\": \"fraud_Powlowski-Weimann\", \"category\": \"food_dining\", \"amt\": 18.91, \"first\": \"Jessica\", \"last\": \"Ward\", \"gender\": \"F\", \"street\": \"72269 Elizabeth Field Apt. 132\", \"city\": \"Phoenix\", \"state\": \"AZ\", \"zip\": 85020, \"lat\": 33.5623, \"long\": -112.0559, \"city_pop\": 1312922, \"job\": \"Contractor\", \"dob\": \"1981-10-24\", \"trans_num\": \"9e7cf1102d36bd9e9a150459d53c0b51\", \"unix_time\": 1337543188, \"merch_lat\": 32.861769, \"merch_long\": -112.572192, \"is_fraud\": 0, \"merchant_label\": 485, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 107}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=618, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2738, timestamp=1715387557555, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-01 03:58:45\", \"cc_num\": 180046765320457, \"merchant\": \"fraud_Mohr Inc\", \"category\": \"shopping_pos\", \"amt\": 9.17, \"first\": \"Jared\", \"last\": \"Camacho\", \"gender\": \"M\", \"street\": \"4257 Perez Mall\", \"city\": \"Canton\", \"state\": \"OH\", \"zip\": 44702, \"lat\": 40.8027, \"long\": -81.3739, \"city_pop\": 192805, \"job\": \"Building control surveyor\", \"dob\": \"1963-06-30\", \"trans_num\": \"e4be548991a53f9fc2b0b38e689e004a\", \"unix_time\": 1333252725, \"merch_lat\": 40.359525, \"merch_long\": -81.855007, \"is_fraud\": 0, \"merchant_label\": 429, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 53}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=605, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2739, timestamp=1715387557557, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-16 20:26:41\", \"cc_num\": 4010002218955876, \"merchant\": \"fraud_Barton LLC\", \"category\": \"kids_pets\", \"amt\": 86.65, \"first\": \"Jennifer\", \"last\": \"Bishop\", \"gender\": \"F\", \"street\": \"589 Matthew Brooks\", \"city\": \"Houston\", \"state\": \"TX\", \"zip\": 77026, \"lat\": 29.7972, \"long\": -95.3288, \"city_pop\": 2906700, \"job\": \"Animator\", \"dob\": \"1983-08-24\", \"trans_num\": \"d2fdb2e02d22ab8596fbcde3463bfafa\", \"unix_time\": 1353097601, \"merch_lat\": 30.059899, \"merch_long\": -94.783178, \"is_fraud\": 0, \"merchant_label\": 26, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 27}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=594, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2740, timestamp=1715387557558, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-11 00:29:07\", \"cc_num\": 584673555952, \"merchant\": \"fraud_Kerluke-Abshire\", \"category\": \"shopping_net\", \"amt\": 1.15, \"first\": \"Jessica\", \"last\": \"Jordan\", \"gender\": \"F\", \"street\": \"071 Wise Trace\", \"city\": \"Coleharbor\", \"state\": \"ND\", \"zip\": 58531, \"lat\": 47.5196, \"long\": -101.2332, \"city_pop\": 307, \"job\": \"Make\", \"dob\": \"1930-08-13\", \"trans_num\": \"5ac480cc947aa3cfc28d614ddf996748\", \"unix_time\": 1381451347, \"merch_lat\": 47.135245, \"merch_long\": -102.094408, \"is_fraud\": 0, \"merchant_label\": 304, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 281}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=592, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2741, timestamp=1715387557560, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-18 13:10:52\", \"cc_num\": 6011104316292105, \"merchant\": \"fraud_Mosciski, Ziemann and Farrell\", \"category\": \"shopping_net\", \"amt\": 103.87, \"first\": \"Valerie\", \"last\": \"Davis\", \"gender\": \"F\", \"street\": \"3861 Anderson Ramp Apt. 536\", \"city\": \"Drakes Branch\", \"state\": \"VA\", \"zip\": 23937, \"lat\": 36.9688, \"long\": -78.5615, \"city_pop\": 1970, \"job\": \"Energy engineer\", \"dob\": \"1985-09-02\", \"trans_num\": \"7191f00998a4ec271c446728c920ca57\", \"unix_time\": 1371561052, \"merch_lat\": 36.131277, \"merch_long\": -78.350702, \"is_fraud\": 0, \"merchant_label\": 443, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 151}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=637, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2742, timestamp=1715387557561, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-27 22:16:43\", \"cc_num\": 370612217861404, \"merchant\": \"fraud_Hills, Hegmann and Schaefer\", \"category\": \"health_fitness\", \"amt\": 109.12, \"first\": \"Amanda\", \"last\": \"Fitzgerald\", \"gender\": \"F\", \"street\": \"298 Kayla Lights\", \"city\": \"Bristol\", \"state\": \"PA\", \"zip\": 19007, \"lat\": 40.1159, \"long\": -74.8536, \"city_pop\": 21125, \"job\": \"Administrator, charities/voluntary organisations\", \"dob\": \"1985-05-25\", \"trans_num\": \"6e163a2b21e42ee82f3576f19b3271cd\", \"unix_time\": 1372371403, \"merch_lat\": 39.569468, \"merch_long\": -75.346197, \"is_fraud\": 0, \"merchant_label\": 253, \"category_label\": 5, \"gender_label\": 0, \"job_label\": 8}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=654, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2743, timestamp=1715387560566, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-02 06:04:53\", \"cc_num\": 4170689372027579, \"merchant\": \"fraud_Kerluke Inc\", \"category\": \"misc_net\", \"amt\": 5.6, \"first\": \"Samuel\", \"last\": \"Frey\", \"gender\": \"M\", \"street\": \"830 Myers Plaza Apt. 384\", \"city\": \"Edmond\", \"state\": \"OK\", \"zip\": 73034, \"lat\": 35.6665, \"long\": -97.4798, \"city_pop\": 116001, \"job\": \"Media buyer\", \"dob\": \"1993-05-10\", \"trans_num\": \"0c0fff4edd722099420490798b3e2d79\", \"unix_time\": 1338617093, \"merch_lat\": 34.701974, \"merch_long\": -97.887404, \"is_fraud\": 0, \"merchant_label\": 300, \"category_label\": 8, \"gender_label\": 1, \"job_label\": 289}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=597, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2744, timestamp=1715387560567, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-20 18:43:58\", \"cc_num\": 3560318482131952, \"merchant\": \"fraud_Windler, Goodwin and Kovacek\", \"category\": \"home\", \"amt\": 22.72, \"first\": \"William\", \"last\": \"Skinner\", \"gender\": \"M\", \"street\": \"524 Wu Spurs Suite 894\", \"city\": \"Mount Hope\", \"state\": \"AL\", \"zip\": 35651, \"lat\": 34.4793, \"long\": -87.4769, \"city_pop\": 1312, \"job\": \"Librarian, academic\", \"dob\": \"1955-02-01\", \"trans_num\": \"9a66e982f492f6d69677c4f8f830c52f\", \"unix_time\": 1350758638, \"merch_lat\": 35.181733, \"merch_long\": -88.037879, \"is_fraud\": 0, \"merchant_label\": 672, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 271}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=624, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2745, timestamp=1715387563575, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-07 11:11:47\", \"cc_num\": 4952583804639909, \"merchant\": \"fraud_Reinger, Weissnat and Strosin\", \"category\": \"food_dining\", \"amt\": 88.49, \"first\": \"Patricia\", \"last\": \"Rodriguez\", \"gender\": \"F\", \"street\": \"386 Randolph Throughway\", \"city\": \"Warren\", \"state\": \"OH\", \"zip\": 44483, \"lat\": 41.2639, \"long\": -80.8164, \"city_pop\": 75903, \"job\": \"Magazine features editor\", \"dob\": \"1957-04-05\", \"trans_num\": \"4bdd8c8cc8b27c22460e24fe3bc1ff64\", \"unix_time\": 1378552307, \"merch_lat\": 41.787306, \"merch_long\": -80.47332, \"is_fraud\": 0, \"merchant_label\": 509, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 278}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=637, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2746, timestamp=1715387563576, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-16 17:03:19\", \"cc_num\": 4642894980163, \"merchant\": \"fraud_Haley, Jewess and Bechtelar\", \"category\": \"shopping_pos\", \"amt\": 4.36, \"first\": \"Eddie\", \"last\": \"Mendez\", \"gender\": \"M\", \"street\": \"1831 Faith View Suite 653\", \"city\": \"Clarinda\", \"state\": \"IA\", \"zip\": 51632, \"lat\": 40.7491, \"long\": -95.038, \"city_pop\": 7297, \"job\": \"IT trainer\", \"dob\": \"1990-07-13\", \"trans_num\": \"a3d99f5241c94b5987c1c5f3385d41bb\", \"unix_time\": 1387213399, \"merch_lat\": 40.541776, \"merch_long\": -94.593231, \"is_fraud\": 0, \"merchant_label\": 224, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 240}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2747, timestamp=1715387563579, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-09 10:29:10\", \"cc_num\": 377026671291680, \"merchant\": \"fraud_Raynor, Feest and Miller\", \"category\": \"gas_transport\", \"amt\": 47.67, \"first\": \"Jackie\", \"last\": \"Davis\", \"gender\": \"F\", \"street\": \"1898 Parker Fork Apt. 057\", \"city\": \"Redford\", \"state\": \"MO\", \"zip\": 63665, \"lat\": 37.3272, \"long\": -91.0243, \"city_pop\": 241, \"job\": \"Investment analyst\", \"dob\": \"1974-10-27\", \"trans_num\": \"29df2438167d62a9451697270097e9a3\", \"unix_time\": 1386584950, \"merch_lat\": 36.705763, \"merch_long\": -91.53389, \"is_fraud\": 0, \"merchant_label\": 497, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 255}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=622, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2748, timestamp=1715387563581, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-08 22:49:08\", \"cc_num\": 30199621383748, \"merchant\": \"fraud_Roberts, Daniel and Macejkovic\", \"category\": \"kids_pets\", \"amt\": 9.59, \"first\": \"Theresa\", \"last\": \"Powell\", \"gender\": \"F\", \"street\": \"117 Natasha Vista Suite 936\", \"city\": \"Leonard\", \"state\": \"TX\", \"zip\": 75452, \"lat\": 33.4044, \"long\": -96.2238, \"city_pop\": 4090, \"job\": \"Sub\", \"dob\": \"1977-03-23\", \"trans_num\": \"9f54b90eaec433f5d9e23b28e3fb6eb3\", \"unix_time\": 1378680548, \"merch_lat\": 34.038090999999994, \"merch_long\": -95.67043, \"is_fraud\": 0, \"merchant_label\": 519, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 439}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2749, timestamp=1715387566590, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-31 03:14:29\", \"cc_num\": 4727244663135968, \"merchant\": \"fraud_Emard Inc\", \"category\": \"gas_transport\", \"amt\": 67.61, \"first\": \"Mary\", \"last\": \"Lewis\", \"gender\": \"F\", \"street\": \"118 Justin Extension\", \"city\": \"Bay Minette\", \"state\": \"AL\", \"zip\": 36507, \"lat\": 30.8635, \"long\": -87.7644, \"city_pop\": 19090, \"job\": \"Science writer\", \"dob\": \"1929-05-30\", \"trans_num\": \"d991e71568c8c10718b211dc4e1fefc4\", \"unix_time\": 1364699669, \"merch_lat\": 30.605142, \"merch_long\": -87.013434, \"is_fraud\": 0, \"merchant_label\": 157, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 408}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=604, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2750, timestamp=1715387566592, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-14 15:48:34\", \"cc_num\": 3523898249167098, \"merchant\": \"fraud_Spencer PLC\", \"category\": \"entertainment\", \"amt\": 21.51, \"first\": \"Joshua\", \"last\": \"Carpenter\", \"gender\": \"M\", \"street\": \"04975 Allison Shoal\", \"city\": \"Bronx\", \"state\": \"NY\", \"zip\": 10463, \"lat\": 40.8798, \"long\": -73.9067, \"city_pop\": 1382480, \"job\": \"Therapist, drama\", \"dob\": \"1990-11-09\", \"trans_num\": \"03eef43d7a84d77b5747ef161ef090a3\", \"unix_time\": 1371224914, \"merch_lat\": 40.777051, \"merch_long\": -73.568593, \"is_fraud\": 0, \"merchant_label\": 586, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 469}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2751, timestamp=1715387566595, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-23 03:02:11\", \"cc_num\": 30199621383748, \"merchant\": \"fraud_Paucek-Wiza\", \"category\": \"grocery_net\", \"amt\": 64.28, \"first\": \"Theresa\", \"last\": \"Powell\", \"gender\": \"F\", \"street\": \"117 Natasha Vista Suite 936\", \"city\": \"Leonard\", \"state\": \"TX\", \"zip\": 75452, \"lat\": 33.4044, \"long\": -96.2238, \"city_pop\": 4090, \"job\": \"Sub\", \"dob\": \"1977-03-23\", \"trans_num\": \"e7d311102850063d97aac594c04b13af\", \"unix_time\": 1369278131, \"merch_lat\": 34.13864, \"merch_long\": -96.579753, \"is_fraud\": 0, \"merchant_label\": 478, \"category_label\": 3, \"gender_label\": 0, \"job_label\": 439}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=596, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2752, timestamp=1715387566596, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-05 17:16:24\", \"cc_num\": 372382441451095, \"merchant\": \"fraud_Hermiston, Russel and Price\", \"category\": \"food_dining\", \"amt\": 15.66, \"first\": \"Brent\", \"last\": \"Terrell\", \"gender\": \"M\", \"street\": \"502 Rice Plaza Apt. 979\", \"city\": \"Port Ewen\", \"state\": \"NY\", \"zip\": 12466, \"lat\": 41.8948, \"long\": -73.9767, \"city_pop\": 2471, \"job\": \"Heritage manager\", \"dob\": \"1966-01-21\", \"trans_num\": \"f9aad792071ba7488db6921ed5d2b64c\", \"unix_time\": 1357406184, \"merch_lat\": 42.832135, \"merch_long\": -73.418995, \"is_fraud\": 0, \"merchant_label\": 249, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 224}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=624, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2753, timestamp=1715387566599, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-25 09:59:46\", \"cc_num\": 377993105397617, \"merchant\": \"fraud_Hudson-Ratke\", \"category\": \"grocery_pos\", \"amt\": 66.76, \"first\": \"Nathan\", \"last\": \"Martinez\", \"gender\": \"M\", \"street\": \"586 Thomas Cliffs\", \"city\": \"Oconto Falls\", \"state\": \"WI\", \"zip\": 54154, \"lat\": 44.8755, \"long\": -88.1555, \"city_pop\": 5548, \"job\": \"Mining engineer\", \"dob\": \"1975-09-11\", \"trans_num\": \"1d89ecb623c61a38322d7a11413ca05f\", \"unix_time\": 1364205586, \"merch_lat\": 45.841002, \"merch_long\": -88.666536, \"is_fraud\": 0, \"merchant_label\": 268, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 299}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2754, timestamp=1715387569604, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-21 19:07:28\", \"cc_num\": 4069975342931683, \"merchant\": \"fraud_O\\'Connell-Ullrich\", \"category\": \"home\", \"amt\": 54.67, \"first\": \"Kimberly\", \"last\": \"Martin\", \"gender\": \"F\", \"street\": \"1943 Dennis Inlet Suite 145\", \"city\": \"Hurricane\", \"state\": \"WV\", \"zip\": 25526, \"lat\": 38.4257, \"long\": -81.9943, \"city_pop\": 21902, \"job\": \"Sub\", \"dob\": \"1980-09-18\", \"trans_num\": \"080e76eab42e18f5dc62649a5a508185\", \"unix_time\": 1366571248, \"merch_lat\": 37.826607, \"merch_long\": -82.440567, \"is_fraud\": 0, \"merchant_label\": 457, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 439}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=602, serialized_header_size=-1)\n",
      "Error in transaction: <Error from server: code=2000 [Syntax error in CQL query] message=\"line 1:141 mismatched input 'Connell' expecting EOF (... INTO bigdata.transaction_data JSON '{\"trans_date_trans_time\": \"2020-04-21 19:07:28\", \"cc_num\": 4069975342931683, \"merchant\": \"fraud_O'[Connell]...)\">\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2755, timestamp=1715387569606, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-03 01:08:15\", \"cc_num\": 3546674063249004, \"merchant\": \"fraud_Cartwright-Harris\", \"category\": \"grocery_pos\", \"amt\": 69.26, \"first\": \"Jordan\", \"last\": \"May\", \"gender\": \"M\", \"street\": \"1626 Susan Course\", \"city\": \"Aledo\", \"state\": \"TX\", \"zip\": 76008, \"lat\": 32.7004, \"long\": -97.6039, \"city_pop\": 13602, \"job\": \"Optometrist\", \"dob\": \"1984-07-05\", \"trans_num\": \"7993d9070fcd74392aa6a6e2f00d66c1\", \"unix_time\": 1362272895, \"merch_lat\": 32.206001, \"merch_long\": -96.629243, \"is_fraud\": 0, \"merchant_label\": 86, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 324}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=597, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2756, timestamp=1715387569607, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-20 02:55:58\", \"cc_num\": 60422928733, \"merchant\": \"fraud_Hermiston, Russel and Price\", \"category\": \"food_dining\", \"amt\": 186.4, \"first\": \"Jeffrey\", \"last\": \"Powers\", \"gender\": \"M\", \"street\": \"38352 Parrish Road Apt. 652\", \"city\": \"North Augusta\", \"state\": \"SC\", \"zip\": 29860, \"lat\": 33.6028, \"long\": -81.9748, \"city_pop\": 46944, \"job\": \"Secondary school teacher\", \"dob\": \"1942-04-02\", \"trans_num\": \"9e0cd0e282794238c74e5e157b5e7737\", \"unix_time\": 1358650558, \"merch_lat\": 33.845023, \"merch_long\": -81.313263, \"is_fraud\": 0, \"merchant_label\": 249, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 418}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=638, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2757, timestamp=1715387569609, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-13 15:16:12\", \"cc_num\": 213125815021702, \"merchant\": \"fraud_Kulas Group\", \"category\": \"health_fitness\", \"amt\": 11.07, \"first\": \"Adam\", \"last\": \"Kirk\", \"gender\": \"M\", \"street\": \"40847 Stark Junctions\", \"city\": \"Big Indian\", \"state\": \"NY\", \"zip\": 12410, \"lat\": 42.074, \"long\": -74.453, \"city_pop\": 397, \"job\": \"Psychiatrist\", \"dob\": \"1931-09-12\", \"trans_num\": \"0a2b012789a042d0763c658d40de0a82\", \"unix_time\": 1365866172, \"merch_lat\": 41.921083, \"merch_long\": -73.588849, \"is_fraud\": 0, \"merchant_label\": 350, \"category_label\": 5, \"gender_label\": 1, \"job_label\": 370}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=599, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2758, timestamp=1715387569610, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-27 02:42:39\", \"cc_num\": 4561546772499, \"merchant\": \"fraud_Bartoletti-Wunsch\", \"category\": \"gas_transport\", \"amt\": 51.32, \"first\": \"Daniel\", \"last\": \"Briggs\", \"gender\": \"M\", \"street\": \"7118 Jessica Unions Apt. 789\", \"city\": \"Moriarty\", \"state\": \"NM\", \"zip\": 87035, \"lat\": 34.9889, \"long\": -106.0609, \"city_pop\": 7268, \"job\": \"Therapist, art\", \"dob\": \"1988-08-04\", \"trans_num\": \"fb12ded521c0091f285f3d3d25d64070\", \"unix_time\": 1380249759, \"merch_lat\": 34.198125, \"merch_long\": -106.914642, \"is_fraud\": 0, \"merchant_label\": 24, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 468}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2759, timestamp=1715387569614, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-28 21:01:50\", \"cc_num\": 213178765398315, \"merchant\": \"fraud_Baumbach, Strosin and Nicolas\", \"category\": \"shopping_pos\", \"amt\": 1.86, \"first\": \"Alan\", \"last\": \"Colon\", \"gender\": \"M\", \"street\": \"748 Bryan Fields Suite 935\", \"city\": \"Riverton\", \"state\": \"WY\", \"zip\": 82501, \"lat\": 43.0351, \"long\": -108.2024, \"city_pop\": 19408, \"job\": \"Lecturer, higher education\", \"dob\": \"1993-09-11\", \"trans_num\": \"7653ba747d94c0bf7cee47a9149ecfea\", \"unix_time\": 1375045310, \"merch_lat\": 42.507515000000005, \"merch_long\": -109.111638, \"is_fraud\": 0, \"merchant_label\": 33, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 267}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=647, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2760, timestamp=1715387569615, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-03 06:41:19\", \"cc_num\": 4670613943676271, \"merchant\": \"fraud_Goldner, Kovacek and Abbott\", \"category\": \"grocery_pos\", \"amt\": 88.58, \"first\": \"Bianca\", \"last\": \"Novak\", \"gender\": \"F\", \"street\": \"0953 David Skyway\", \"city\": \"Cuthbert\", \"state\": \"GA\", \"zip\": 39840, \"lat\": 31.7706, \"long\": -84.7936, \"city_pop\": 5726, \"job\": \"Fitness centre manager\", \"dob\": \"1947-08-14\", \"trans_num\": \"ca39fe5d1025e6fea25e3e72eaf14e04\", \"unix_time\": 1354516879, \"merch_lat\": 32.633512, \"merch_long\": -85.481105, \"is_fraud\": 0, \"merchant_label\": 194, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 200}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=623, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2761, timestamp=1715387572620, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-01 16:23:46\", \"cc_num\": 4378993458389626, \"merchant\": \"fraud_Bradtke, Torp and Bahringer\", \"category\": \"personal_care\", \"amt\": 45.8, \"first\": \"Travis\", \"last\": \"Hayes\", \"gender\": \"M\", \"street\": \"1561 Chase Grove\", \"city\": \"Conway\", \"state\": \"NH\", \"zip\": 3818, \"lat\": 43.9742, \"long\": -71.1503, \"city_pop\": 3807, \"job\": \"Surgeon\", \"dob\": \"1999-10-25\", \"trans_num\": \"85ede7e3ad7f8d579cc6ae046b6d0604\", \"unix_time\": 1367425426, \"merch_lat\": 43.161392, \"merch_long\": -72.11000200000001, \"is_fraud\": 0, \"merchant_label\": 74, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 440}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2762, timestamp=1715387572621, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-05 00:55:40\", \"cc_num\": 38014427445058, \"merchant\": \"fraud_Beier-Hyatt\", \"category\": \"shopping_pos\", \"amt\": 269.83, \"first\": \"Sonya\", \"last\": \"Jensen\", \"gender\": \"F\", \"street\": \"4470 Jillian Courts\", \"city\": \"Adams\", \"state\": \"WI\", \"zip\": 53910, \"lat\": 43.8967, \"long\": -89.8219, \"city_pop\": 3508, \"job\": \"Sport and exercise psychologist\", \"dob\": \"1946-08-11\", \"trans_num\": \"b18d1ffba206d1b731b5eb0e5ee61584\", \"unix_time\": 1354668940, \"merch_lat\": 43.922737, \"merch_long\": -89.13036600000001, \"is_fraud\": 0, \"merchant_label\": 42, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 433}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=623, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2763, timestamp=1715387572624, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-18 16:58:42\", \"cc_num\": 4561546772499, \"merchant\": \"fraud_Parker-Kunde\", \"category\": \"personal_care\", \"amt\": 2.02, \"first\": \"Daniel\", \"last\": \"Briggs\", \"gender\": \"M\", \"street\": \"7118 Jessica Unions Apt. 789\", \"city\": \"Moriarty\", \"state\": \"NM\", \"zip\": 87035, \"lat\": 34.9889, \"long\": -106.0609, \"city_pop\": 7268, \"job\": \"Therapist, art\", \"dob\": \"1988-08-04\", \"trans_num\": \"0c95f973c355fb6ceb13709782c7628f\", \"unix_time\": 1353257922, \"merch_lat\": 35.974088, \"merch_long\": -105.091707, \"is_fraud\": 0, \"merchant_label\": 477, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 468}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2764, timestamp=1715387572629, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-26 03:37:44\", \"cc_num\": 180046765320457, \"merchant\": \"fraud_Moen, Reinger and Murphy\", \"category\": \"grocery_pos\", \"amt\": 83.05, \"first\": \"Jared\", \"last\": \"Camacho\", \"gender\": \"M\", \"street\": \"4257 Perez Mall\", \"city\": \"Canton\", \"state\": \"OH\", \"zip\": 44702, \"lat\": 40.8027, \"long\": -81.3739, \"city_pop\": 192805, \"job\": \"Building control surveyor\", \"dob\": \"1963-06-30\", \"trans_num\": \"329bcf305c85f2865541bd8366fdfc7e\", \"unix_time\": 1327549064, \"merch_lat\": 40.735512, \"merch_long\": -82.00964599999999, \"is_fraud\": 0, \"merchant_label\": 428, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 53}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=628, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2765, timestamp=1715387572631, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-29 16:05:47\", \"cc_num\": 3556613125071656, \"merchant\": \"fraud_Roberts-Beahan\", \"category\": \"misc_pos\", \"amt\": 2.25, \"first\": \"Jose\", \"last\": \"Vasquez\", \"gender\": \"M\", \"street\": \"572 Davis Mountains\", \"city\": \"Lake Jackson\", \"state\": \"TX\", \"zip\": 77566, \"lat\": 29.0393, \"long\": -95.4401, \"city_pop\": 28739, \"job\": \"Futures trader\", \"dob\": \"1999-12-27\", \"trans_num\": \"bd5273c04903e756557d846b24ffd13c\", \"unix_time\": 1380470747, \"merch_lat\": 28.495276, \"merch_long\": -94.785263, \"is_fraud\": 0, \"merchant_label\": 521, \"category_label\": 9, \"gender_label\": 1, \"job_label\": 207}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=605, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2766, timestamp=1715387572633, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-29 22:23:50\", \"cc_num\": 30270432095985, \"merchant\": \"fraud_Will Ltd\", \"category\": \"food_dining\", \"amt\": 17.11, \"first\": \"Lisa\", \"last\": \"Lin\", \"gender\": \"F\", \"street\": \"908 Brooks Brook\", \"city\": \"Lomax\", \"state\": \"IL\", \"zip\": 61454, \"lat\": 40.6761, \"long\": -91.0391, \"city_pop\": 725, \"job\": \"Environmental consultant\", \"dob\": \"1972-11-28\", \"trans_num\": \"075f1f00308197096c880c9622ec7d6f\", \"unix_time\": 1348957430, \"merch_lat\": 40.531914, \"merch_long\": -91.572893, \"is_fraud\": 0, \"merchant_label\": 668, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 179}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=595, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2767, timestamp=1715387572635, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-08-12 13:04:26\", \"cc_num\": 3598304579370089, \"merchant\": \"fraud_Kub PLC\", \"category\": \"personal_care\", \"amt\": 20.66, \"first\": \"Vincent\", \"last\": \"Flowers\", \"gender\": \"M\", \"street\": \"0189 Emily Prairie\", \"city\": \"Wichita\", \"state\": \"KS\", \"zip\": 67232, \"lat\": 37.6395, \"long\": -97.1714, \"city_pop\": 409656, \"job\": \"Heritage manager\", \"dob\": \"1985-12-27\", \"trans_num\": \"6b4f6e9c671c8935ad74cf170781df76\", \"unix_time\": 1344776666, \"merch_lat\": 38.394063, \"merch_long\": -96.688925, \"is_fraud\": 0, \"merchant_label\": 343, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 224}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=605, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2768, timestamp=1715387572638, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-24 09:09:32\", \"cc_num\": 375904527651269, \"merchant\": \"fraud_Mante Group\", \"category\": \"misc_net\", \"amt\": 2.3, \"first\": \"Ryan\", \"last\": \"Cook\", \"gender\": \"M\", \"street\": \"75952 Wilson Course\", \"city\": \"Roseland\", \"state\": \"NE\", \"zip\": 68973, \"lat\": 40.4591, \"long\": -98.5551, \"city_pop\": 463, \"job\": \"Nurse, mental health\", \"dob\": \"1948-05-31\", \"trans_num\": \"18a473a632d9a574f9b74072ca0f2b63\", \"unix_time\": 1364116172, \"merch_lat\": 40.310017, \"merch_long\": -98.570153, \"is_fraud\": 0, \"merchant_label\": 405, \"category_label\": 8, \"gender_label\": 1, \"job_label\": 313}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=597, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2769, timestamp=1715387575644, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-06 19:37:03\", \"cc_num\": 6526448584969862, \"merchant\": \"fraud_Auer LLC\", \"category\": \"personal_care\", \"amt\": 14.84, \"first\": \"Nathan\", \"last\": \"Stewart\", \"gender\": \"M\", \"street\": \"63502 Brown Road Apt. 318\", \"city\": \"West Long Branch\", \"state\": \"NJ\", \"zip\": 7764, \"lat\": 40.2878, \"long\": -74.0162, \"city_pop\": 8097, \"job\": \"Mechanical engineer\", \"dob\": \"1964-02-18\", \"trans_num\": \"c16caf291ad23687ef3d1d6f121b4502\", \"unix_time\": 1362598623, \"merch_lat\": 39.451949, \"merch_long\": -74.143908, \"is_fraud\": 0, \"merchant_label\": 11, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 288}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=620, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2770, timestamp=1715387575645, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-10 12:40:01\", \"cc_num\": 348789608637806, \"merchant\": \"fraud_Romaguera, Wehner and Tromp\", \"category\": \"kids_pets\", \"amt\": 7.66, \"first\": \"Megan\", \"last\": \"Murphy\", \"gender\": \"F\", \"street\": \"53696 Laura Radial\", \"city\": \"Holstein\", \"state\": \"NE\", \"zip\": 68950, \"lat\": 40.4542, \"long\": -98.6538, \"city_pop\": 331, \"job\": \"Telecommunications researcher\", \"dob\": \"1950-08-19\", \"trans_num\": \"322819578f7c1bb3fb004a5eca417742\", \"unix_time\": 1360500001, \"merch_lat\": 40.272895, \"merch_long\": -98.032162, \"is_fraud\": 0, \"merchant_label\": 529, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 459}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=626, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2771, timestamp=1715387575648, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-24 05:12:05\", \"cc_num\": 3528231451607350, \"merchant\": \"fraud_Kerluke, Considine and Macejkovic\", \"category\": \"misc_net\", \"amt\": 306.91, \"first\": \"Lauren\", \"last\": \"Moreno\", \"gender\": \"F\", \"street\": \"83719 Wilson Shore\", \"city\": \"Heislerville\", \"state\": \"NJ\", \"zip\": 8324, \"lat\": 39.224, \"long\": -74.9942, \"city_pop\": 526, \"job\": \"Exercise physiologist\", \"dob\": \"1940-09-06\", \"trans_num\": \"b26131d7aafd406cee535d8311639e3c\", \"unix_time\": 1340514725, \"merch_lat\": 40.03516, \"merch_long\": -75.808686, \"is_fraud\": 0, \"merchant_label\": 302, \"category_label\": 8, \"gender_label\": 0, \"job_label\": 187}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=628, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2772, timestamp=1715387575650, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-30 22:42:10\", \"cc_num\": 4430881574719618, \"merchant\": \"fraud_Kozey-McDermott\", \"category\": \"travel\", \"amt\": 6.82, \"first\": \"Alicia\", \"last\": \"Morales\", \"gender\": \"F\", \"street\": \"4456 Dunn Roads\", \"city\": \"Meredith\", \"state\": \"CO\", \"zip\": 81642, \"lat\": 39.3199, \"long\": -106.6596, \"city_pop\": 61, \"job\": \"Public relations account executive\", \"dob\": \"1939-11-04\", \"trans_num\": \"8b5317a008cbe0a4fe39fd75db3bacc6\", \"unix_time\": 1356907330, \"merch_lat\": 40.17568, \"merch_long\": -106.515999, \"is_fraud\": 0, \"merchant_label\": 339, \"category_label\": 13, \"gender_label\": 0, \"job_label\": 380}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2773, timestamp=1715387578656, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-11 12:32:13\", \"cc_num\": 4239552724014407, \"merchant\": \"fraud_Marvin-Lind\", \"category\": \"personal_care\", \"amt\": 102.01, \"first\": \"Carl\", \"last\": \"Hernandez\", \"gender\": \"M\", \"street\": \"9134 Darryl Flat Suite 916\", \"city\": \"Paulding\", \"state\": \"OH\", \"zip\": 45879, \"lat\": 41.141000000000005, \"long\": -84.5722, \"city_pop\": 6284, \"job\": \"Secondary school teacher\", \"dob\": \"1936-03-27\", \"trans_num\": \"5d72e265535c3fb3ae5e2e34fb5aac79\", \"unix_time\": 1347366733, \"merch_lat\": 41.983493, \"merch_long\": -85.33264799999999, \"is_fraud\": 0, \"merchant_label\": 408, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 418}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=643, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2774, timestamp=1715387578657, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-21 14:38:30\", \"cc_num\": 4301028321766222513, \"merchant\": \"fraud_Fritsch and Sons\", \"category\": \"health_fitness\", \"amt\": 74.95, \"first\": \"Joe\", \"last\": \"Howard\", \"gender\": \"M\", \"street\": \"109 Brian Lights Apt. 504\", \"city\": \"Shippingport\", \"state\": \"PA\", \"zip\": 15077, \"lat\": 40.6025, \"long\": -80.3863, \"city_pop\": 198, \"job\": \"Secretary/administrator\", \"dob\": \"1978-10-26\", \"trans_num\": \"4c5634d85e962f9ea092adae78557fd9\", \"unix_time\": 1356100710, \"merch_lat\": 39.863282, \"merch_long\": -80.079939, \"is_fraud\": 0, \"merchant_label\": 185, \"category_label\": 5, \"gender_label\": 1, \"job_label\": 419}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=628, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2775, timestamp=1715387578658, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-25 19:16:38\", \"cc_num\": 4171397999167005, \"merchant\": \"fraud_Champlin, Rolfson and Connelly\", \"category\": \"travel\", \"amt\": 7.66, \"first\": \"Ashley\", \"last\": \"Mcdonald\", \"gender\": \"F\", \"street\": \"3160 Tina Estates Suite 234\", \"city\": \"Marietta\", \"state\": \"SC\", \"zip\": 29661, \"lat\": 35.0296, \"long\": -82.5136, \"city_pop\": 5648, \"job\": \"Museum/gallery exhibitions officer\", \"dob\": \"1934-10-06\", \"trans_num\": \"0f1c63fdac83cbe2d9925d7cba39d660\", \"unix_time\": 1387998998, \"merch_lat\": 35.440037, \"merch_long\": -83.36706600000001, \"is_fraud\": 0, \"merchant_label\": 90, \"category_label\": 13, \"gender_label\": 0, \"job_label\": 304}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=653, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2776, timestamp=1715387578660, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-08-19 20:11:45\", \"cc_num\": 6011381817520024, \"merchant\": \"fraud_Wuckert, Wintheiser and Friesen\", \"category\": \"home\", \"amt\": 39.79, \"first\": \"Kristen\", \"last\": \"Allen\", \"gender\": \"F\", \"street\": \"8619 Lisa Manors Apt. 871\", \"city\": \"Lagrange\", \"state\": \"WY\", \"zip\": 82221, \"lat\": 41.6423, \"long\": -104.1974, \"city_pop\": 635, \"job\": \"Product/process development scientist\", \"dob\": \"1973-07-13\", \"trans_num\": \"c62b5522e55688b2188192aa0b4319df\", \"unix_time\": 1345407105, \"merch_lat\": 41.460121, \"merch_long\": -103.648157, \"is_fraud\": 0, \"merchant_label\": 679, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 360}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=645, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2777, timestamp=1715387578661, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-14 13:29:10\", \"cc_num\": 30408301059761, \"merchant\": \"fraud_Brown, Homenick and Lesch\", \"category\": \"health_fitness\", \"amt\": 90.18, \"first\": \"Brandon\", \"last\": \"Pittman\", \"gender\": \"M\", \"street\": \"2881 Frey Village\", \"city\": \"Cross\", \"state\": \"SC\", \"zip\": 29436, \"lat\": 33.3364, \"long\": -80.1859, \"city_pop\": 4471, \"job\": \"Occupational hygienist\", \"dob\": \"1973-10-09\", \"trans_num\": \"afd953f21f9278a11a712aa53a63ab66\", \"unix_time\": 1381757350, \"merch_lat\": 32.514265, \"merch_long\": -80.966245, \"is_fraud\": 0, \"merchant_label\": 80, \"category_label\": 5, \"gender_label\": 1, \"job_label\": 315}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2778, timestamp=1715387581669, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-25 23:20:41\", \"cc_num\": 3529597930342630, \"merchant\": \"fraud_Dickinson-Rempel\", \"category\": \"misc_pos\", \"amt\": 7.76, \"first\": \"Melissa\", \"last\": \"Rodriguez\", \"gender\": \"F\", \"street\": \"81708 Christopher Plaza\", \"city\": \"Jordanville\", \"state\": \"NY\", \"zip\": 13361, \"lat\": 42.8948, \"long\": -74.8209, \"city_pop\": 824, \"job\": \"Travel agency manager\", \"dob\": \"1985-09-01\", \"trans_num\": \"43842db4db111b16e3b264caafd8ca79\", \"unix_time\": 1353885641, \"merch_lat\": 43.756311, \"merch_long\": -73.847408, \"is_fraud\": 0, \"merchant_label\": 137, \"category_label\": 9, \"gender_label\": 0, \"job_label\": 483}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=620, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2779, timestamp=1715387584673, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-05-26 17:33:41\", \"cc_num\": 630451534402, \"merchant\": \"fraud_Terry Ltd\", \"category\": \"home\", \"amt\": 74.1, \"first\": \"Rachel\", \"last\": \"Daniels\", \"gender\": \"F\", \"street\": \"561 Little Plain Apt. 738\", \"city\": \"Wetmore\", \"state\": \"MI\", \"zip\": 49895, \"lat\": 46.3535, \"long\": -86.6345, \"city_pop\": 765, \"job\": \"Immunologist\", \"dob\": \"1972-06-12\", \"trans_num\": \"af63a12658241f8835bd374c529e1594\", \"unix_time\": 1338053621, \"merch_lat\": 45.437904, \"merch_long\": -86.600765, \"is_fraud\": 0, \"merchant_label\": 614, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 243}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=591, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2780, timestamp=1715387584675, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-28 11:32:18\", \"cc_num\": 4635330563105903, \"merchant\": \"fraud_McCullough LLC\", \"category\": \"misc_pos\", \"amt\": 6.07, \"first\": \"Christina\", \"last\": \"Rose\", \"gender\": \"F\", \"street\": \"1984 Taylor Island Suite 836\", \"city\": \"Falls Church\", \"state\": \"VA\", \"zip\": 22046, \"lat\": 38.8856, \"long\": -77.1802, \"city_pop\": 116155, \"job\": \"Chartered accountant\", \"dob\": \"1983-07-10\", \"trans_num\": \"dc64a6dd881b967ea318c0cac6ea6926\", \"unix_time\": 1335612738, \"merch_lat\": 39.120456, \"merch_long\": -76.93047, \"is_fraud\": 0, \"merchant_label\": 411, \"category_label\": 9, \"gender_label\": 0, \"job_label\": 68}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2781, timestamp=1715387584676, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-28 05:07:11\", \"cc_num\": 2576709887791552, \"merchant\": \"fraud_Prohaska-Murray\", \"category\": \"gas_transport\", \"amt\": 69.66, \"first\": \"Joseph\", \"last\": \"Morgan\", \"gender\": \"M\", \"street\": \"126 Underwood Drive\", \"city\": \"San Diego\", \"state\": \"CA\", \"zip\": 92128, \"lat\": 33.0067, \"long\": -117.069, \"city_pop\": 1241364, \"job\": \"Chartered public finance accountant\", \"dob\": \"1959-08-05\", \"trans_num\": \"dcce89829ae6cf05352261668a3242b7\", \"unix_time\": 1380344831, \"merch_lat\": 33.245563, \"merch_long\": -117.77818, \"is_fraud\": 0, \"merchant_label\": 488, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 71}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=632, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2782, timestamp=1715387584678, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-23 14:26:18\", \"cc_num\": 180048185037117, \"merchant\": \"fraud_Howe PLC\", \"category\": \"entertainment\", \"amt\": 106.01, \"first\": \"Mary\", \"last\": \"Wall\", \"gender\": \"F\", \"street\": \"2481 Mills Lock\", \"city\": \"Plainfield\", \"state\": \"NJ\", \"zip\": 7060, \"lat\": 40.6152, \"long\": -74.415, \"city_pop\": 71485, \"job\": \"Leisure centre manager\", \"dob\": \"1974-07-19\", \"trans_num\": \"9011b5d46f357b257ebe3f578e03c6b5\", \"unix_time\": 1348410378, \"merch_lat\": 41.040219, \"merch_long\": -74.051422, \"is_fraud\": 0, \"merchant_label\": 266, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 269}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=602, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2783, timestamp=1715387584681, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-10 14:43:17\", \"cc_num\": 2712209726293386, \"merchant\": \"fraud_Lynch-Wisozk\", \"category\": \"home\", \"amt\": 150.93, \"first\": \"Jenna\", \"last\": \"Brooks\", \"gender\": \"F\", \"street\": \"50872 Alex Plain Suite 088\", \"city\": \"Baton Rouge\", \"state\": \"LA\", \"zip\": 70808, \"lat\": 30.4066, \"long\": -91.1468, \"city_pop\": 378909, \"job\": \"Designer, furniture\", \"dob\": \"1977-02-22\", \"trans_num\": \"7c0008451fa791c3bb47e51118bf1636\", \"unix_time\": 1381416197, \"merch_lat\": 30.20278, \"merch_long\": -91.749116, \"is_fraud\": 0, \"merchant_label\": 402, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 123}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=612, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2784, timestamp=1715387584685, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-16 11:51:49\", \"cc_num\": 3590736522064285, \"merchant\": \"fraud_Block Group\", \"category\": \"misc_pos\", \"amt\": 86.17, \"first\": \"Kimberly\", \"last\": \"Gonzalez\", \"gender\": \"F\", \"street\": \"72966 Shannon Pass Apt. 391\", \"city\": \"Bauxite\", \"state\": \"AR\", \"zip\": 72011, \"lat\": 34.5091, \"long\": -92.4828, \"city_pop\": 4074, \"job\": \"Scientist, audiological\", \"dob\": \"1975-12-20\", \"trans_num\": \"8f10b3f3b01650535b95afb891668658\", \"unix_time\": 1366113109, \"merch_lat\": 35.443938, \"merch_long\": -92.947298, \"is_fraud\": 0, \"merchant_label\": 57, \"category_label\": 9, \"gender_label\": 0, \"job_label\": 410}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=618, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2785, timestamp=1715387584686, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-13 23:24:48\", \"cc_num\": 30199621383748, \"merchant\": \"fraud_Graham, Hegmann and Hammes\", \"category\": \"food_dining\", \"amt\": 51.61, \"first\": \"Theresa\", \"last\": \"Powell\", \"gender\": \"F\", \"street\": \"117 Natasha Vista Suite 936\", \"city\": \"Leonard\", \"state\": \"TX\", \"zip\": 75452, \"lat\": 33.4044, \"long\": -96.2238, \"city_pop\": 4090, \"job\": \"Sub\", \"dob\": \"1977-03-23\", \"trans_num\": \"aba467f192820568d354086910a9d6ce\", \"unix_time\": 1386977088, \"merch_lat\": 33.933137, \"merch_long\": -96.753133, \"is_fraud\": 0, \"merchant_label\": 205, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 439}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=612, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2786, timestamp=1715387584687, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-02 09:38:49\", \"cc_num\": 379897244598068, \"merchant\": \"fraud_Erdman-Kertzmann\", \"category\": \"gas_transport\", \"amt\": 84.24, \"first\": \"Frank\", \"last\": \"Key\", \"gender\": \"M\", \"street\": \"5537 Jessica Plaza\", \"city\": \"Pewee Valley\", \"state\": \"KY\", \"zip\": 40056, \"lat\": 38.3039, \"long\": -85.4834, \"city_pop\": 3263, \"job\": \"Stage manager\", \"dob\": \"1930-02-28\", \"trans_num\": \"8c7641fe4ca649036de1859294f290a2\", \"unix_time\": 1333359529, \"merch_lat\": 39.204936, \"merch_long\": -86.00985, \"is_fraud\": 0, \"merchant_label\": 162, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 436}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=605, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2787, timestamp=1715387584689, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-11 13:32:10\", \"cc_num\": 4862293128558, \"merchant\": \"fraud_Lind-Buckridge\", \"category\": \"entertainment\", \"amt\": 31.83, \"first\": \"Elizabeth\", \"last\": \"Payne\", \"gender\": \"F\", \"street\": \"897 Daugherty Mission\", \"city\": \"Grassflat\", \"state\": \"PA\", \"zip\": 16839, \"lat\": 41.0036, \"long\": -78.1104, \"city_pop\": 489, \"job\": \"Pension scheme manager\", \"dob\": \"1956-09-15\", \"trans_num\": \"4ac2f971018b7248244f6f03cba36f7e\", \"unix_time\": 1342013530, \"merch_lat\": 40.242097, \"merch_long\": -78.221548, \"is_fraud\": 0, \"merchant_label\": 390, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 332}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2788, timestamp=1715387584691, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-26 12:07:25\", \"cc_num\": 6011366578560244, \"merchant\": \"fraud_Conroy Ltd\", \"category\": \"shopping_pos\", \"amt\": 2.6, \"first\": \"Adam\", \"last\": \"Stark\", \"gender\": \"M\", \"street\": \"0912 Mark Fields Apt. 080\", \"city\": \"Mc Veytown\", \"state\": \"PA\", \"zip\": 17051, \"lat\": 40.5046, \"long\": -77.7186, \"city_pop\": 4653, \"job\": \"Nutritional therapist\", \"dob\": \"1997-07-01\", \"trans_num\": \"7bdc487787fb5971966f511aee85266b\", \"unix_time\": 1374840445, \"merch_lat\": 41.111178, \"merch_long\": -77.730138, \"is_fraud\": 0, \"merchant_label\": 101, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 314}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2789, timestamp=1715387587696, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-17 02:42:41\", \"cc_num\": 3534330126107879, \"merchant\": \"fraud_Mohr Inc\", \"category\": \"shopping_pos\", \"amt\": 117.51, \"first\": \"Jeffrey\", \"last\": \"Smith\", \"gender\": \"M\", \"street\": \"713 Scott Pike Apt. 712\", \"city\": \"Bridger\", \"state\": \"MT\", \"zip\": 59014, \"lat\": 45.2857, \"long\": -108.9082, \"city_pop\": 1446, \"job\": \"Chartered loss adjuster\", \"dob\": \"1978-01-15\", \"trans_num\": \"eb76305e1505b84337c347391e26a565\", \"unix_time\": 1387248161, \"merch_lat\": 45.393254, \"merch_long\": -108.886656, \"is_fraud\": 0, \"merchant_label\": 429, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 70}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=615, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2790, timestamp=1715387587698, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-02 18:45:41\", \"cc_num\": 581686439828, \"merchant\": \"fraud_Berge-Hills\", \"category\": \"kids_pets\", \"amt\": 16.65, \"first\": \"Larry\", \"last\": \"House\", \"gender\": \"M\", \"street\": \"911 Sabrina Trafficway\", \"city\": \"Cochranton\", \"state\": \"PA\", \"zip\": 16314, \"lat\": 41.5205, \"long\": -80.0573, \"city_pop\": 5507, \"job\": \"Retail merchandiser\", \"dob\": \"1973-07-28\", \"trans_num\": \"4361d049c378fc83d20dfefe2922b8ee\", \"unix_time\": 1372790741, \"merch_lat\": 40.712188, \"merch_long\": -79.743394, \"is_fraud\": 0, \"merchant_label\": 45, \"category_label\": 7, \"gender_label\": 1, \"job_label\": 402}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=603, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2791, timestamp=1715387587699, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-12 00:50:41\", \"cc_num\": 4599735407877245080, \"merchant\": \"fraud_Cummings LLC\", \"category\": \"gas_transport\", \"amt\": 53.98, \"first\": \"Mary\", \"last\": \"Myers\", \"gender\": \"F\", \"street\": \"39787 Pamela Fall Suite 639\", \"city\": \"Tiptonville\", \"state\": \"TN\", \"zip\": 38079, \"lat\": 36.3846, \"long\": -89.4649, \"city_pop\": 5577, \"job\": \"Geochemist\", \"dob\": \"1964-12-30\", \"trans_num\": \"18dcc652dbc7507223e3684c603801ce\", \"unix_time\": 1373590241, \"merch_lat\": 36.457872, \"merch_long\": -88.774647, \"is_fraud\": 0, \"merchant_label\": 119, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 212}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=612, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2792, timestamp=1715387587701, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-07 16:09:41\", \"cc_num\": 3551217896304745, \"merchant\": \"fraud_Gleason and Sons\", \"category\": \"kids_pets\", \"amt\": 82.14, \"first\": \"Sara\", \"last\": \"Harris\", \"gender\": \"F\", \"street\": \"597 Jenny Ford Apt. 543\", \"city\": \"Tupper Lake\", \"state\": \"NY\", \"zip\": 12986, \"lat\": 44.232, \"long\": -74.4905, \"city_pop\": 6120, \"job\": \"Chartered loss adjuster\", \"dob\": \"1976-10-09\", \"trans_num\": \"cc3648a734c4b688d9b3eb7649ac8ba4\", \"unix_time\": 1370621381, \"merch_lat\": 44.778605, \"merch_long\": -74.560266, \"is_fraud\": 0, \"merchant_label\": 192, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 70}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2793, timestamp=1715387590708, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-24 08:54:42\", \"cc_num\": 341546199006537, \"merchant\": \"fraud_Strosin-Cruickshank\", \"category\": \"grocery_pos\", \"amt\": 151.42, \"first\": \"Mark\", \"last\": \"Brown\", \"gender\": \"M\", \"street\": \"8580 Moore Cove\", \"city\": \"Wales\", \"state\": \"AK\", \"zip\": 99783, \"lat\": 64.7556, \"long\": -165.6723, \"city_pop\": 145, \"job\": \"Administrator, education\", \"dob\": \"1939-11-09\", \"trans_num\": \"a3e9c683c1eca791b41c43bf8624a222\", \"unix_time\": 1343120082, \"merch_lat\": 65.591184, \"merch_long\": -165.506715, \"is_fraud\": 0, \"merchant_label\": 608, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 9}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2794, timestamp=1715387590709, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-18 10:33:24\", \"cc_num\": 30427035050508, \"merchant\": \"fraud_Cremin, Hamill and Reichel\", \"category\": \"misc_pos\", \"amt\": 4.46, \"first\": \"John\", \"last\": \"Chandler\", \"gender\": \"M\", \"street\": \"88325 Brandon Greens Apt. 477\", \"city\": \"Detroit\", \"state\": \"MI\", \"zip\": 48202, \"lat\": 42.377, \"long\": -83.0796, \"city_pop\": 673342, \"job\": \"Broadcast presenter\", \"dob\": \"1969-11-20\", \"trans_num\": \"dc83731468e12feee86b56c7ed0a69f0\", \"unix_time\": 1371551604, \"merch_lat\": 42.333122, \"merch_long\": -83.824033, \"is_fraud\": 0, \"merchant_label\": 110, \"category_label\": 9, \"gender_label\": 1, \"job_label\": 52}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=625, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2795, timestamp=1715387593714, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-12 14:52:27\", \"cc_num\": 38947654498698, \"merchant\": \"fraud_Schmeler, Bashirian and Price\", \"category\": \"shopping_net\", \"amt\": 4.2, \"first\": \"Lori\", \"last\": \"Rodriguez\", \"gender\": \"F\", \"street\": \"12087 Michael Light\", \"city\": \"Creola\", \"state\": \"OH\", \"zip\": 45622, \"lat\": 39.3543, \"long\": -82.50299999999999, \"city_pop\": 321, \"job\": \"Copywriter, advertising\", \"dob\": \"1979-06-24\", \"trans_num\": \"b04237bb4b1a7ae790a077cacbd3d475\", \"unix_time\": 1386859947, \"merch_lat\": 40.217735, \"merch_long\": -83.43672099999999, \"is_fraud\": 0, \"merchant_label\": 555, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 110}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=643, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2796, timestamp=1715387593717, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-02-19 05:41:14\", \"cc_num\": 342952484382519, \"merchant\": \"fraud_Spinka Inc\", \"category\": \"grocery_net\", \"amt\": 97.62, \"first\": \"Kayla\", \"last\": \"Jones\", \"gender\": \"F\", \"street\": \"6033 Young Track Suite 804\", \"city\": \"East Canaan\", \"state\": \"CT\", \"zip\": 6024, \"lat\": 42.0158, \"long\": -73.2913, \"city_pop\": 647, \"job\": \"Comptroller\", \"dob\": \"1987-09-26\", \"trans_num\": \"2fdb6388313419bbb47feb5757fb39bd\", \"unix_time\": 1329630074, \"merch_lat\": 42.852793, \"merch_long\": -73.037099, \"is_fraud\": 0, \"merchant_label\": 588, \"category_label\": 3, \"gender_label\": 0, \"job_label\": 102}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=603, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2797, timestamp=1715387596722, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-22 18:18:27\", \"cc_num\": 6011492816282597, \"merchant\": \"fraud_Botsford PLC\", \"category\": \"home\", \"amt\": 13.48, \"first\": \"Gary\", \"last\": \"Barnes\", \"gender\": \"M\", \"street\": \"2970 Flores Brooks\", \"city\": \"Smackover\", \"state\": \"AR\", \"zip\": 71762, \"lat\": 33.3398, \"long\": -92.7442, \"city_pop\": 2501, \"job\": \"Financial adviser\", \"dob\": \"1986-06-11\", \"trans_num\": \"2abc2ee1c45902219836b0bfd0ebad55\", \"unix_time\": 1348337907, \"merch_lat\": 33.804998, \"merch_long\": -91.815186, \"is_fraud\": 0, \"merchant_label\": 68, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 195}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=596, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2798, timestamp=1715387596723, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-03-02 20:26:12\", \"cc_num\": 3576021480694169, \"merchant\": \"fraud_Satterfield-Lowe\", \"category\": \"travel\", \"amt\": 7.8, \"first\": \"Dawn\", \"last\": \"Gray\", \"gender\": \"F\", \"street\": \"9486 Joel Common Suite 554\", \"city\": \"Topeka\", \"state\": \"KS\", \"zip\": 66618, \"lat\": 39.1329, \"long\": -95.7023, \"city_pop\": 163415, \"job\": \"Secondary school teacher\", \"dob\": \"2004-12-30\", \"trans_num\": \"a2c39db6dfb275b15232cb0114f58e87\", \"unix_time\": 1330719972, \"merch_lat\": 38.542438, \"merch_long\": -94.965014, \"is_fraud\": 0, \"merchant_label\": 544, \"category_label\": 13, \"gender_label\": 0, \"job_label\": 418}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=614, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2799, timestamp=1715387596727, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-27 05:26:08\", \"cc_num\": 4379260813815979609, \"merchant\": \"fraud_Hackett-Lueilwitz\", \"category\": \"grocery_pos\", \"amt\": 55.34, \"first\": \"Thomas\", \"last\": \"Jenkins\", \"gender\": \"M\", \"street\": \"93914 Gregory Via\", \"city\": \"Oakland\", \"state\": \"CA\", \"zip\": 94619, \"lat\": 37.7878, \"long\": -122.1884, \"city_pop\": 381459, \"job\": \"Barista\", \"dob\": \"1974-01-03\", \"trans_num\": \"6b230e6c54ad12c6cddbe9191f60a2a1\", \"unix_time\": 1374902768, \"merch_lat\": 37.242998, \"merch_long\": -121.593465, \"is_fraud\": 0, \"merchant_label\": 217, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 43}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=605, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2800, timestamp=1715387596729, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-28 17:32:19\", \"cc_num\": 4464457352619, \"merchant\": \"fraud_Lesch, D\\'Amore and Brown\", \"category\": \"food_dining\", \"amt\": 25.22, \"first\": \"Breanna\", \"last\": \"Rodriguez\", \"gender\": \"F\", \"street\": \"118 Cabrera Springs Apt. 105\", \"city\": \"Lanark Village\", \"state\": \"FL\", \"zip\": 32323, \"lat\": 29.8826, \"long\": -84.5964, \"city_pop\": 217, \"job\": \"Television production assistant\", \"dob\": \"1990-01-24\", \"trans_num\": \"71769ba9e328ed9bef87e85e9f604f2e\", \"unix_time\": 1343496739, \"merch_lat\": 30.851307, \"merch_long\": -85.530937, \"is_fraud\": 0, \"merchant_label\": 388, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 462}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=647, serialized_header_size=-1)\n",
      "Error in transaction: <Error from server: code=2000 [Syntax error in CQL query] message=\"line 1:145 mismatched input 'Amore' expecting EOF (... INTO bigdata.transaction_data JSON '{\"trans_date_trans_time\": \"2019-07-28 17:32:19\", \"cc_num\": 4464457352619, \"merchant\": \"fraud_Lesch, D'[Amore]...)\">\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2801, timestamp=1715387596731, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-15 17:44:24\", \"cc_num\": 4191109180926792, \"merchant\": \"fraud_Schroeder, Hauck and Treutel\", \"category\": \"entertainment\", \"amt\": 61.14, \"first\": \"Jennifer\", \"last\": \"Spencer\", \"gender\": \"F\", \"street\": \"477 Wheeler Burg\", \"city\": \"Amanda\", \"state\": \"OH\", \"zip\": 43102, \"lat\": 39.6251, \"long\": -82.7552, \"city_pop\": 4512, \"job\": \"Farm manager\", \"dob\": \"1992-10-03\", \"trans_num\": \"9c1999325958be2862f0e5602751f9c3\", \"unix_time\": 1326649464, \"merch_lat\": 39.464694, \"merch_long\": -82.824061, \"is_fraud\": 0, \"merchant_label\": 567, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 191}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2802, timestamp=1715387596735, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-15 04:39:37\", \"cc_num\": 4809701904914, \"merchant\": \"fraud_Simonis-Prohaska\", \"category\": \"misc_pos\", \"amt\": 302.01, \"first\": \"Sabrina\", \"last\": \"Nolan\", \"gender\": \"F\", \"street\": \"312 Eric Expressway Apt. 014\", \"city\": \"Phenix City\", \"state\": \"AL\", \"zip\": 36869, \"lat\": 32.4204, \"long\": -85.0796, \"city_pop\": 59744, \"job\": \"Chemical engineer\", \"dob\": \"1984-02-07\", \"trans_num\": \"5e39e669848edd5e785f4769fb55a357\", \"unix_time\": 1358224777, \"merch_lat\": 31.47314, \"merch_long\": -85.657004, \"is_fraud\": 0, \"merchant_label\": 580, \"category_label\": 9, \"gender_label\": 0, \"job_label\": 72}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2803, timestamp=1715387596737, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-10 12:58:16\", \"cc_num\": 30033162392091, \"merchant\": \"fraud_Larkin, Stracke and Greenfelder\", \"category\": \"entertainment\", \"amt\": 78.19, \"first\": \"Kevin\", \"last\": \"Summers\", \"gender\": \"M\", \"street\": \"7302 Samantha Mission\", \"city\": \"Carroll\", \"state\": \"NE\", \"zip\": 68723, \"lat\": 42.277, \"long\": -97.1926, \"city_pop\": 566, \"job\": \"Metallurgist\", \"dob\": \"1975-01-26\", \"trans_num\": \"9bfcb7ab46d7b06f9df54f8950a9ff60\", \"unix_time\": 1326200296, \"merch_lat\": 42.726735, \"merch_long\": -96.339081, \"is_fraud\": 0, \"merchant_label\": 374, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 297}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=619, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2804, timestamp=1715387596739, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-18 03:16:03\", \"cc_num\": 4430881574719618, \"merchant\": \"fraud_Balistreri-Nader\", \"category\": \"misc_pos\", \"amt\": 6.02, \"first\": \"Alicia\", \"last\": \"Morales\", \"gender\": \"F\", \"street\": \"4456 Dunn Roads\", \"city\": \"Meredith\", \"state\": \"CO\", \"zip\": 81642, \"lat\": 39.3199, \"long\": -106.6596, \"city_pop\": 61, \"job\": \"Public relations account executive\", \"dob\": \"1939-11-04\", \"trans_num\": \"aba79c4831ff4b3c2f9c8866cad51818\", \"unix_time\": 1361157363, \"merch_lat\": 39.52141, \"merch_long\": -106.490972, \"is_fraud\": 0, \"merchant_label\": 21, \"category_label\": 9, \"gender_label\": 0, \"job_label\": 380}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=618, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2805, timestamp=1715387596744, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-28 05:55:48\", \"cc_num\": 3534330126107879, \"merchant\": \"fraud_Bahringer-Larson\", \"category\": \"grocery_net\", \"amt\": 55.03, \"first\": \"Jeffrey\", \"last\": \"Smith\", \"gender\": \"M\", \"street\": \"713 Scott Pike Apt. 712\", \"city\": \"Bridger\", \"state\": \"MT\", \"zip\": 59014, \"lat\": 45.2857, \"long\": -108.9082, \"city_pop\": 1446, \"job\": \"Chartered loss adjuster\", \"dob\": \"1978-01-15\", \"trans_num\": \"5de68926c08e37d2d6008a6962c468fe\", \"unix_time\": 1335592548, \"merch_lat\": 45.148784, \"merch_long\": -108.473331, \"is_fraud\": 0, \"merchant_label\": 18, \"category_label\": 3, \"gender_label\": 1, \"job_label\": 70}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=619, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2806, timestamp=1715387599751, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-03 23:50:56\", \"cc_num\": 4783226709001, \"merchant\": \"fraud_Rolfson-Kunde\", \"category\": \"personal_care\", \"amt\": 40.47, \"first\": \"Jessica\", \"last\": \"Garcia\", \"gender\": \"F\", \"street\": \"13108 Jennifer Passage\", \"city\": \"Mc Cracken\", \"state\": \"KS\", \"zip\": 67556, \"lat\": 38.5957, \"long\": -99.554, \"city_pop\": 320, \"job\": \"Film/video editor\", \"dob\": \"1961-04-22\", \"trans_num\": \"e366ea3cefedb7fcb67138e078f71177\", \"unix_time\": 1375573856, \"merch_lat\": 37.856943, \"merch_long\": -98.770701, \"is_fraud\": 0, \"merchant_label\": 525, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 194}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=611, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2807, timestamp=1715387599752, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-07 21:27:36\", \"cc_num\": 4424338559877976, \"merchant\": \"fraud_Gaylord-Powlowski\", \"category\": \"home\", \"amt\": 7.17, \"first\": \"Denise\", \"last\": \"Barnett\", \"gender\": \"F\", \"street\": \"23220 Eaton Harbors\", \"city\": \"Kirby\", \"state\": \"OH\", \"zip\": 43330, \"lat\": 40.813, \"long\": -83.4196, \"city_pop\": 118, \"job\": \"Private music teacher\", \"dob\": \"1957-11-12\", \"trans_num\": \"609871d89b903376591474d7e07f75c6\", \"unix_time\": 1352323656, \"merch_lat\": 41.555291, \"merch_long\": -83.50836899999999, \"is_fraud\": 0, \"merchant_label\": 187, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 354}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=611, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2808, timestamp=1715387599753, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-10 17:08:58\", \"cc_num\": 371284424780634, \"merchant\": \"fraud_Streich, Rolfson and Wilderman\", \"category\": \"kids_pets\", \"amt\": 154.03, \"first\": \"Jeremy\", \"last\": \"Moore\", \"gender\": \"M\", \"street\": \"574 Patricia Extensions\", \"city\": \"Lubbock\", \"state\": \"TX\", \"zip\": 79413, \"lat\": 33.5466, \"long\": -101.8871, \"city_pop\": 254282, \"job\": \"Doctor, general practice\", \"dob\": \"1952-01-29\", \"trans_num\": \"65c77799bf3e1bcec85b4d603e278525\", \"unix_time\": 1349888938, \"merch_lat\": 33.505517, \"merch_long\": -100.926948, \"is_fraud\": 0, \"merchant_label\": 606, \"category_label\": 7, \"gender_label\": 1, \"job_label\": 134}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=635, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2809, timestamp=1715387599756, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-30 17:14:01\", \"cc_num\": 30273037698427, \"merchant\": \"fraud_Wiza, Schaden and Stark\", \"category\": \"misc_pos\", \"amt\": 170.89, \"first\": \"Andrew\", \"last\": \"Patterson\", \"gender\": \"M\", \"street\": \"06959 Stephen Branch Suite 246\", \"city\": \"Thida\", \"state\": \"AR\", \"zip\": 72165, \"lat\": 35.5762, \"long\": -91.4539, \"city_pop\": 111, \"job\": \"Careers information officer\", \"dob\": \"2000-06-13\", \"trans_num\": \"c7afcbd29fefc55590f9b564620d21c2\", \"unix_time\": 1356887641, \"merch_lat\": 36.061434000000006, \"merch_long\": -92.282623, \"is_fraud\": 0, \"merchant_label\": 677, \"category_label\": 9, \"gender_label\": 1, \"job_label\": 62}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=641, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2810, timestamp=1715387599756, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-07 04:03:32\", \"cc_num\": 180048185037117, \"merchant\": \"fraud_Raynor, Feest and Miller\", \"category\": \"gas_transport\", \"amt\": 62.89, \"first\": \"Mary\", \"last\": \"Wall\", \"gender\": \"F\", \"street\": \"2481 Mills Lock\", \"city\": \"Plainfield\", \"state\": \"NJ\", \"zip\": 7060, \"lat\": 40.6152, \"long\": -74.415, \"city_pop\": 71485, \"job\": \"Leisure centre manager\", \"dob\": \"1974-07-19\", \"trans_num\": \"2c10ab89fb17d3dde8ca0e3bb43cbf10\", \"unix_time\": 1386389012, \"merch_lat\": 40.368539, \"merch_long\": -74.85378, \"is_fraud\": 0, \"merchant_label\": 497, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 269}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2811, timestamp=1715387599758, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-01 10:46:52\", \"cc_num\": 213148039875802, \"merchant\": \"fraud_Schumm, Bauch and Ondricka\", \"category\": \"grocery_pos\", \"amt\": 192.33, \"first\": \"Jill\", \"last\": \"Jacobs\", \"gender\": \"F\", \"street\": \"034 Kimberly Mountains\", \"city\": \"Brandon\", \"state\": \"FL\", \"zip\": 33510, \"lat\": 27.9551, \"long\": -82.2966, \"city_pop\": 79613, \"job\": \"Environmental consultant\", \"dob\": \"1978-11-30\", \"trans_num\": \"f9ae7c1ea321ca2a4219ea8b4c4a21f4\", \"unix_time\": 1351766812, \"merch_lat\": 28.196092, \"merch_long\": -83.080733, \"is_fraud\": 0, \"merchant_label\": 572, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 179}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=628, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2812, timestamp=1715387599759, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-20 20:36:58\", \"cc_num\": 30541100351706, \"merchant\": \"fraud_Towne, Greenholt and Koepp\", \"category\": \"shopping_net\", \"amt\": 7.55, \"first\": \"Derrick\", \"last\": \"George\", \"gender\": \"M\", \"street\": \"575 Chapman Union\", \"city\": \"Spring\", \"state\": \"TX\", \"zip\": 77379, \"lat\": 30.0377, \"long\": -95.5326, \"city_pop\": 316665, \"job\": \"Education officer, museum\", \"dob\": \"1990-09-12\", \"trans_num\": \"f63010f430fedd504dc4d86d0d5612c0\", \"unix_time\": 1340224618, \"merch_lat\": 29.698181, \"merch_long\": -95.566808, \"is_fraud\": 0, \"merchant_label\": 630, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 145}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=626, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2813, timestamp=1715387602808, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-02 21:26:01\", \"cc_num\": 4503101193493052864, \"merchant\": \"fraud_Jast-McDermott\", \"category\": \"shopping_pos\", \"amt\": 4.22, \"first\": \"Katherine\", \"last\": \"Tucker\", \"gender\": \"F\", \"street\": \"670 Le Meadows Suite 250\", \"city\": \"Lakeland\", \"state\": \"FL\", \"zip\": 33811, \"lat\": 27.9865, \"long\": -82.0139, \"city_pop\": 237282, \"job\": \"Clothing/textile technologist\", \"dob\": \"1979-07-03\", \"trans_num\": \"130c987d895f66a69e749d29722599ab\", \"unix_time\": 1386019561, \"merch_lat\": 28.922201, \"merch_long\": -81.162019, \"is_fraud\": 0, \"merchant_label\": 284, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 91}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=633, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2814, timestamp=1715387602811, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-07 15:45:19\", \"cc_num\": 6011104316292105, \"merchant\": \"fraud_Goyette-Gerhold\", \"category\": \"kids_pets\", \"amt\": 28.57, \"first\": \"Valerie\", \"last\": \"Davis\", \"gender\": \"F\", \"street\": \"3861 Anderson Ramp Apt. 536\", \"city\": \"Drakes Branch\", \"state\": \"VA\", \"zip\": 23937, \"lat\": 36.9688, \"long\": -78.5615, \"city_pop\": 1970, \"job\": \"Energy engineer\", \"dob\": \"1985-09-02\", \"trans_num\": \"ad40b61b115d88cc0b226efbb8b8c259\", \"unix_time\": 1349624719, \"merch_lat\": 36.68183, \"merch_long\": -77.670004, \"is_fraud\": 0, \"merchant_label\": 202, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 151}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2815, timestamp=1715387602812, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-21 12:39:42\", \"cc_num\": 3547574373318979, \"merchant\": \"fraud_Spencer PLC\", \"category\": \"entertainment\", \"amt\": 73.86, \"first\": \"Jacob\", \"last\": \"Patel\", \"gender\": \"M\", \"street\": \"54822 Hill Forks\", \"city\": \"Dieterich\", \"state\": \"IL\", \"zip\": 62424, \"lat\": 39.0319, \"long\": -88.4074, \"city_pop\": 2092, \"job\": \"Psychologist, clinical\", \"dob\": \"1962-04-30\", \"trans_num\": \"11cc292c317d3c830cd5f78ec02ab9f5\", \"unix_time\": 1387629582, \"merch_lat\": 39.358255, \"merch_long\": -88.097348, \"is_fraud\": 0, \"merchant_label\": 586, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 371}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=608, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2816, timestamp=1715387605817, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-10 11:55:52\", \"cc_num\": 377264520876399, \"merchant\": \"fraud_Lesch Ltd\", \"category\": \"shopping_pos\", \"amt\": 6.22, \"first\": \"Kara\", \"last\": \"Miles\", \"gender\": \"F\", \"street\": \"2076 Thomas Roads Suite 970\", \"city\": \"Cassatt\", \"state\": \"SC\", \"zip\": 29032, \"lat\": 34.3424, \"long\": -80.5, \"city_pop\": 4424, \"job\": \"Lawyer\", \"dob\": \"1961-07-31\", \"trans_num\": \"6a8d744f15e096bc5950eafe8e903b71\", \"unix_time\": 1360497352, \"merch_lat\": 34.868538, \"merch_long\": -80.401536, \"is_fraud\": 0, \"merchant_label\": 387, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 263}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=593, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2817, timestamp=1715387605818, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-06 14:53:59\", \"cc_num\": 30150717898388, \"merchant\": \"fraud_Weber and Sons\", \"category\": \"food_dining\", \"amt\": 35.49, \"first\": \"Raymond\", \"last\": \"Lloyd\", \"gender\": \"M\", \"street\": \"5930 Rebecca Bridge Apt. 444\", \"city\": \"Paint Rock\", \"state\": \"AL\", \"zip\": 35764, \"lat\": 34.7031, \"long\": -86.3068, \"city_pop\": 653, \"job\": \"Paediatric nurse\", \"dob\": \"1966-06-19\", \"trans_num\": \"70b1916f7190afaadb2fe06b45ef432d\", \"unix_time\": 1365260039, \"merch_lat\": 35.01292, \"merch_long\": -86.465032, \"is_fraud\": 0, \"merchant_label\": 657, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 328}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=614, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2818, timestamp=1715387605819, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-26 17:03:33\", \"cc_num\": 213163860545705, \"merchant\": \"fraud_Bahringer Group\", \"category\": \"health_fitness\", \"amt\": 78.73, \"first\": \"Mark\", \"last\": \"Tyler\", \"gender\": \"M\", \"street\": \"82201 Bradley Radial Suite 703\", \"city\": \"Avera\", \"state\": \"GA\", \"zip\": 30803, \"lat\": 33.141, \"long\": -82.515, \"city_pop\": 741, \"job\": \"Claims inspector/assessor\", \"dob\": \"1986-04-28\", \"trans_num\": \"4521250db632b4d21cd7ed7a5f3da0e2\", \"unix_time\": 1369587813, \"merch_lat\": 32.697776, \"merch_long\": -82.90850999999999, \"is_fraud\": 0, \"merchant_label\": 14, \"category_label\": 5, \"gender_label\": 1, \"job_label\": 86}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=627, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2819, timestamp=1715387605821, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-27 23:55:26\", \"cc_num\": 377993105397617, \"merchant\": \"fraud_Daugherty, Pouros and Beahan\", \"category\": \"shopping_pos\", \"amt\": 1.12, \"first\": \"Nathan\", \"last\": \"Martinez\", \"gender\": \"M\", \"street\": \"586 Thomas Cliffs\", \"city\": \"Oconto Falls\", \"state\": \"WI\", \"zip\": 54154, \"lat\": 44.8755, \"long\": -88.1555, \"city_pop\": 5548, \"job\": \"Mining engineer\", \"dob\": \"1975-09-11\", \"trans_num\": \"9cb24d6b104e2fe47144eb544f8326f8\", \"unix_time\": 1372377326, \"merch_lat\": 44.012053, \"merch_long\": -87.876137, \"is_fraud\": 0, \"merchant_label\": 127, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 299}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=624, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2820, timestamp=1715387605823, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-28 13:08:23\", \"cc_num\": 3527536963490470, \"merchant\": \"fraud_Mueller, Gerhold and Mueller\", \"category\": \"health_fitness\", \"amt\": 99.5, \"first\": \"Teresa\", \"last\": \"Stein\", \"gender\": \"F\", \"street\": \"2838 White Fields Apt. 473\", \"city\": \"Brunson\", \"state\": \"SC\", \"zip\": 29911, \"lat\": 32.9413, \"long\": -81.1807, \"city_pop\": 1725, \"job\": \"Social researcher\", \"dob\": \"1974-12-05\", \"trans_num\": \"7d69128946640aedd56c9fe4a5ffa5e6\", \"unix_time\": 1382965703, \"merch_lat\": 32.836019, \"merch_long\": -81.274626, \"is_fraud\": 0, \"merchant_label\": 445, \"category_label\": 5, \"gender_label\": 0, \"job_label\": 426}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=629, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2821, timestamp=1715387605824, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-27 03:13:16\", \"cc_num\": 6011999606625827, \"merchant\": \"fraud_Murray-Smitham\", \"category\": \"grocery_pos\", \"amt\": 97.17, \"first\": \"Ronald\", \"last\": \"Carson\", \"gender\": \"M\", \"street\": \"870 Rocha Drive\", \"city\": \"Harrington Park\", \"state\": \"NJ\", \"zip\": 7640, \"lat\": 40.9918, \"long\": -73.98, \"city_pop\": 4664, \"job\": \"Radiographer, diagnostic\", \"dob\": \"1965-06-30\", \"trans_num\": \"b099b0fa3a8c12309fe0116190e12034\", \"unix_time\": 1335496396, \"merch_lat\": 40.647243, \"merch_long\": -73.20387099999999, \"is_fraud\": 0, \"merchant_label\": 447, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 388}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=623, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2822, timestamp=1715387605826, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-21 18:22:11\", \"cc_num\": 374930071163758, \"merchant\": \"fraud_Bahringer-Streich\", \"category\": \"food_dining\", \"amt\": 6.21, \"first\": \"Daniel\", \"last\": \"Escobar\", \"gender\": \"M\", \"street\": \"61390 Hayes Port\", \"city\": \"Romulus\", \"state\": \"MI\", \"zip\": 48174, \"lat\": 42.2203, \"long\": -83.3583, \"city_pop\": 31515, \"job\": \"Police officer\", \"dob\": \"1971-11-05\", \"trans_num\": \"ff277c65705a58df6b0fcf4cd6b9a3d7\", \"unix_time\": 1356114131, \"merch_lat\": 41.624442, \"merch_long\": -82.75703100000001, \"is_fraud\": 0, \"merchant_label\": 19, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 347}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=611, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2823, timestamp=1715387605827, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-27 12:46:06\", \"cc_num\": 6593939509150446, \"merchant\": \"fraud_Dare, Fritsch and Zboncak\", \"category\": \"health_fitness\", \"amt\": 45.28, \"first\": \"Margaret\", \"last\": \"Ward\", \"gender\": \"F\", \"street\": \"244 Jeffery Rapids\", \"city\": \"Azusa\", \"state\": \"CA\", \"zip\": 91702, \"lat\": 34.1248, \"long\": -117.9031, \"city_pop\": 59705, \"job\": \"Civil Service fast streamer\", \"dob\": \"1983-06-23\", \"trans_num\": \"22dd7cd83d645c69568dae59e0bc0a2a\", \"unix_time\": 1361969166, \"merch_lat\": 34.091649, \"merch_long\": -117.214567, \"is_fraud\": 0, \"merchant_label\": 123, \"category_label\": 5, \"gender_label\": 0, \"job_label\": 84}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=630, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2824, timestamp=1715387605829, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-05-31 06:47:37\", \"cc_num\": 6547670341037171, \"merchant\": \"fraud_Kerluke Inc\", \"category\": \"misc_net\", \"amt\": 8.02, \"first\": \"Bryce\", \"last\": \"Joseph\", \"gender\": \"M\", \"street\": \"148 Baker Field\", \"city\": \"Chester Heights\", \"state\": \"PA\", \"zip\": 19017, \"lat\": 39.8839, \"long\": -75.4669, \"city_pop\": 348, \"job\": \"Management consultant\", \"dob\": \"1945-05-05\", \"trans_num\": \"f96a5d3b1841be2e78d41ac76f3b86da\", \"unix_time\": 1338446857, \"merch_lat\": 40.008766, \"merch_long\": -75.119569, \"is_fraud\": 0, \"merchant_label\": 300, \"category_label\": 8, \"gender_label\": 1, \"job_label\": 282}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=606, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2825, timestamp=1715387605831, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-10 06:50:56\", \"cc_num\": 502012776709, \"merchant\": \"fraud_Rau and Sons\", \"category\": \"grocery_pos\", \"amt\": 138.36, \"first\": \"Sherry\", \"last\": \"Martinez\", \"gender\": \"F\", \"street\": \"144 Yu Locks Apt. 754\", \"city\": \"Garrattsville\", \"state\": \"NY\", \"zip\": 13342, \"lat\": 42.6315, \"long\": -75.1866, \"city_pop\": 165, \"job\": \"Naval architect\", \"dob\": \"1945-09-20\", \"trans_num\": \"bbaf0896661cde4965ee0f769be5bc79\", \"unix_time\": 1373439056, \"merch_lat\": 43.045851, \"merch_long\": -76.0693, \"is_fraud\": 0, \"merchant_label\": 494, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 309}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2826, timestamp=1715387608836, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-05 00:21:40\", \"cc_num\": 4451438912406400, \"merchant\": \"fraud_Luettgen PLC\", \"category\": \"gas_transport\", \"amt\": 71.7, \"first\": \"Cheryl\", \"last\": \"Morgan\", \"gender\": \"F\", \"street\": \"7535 Amanda Manors Suite 293\", \"city\": \"Norman\", \"state\": \"AR\", \"zip\": 71960, \"lat\": 34.4596, \"long\": -93.6743, \"city_pop\": 1383, \"job\": \"Manufacturing engineer\", \"dob\": \"1999-09-11\", \"trans_num\": \"61a64ed3d18e3ff702b091755839e280\", \"unix_time\": 1357345300, \"merch_lat\": 34.814002, \"merch_long\": -93.697886, \"is_fraud\": 0, \"merchant_label\": 399, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 283}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=619, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2827, timestamp=1715387608837, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-12 15:19:44\", \"cc_num\": 30135235368675, \"merchant\": \"fraud_Kilback and Sons\", \"category\": \"entertainment\", \"amt\": 115.39, \"first\": \"Amanda\", \"last\": \"Williams\", \"gender\": \"F\", \"street\": \"02018 Gary Key Apt. 911\", \"city\": \"Independence\", \"state\": \"MO\", \"zip\": 64058, \"lat\": 39.1412, \"long\": -94.3515, \"city_pop\": 123373, \"job\": \"Engineer, production\", \"dob\": \"1992-11-27\", \"trans_num\": \"4a39c81a5ac80b75aa46082114b031a8\", \"unix_time\": 1381591184, \"merch_lat\": 39.879467, \"merch_long\": -93.876971, \"is_fraud\": 0, \"merchant_label\": 317, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 171}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=626, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2828, timestamp=1715387608838, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-22 06:04:25\", \"cc_num\": 4972228199573984, \"merchant\": \"fraud_Fisher Inc\", \"category\": \"shopping_net\", \"amt\": 1.39, \"first\": \"Brian\", \"last\": \"Hogan\", \"gender\": \"M\", \"street\": \"3316 Cindy Land\", \"city\": \"Lane\", \"state\": \"OK\", \"zip\": 74555, \"lat\": 34.2691, \"long\": -95.9685, \"city_pop\": 861, \"job\": \"Quantity surveyor\", \"dob\": \"1960-04-08\", \"trans_num\": \"6749bef7b32912d5a754f5a791d41483\", \"unix_time\": 1361513065, \"merch_lat\": 34.940636, \"merch_long\": -95.360128, \"is_fraud\": 0, \"merchant_label\": 174, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 383}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=594, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2829, timestamp=1715387608839, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-04 01:12:14\", \"cc_num\": 630423337322, \"merchant\": \"fraud_Raynor, Reinger and Hagenes\", \"category\": \"gas_transport\", \"amt\": 72.32, \"first\": \"Stephanie\", \"last\": \"Gill\", \"gender\": \"F\", \"street\": \"43039 Riley Greens Suite 393\", \"city\": \"Orient\", \"state\": \"WA\", \"zip\": 99160, \"lat\": 48.8878, \"long\": -118.2105, \"city_pop\": 149, \"job\": \"Special educational needs teacher\", \"dob\": \"1978-06-21\", \"trans_num\": \"449f4c95a5053a44469e46db7ad8ca9c\", \"unix_time\": 1372900334, \"merch_lat\": 48.716244, \"merch_long\": -119.126688, \"is_fraud\": 0, \"merchant_label\": 498, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 431}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=644, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2830, timestamp=1715387608841, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-20 20:20:04\", \"cc_num\": 340953839692349, \"merchant\": \"fraud_Eichmann-Kilback\", \"category\": \"home\", \"amt\": 18.35, \"first\": \"Tyler\", \"last\": \"Wright\", \"gender\": \"M\", \"street\": \"615 Clarke Spring Apt. 172\", \"city\": \"Warren\", \"state\": \"MI\", \"zip\": 48088, \"lat\": 42.5164, \"long\": -82.9832, \"city_pop\": 134056, \"job\": \"Doctor, hospital\", \"dob\": \"1980-05-18\", \"trans_num\": \"9e1028c98ff0a8c0a039d832a16c0dcd\", \"unix_time\": 1361391604, \"merch_lat\": 41.890346, \"merch_long\": -82.214574, \"is_fraud\": 0, \"merchant_label\": 155, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 135}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2831, timestamp=1715387611847, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-26 14:36:48\", \"cc_num\": 2224100459250597, \"merchant\": \"fraud_Schmeler-Howe\", \"category\": \"personal_care\", \"amt\": 40.44, \"first\": \"Sheri\", \"last\": \"Thomas\", \"gender\": \"F\", \"street\": \"019 Kimberly Light Apt. 039\", \"city\": \"Kings Bay\", \"state\": \"GA\", \"zip\": 31547, \"lat\": 30.7906, \"long\": -81.5607, \"city_pop\": 1293, \"job\": \"Naval architect\", \"dob\": \"1963-09-11\", \"trans_num\": \"f1076e3357b5e9f10036df650cd169ca\", \"unix_time\": 1382798208, \"merch_lat\": 30.012687, \"merch_long\": -81.098675, \"is_fraud\": 0, \"merchant_label\": 556, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 309}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2832, timestamp=1715387611847, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-17 19:13:15\", \"cc_num\": 3597926034019603, \"merchant\": \"fraud_Hermiston, Russel and Price\", \"category\": \"food_dining\", \"amt\": 15.7, \"first\": \"Derrick\", \"last\": \"Flores\", \"gender\": \"M\", \"street\": \"83690 Nicholas Ports Apt. 846\", \"city\": \"Oakland\", \"state\": \"TN\", \"zip\": 38060, \"lat\": 35.2229, \"long\": -89.5518, \"city_pop\": 9496, \"job\": \"Furniture conservator/restorer\", \"dob\": \"1993-03-23\", \"trans_num\": \"9b358741f594d9821af5ac67fc1412e4\", \"unix_time\": 1347909195, \"merch_lat\": 34.387675, \"merch_long\": -89.3894, \"is_fraud\": 0, \"merchant_label\": 249, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 204}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=641, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2833, timestamp=1715387611849, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-14 20:28:08\", \"cc_num\": 213161293389774, \"merchant\": \"fraud_Ritchie, Bradtke and Stiedemann\", \"category\": \"travel\", \"amt\": 8.9, \"first\": \"Catherine\", \"last\": \"Weber\", \"gender\": \"F\", \"street\": \"74890 Rodriguez Springs Apt. 540\", \"city\": \"West Henrietta\", \"state\": \"NY\", \"zip\": 14586, \"lat\": 43.0397, \"long\": -77.6871, \"city_pop\": 10256, \"job\": \"Teacher, primary school\", \"dob\": \"1968-06-24\", \"trans_num\": \"7cd203991eeb08dc5bd03feae765418d\", \"unix_time\": 1387052888, \"merch_lat\": 42.462156, \"merch_long\": -77.527694, \"is_fraud\": 0, \"merchant_label\": 516, \"category_label\": 13, \"gender_label\": 0, \"job_label\": 454}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=646, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2834, timestamp=1715387611850, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-11 22:47:02\", \"cc_num\": 6011975266774121, \"merchant\": \"fraud_O\\'Connell, Botsford and Hand\", \"category\": \"home\", \"amt\": 15.15, \"first\": \"Haley\", \"last\": \"Wagner\", \"gender\": \"F\", \"street\": \"05561 Farrell Crescent\", \"city\": \"Annapolis\", \"state\": \"MD\", \"zip\": 21405, \"lat\": 39.0305, \"long\": -76.5515, \"city_pop\": 92106, \"job\": \"Accountant, chartered certified\", \"dob\": \"1943-05-28\", \"trans_num\": \"c3a6859fa01138b71d78c8d3f4aacac1\", \"unix_time\": 1376261222, \"merch_lat\": 38.120343, \"merch_long\": -76.682767, \"is_fraud\": 0, \"merchant_label\": 456, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 2}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=631, serialized_header_size=-1)\n",
      "Error in transaction: <Error from server: code=2000 [Syntax error in CQL query] message=\"line 1:141 mismatched input 'Connell' expecting EOF (... INTO bigdata.transaction_data JSON '{\"trans_date_trans_time\": \"2020-08-11 22:47:02\", \"cc_num\": 6011975266774121, \"merchant\": \"fraud_O'[Connell]...)\">\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2835, timestamp=1715387611853, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-02-08 11:12:30\", \"cc_num\": 4365382885912355, \"merchant\": \"fraud_Towne LLC\", \"category\": \"misc_pos\", \"amt\": 34.94, \"first\": \"Robert\", \"last\": \"Goodman\", \"gender\": \"M\", \"street\": \"956 Paul Fields Suite 108\", \"city\": \"Orr\", \"state\": \"MN\", \"zip\": 55771, \"lat\": 48.1439, \"long\": -92.8561, \"city_pop\": 1680, \"job\": \"Horticultural therapist\", \"dob\": \"1976-12-10\", \"trans_num\": \"261b2907a2088c4c48aa1fec99057643\", \"unix_time\": 1328699550, \"merch_lat\": 48.456441, \"merch_long\": -92.22655, \"is_fraud\": 0, \"merchant_label\": 629, \"category_label\": 9, \"gender_label\": 1, \"job_label\": 230}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2836, timestamp=1715387611854, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-05 22:39:10\", \"cc_num\": 3593399694467427, \"merchant\": \"fraud_Hauck, Dietrich and Funk\", \"category\": \"kids_pets\", \"amt\": 13.79, \"first\": \"Douglas\", \"last\": \"Smith\", \"gender\": \"M\", \"street\": \"85932 Marc Throughway Apt. 080\", \"city\": \"Knowlesville\", \"state\": \"NY\", \"zip\": 14479, \"lat\": 43.2363, \"long\": -78.3138, \"city_pop\": 275, \"job\": \"TEFL teacher\", \"dob\": \"1964-08-18\", \"trans_num\": \"6f4e235508e2ca66894d69f61771ea76\", \"unix_time\": 1367793550, \"merch_lat\": 43.59489, \"merch_long\": -78.390518, \"is_fraud\": 0, \"merchant_label\": 234, \"category_label\": 7, \"gender_label\": 1, \"job_label\": 448}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=624, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2837, timestamp=1715387611856, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-12 03:42:41\", \"cc_num\": 571365235126, \"merchant\": \"fraud_Rodriguez Group\", \"category\": \"gas_transport\", \"amt\": 59.98, \"first\": \"Barbara\", \"last\": \"Taylor\", \"gender\": \"F\", \"street\": \"0069 Robin Brooks Apt. 695\", \"city\": \"Elberta\", \"state\": \"MI\", \"zip\": 49628, \"lat\": 44.5995, \"long\": -86.2141, \"city_pop\": 372, \"job\": \"Exhibitions officer, museum/gallery\", \"dob\": \"1995-07-12\", \"trans_num\": \"fb100ac63475e45002d08f3d82c8b13a\", \"unix_time\": 1386819761, \"merch_lat\": 44.84676, \"merch_long\": -87.035202, \"is_fraud\": 0, \"merchant_label\": 522, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 189}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=630, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2838, timestamp=1715387611857, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-03-06 01:11:55\", \"cc_num\": 3519607465576254, \"merchant\": \"fraud_Reichert, Rowe and Mraz\", \"category\": \"shopping_net\", \"amt\": 9.09, \"first\": \"Audrey\", \"last\": \"Gonzalez\", \"gender\": \"F\", \"street\": \"34180 Lopez Plaza\", \"city\": \"Fields Landing\", \"state\": \"CA\", \"zip\": 95537, \"lat\": 40.7268, \"long\": -124.2174, \"city_pop\": 276, \"job\": \"Scientist, audiological\", \"dob\": \"1929-05-06\", \"trans_num\": \"d768467504a9dcca83de9957f8e46e46\", \"unix_time\": 1330996315, \"merch_lat\": 41.694809, \"merch_long\": -124.690131, \"is_fraud\": 0, \"merchant_label\": 503, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 410}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=631, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2839, timestamp=1715387611860, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-23 12:00:43\", \"cc_num\": 213148039875802, \"merchant\": \"fraud_Padberg-Sauer\", \"category\": \"home\", \"amt\": 20.24, \"first\": \"Jill\", \"last\": \"Jacobs\", \"gender\": \"F\", \"street\": \"034 Kimberly Mountains\", \"city\": \"Brandon\", \"state\": \"FL\", \"zip\": 33510, \"lat\": 27.9551, \"long\": -82.2966, \"city_pop\": 79613, \"job\": \"Environmental consultant\", \"dob\": \"1978-11-30\", \"trans_num\": \"038acb47218b6ec815b35040e92e1e7e\", \"unix_time\": 1340452843, \"merch_lat\": 28.778296, \"merch_long\": -82.582143, \"is_fraud\": 0, \"merchant_label\": 471, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 179}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2840, timestamp=1715387611861, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-03 03:23:07\", \"cc_num\": 4666314527820883145, \"merchant\": \"fraud_Miller-Hauck\", \"category\": \"grocery_pos\", \"amt\": 88.47, \"first\": \"Guy\", \"last\": \"Thompson\", \"gender\": \"M\", \"street\": \"5812 Ramos Oval Suite 598\", \"city\": \"Ravenna\", \"state\": \"NE\", \"zip\": 68869, \"lat\": 41.0233, \"long\": -98.9041, \"city_pop\": 2202, \"job\": \"Solicitor, Scotland\", \"dob\": \"1974-06-21\", \"trans_num\": \"524bccaa03047b2a12e3a596217f03f9\", \"unix_time\": 1359861787, \"merch_lat\": 40.267563, \"merch_long\": -98.281404, \"is_fraud\": 0, \"merchant_label\": 427, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 430}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=615, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2841, timestamp=1715387614869, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-11-01 00:52:08\", \"cc_num\": 4957924165498, \"merchant\": \"fraud_Kerluke-Abshire\", \"category\": \"shopping_net\", \"amt\": 2.72, \"first\": \"Alan\", \"last\": \"Parsons\", \"gender\": \"M\", \"street\": \"0547 Russell Ford Suite 574\", \"city\": \"Kirk\", \"state\": \"CO\", \"zip\": 80824, \"lat\": 39.6171, \"long\": -102.4776, \"city_pop\": 207, \"job\": \"Network engineer\", \"dob\": \"1955-12-04\", \"trans_num\": \"5354db77ca640192adff2d8d53311265\", \"unix_time\": 1383267128, \"merch_lat\": 39.89469, \"merch_long\": -102.407633, \"is_fraud\": 0, \"merchant_label\": 304, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 310}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2842, timestamp=1715387614871, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-15 03:22:30\", \"cc_num\": 3560797065840735, \"merchant\": \"fraud_Friesen-D\\'Amore\", \"category\": \"gas_transport\", \"amt\": 27.74, \"first\": \"Janet\", \"last\": \"Turner\", \"gender\": \"F\", \"street\": \"0925 Lang Extensions\", \"city\": \"Shields\", \"state\": \"ND\", \"zip\": 58569, \"lat\": 46.1838, \"long\": -101.2589, \"city_pop\": 77, \"job\": \"Film/video editor\", \"dob\": \"1989-12-17\", \"trans_num\": \"1b29ffe846d635dbb101c73729621954\", \"unix_time\": 1381807350, \"merch_lat\": 45.727239, \"merch_long\": -100.262251, \"is_fraud\": 0, \"merchant_label\": 181, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 194}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=610, serialized_header_size=-1)\n",
      "Error in transaction: <Error from server: code=2000 [Syntax error in CQL query] message=\"line 1:149 mismatched input 'Amore' expecting EOF (... INTO bigdata.transaction_data JSON '{\"trans_date_trans_time\": \"2020-10-15 03:22:30\", \"cc_num\": 3560797065840735, \"merchant\": \"fraud_Friesen-D'[Amore]...)\">\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2843, timestamp=1715387614874, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-08 07:55:29\", \"cc_num\": 3577794103155425, \"merchant\": \"fraud_Auer-Mosciski\", \"category\": \"grocery_pos\", \"amt\": 79.75, \"first\": \"Mary\", \"last\": \"Humphrey\", \"gender\": \"F\", \"street\": \"9853 Flynn Hollow Apt. 602\", \"city\": \"Reynolds\", \"state\": \"ND\", \"zip\": 58275, \"lat\": 47.7068, \"long\": -97.2092, \"city_pop\": 733, \"job\": \"Visual merchandiser\", \"dob\": \"1994-11-12\", \"trans_num\": \"16ea582ed92c935ae6c0a53a54a14794\", \"unix_time\": 1349682929, \"merch_lat\": 47.171739, \"merch_long\": -96.792726, \"is_fraud\": 0, \"merchant_label\": 12, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 487}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=614, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2844, timestamp=1715387614876, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-27 00:34:49\", \"cc_num\": 4277232699798846, \"merchant\": \"fraud_Doyle Ltd\", \"category\": \"grocery_pos\", \"amt\": 149.12, \"first\": \"Jennifer\", \"last\": \"Vance\", \"gender\": \"F\", \"street\": \"13299 Patrick Terrace\", \"city\": \"Rhame\", \"state\": \"ND\", \"zip\": 58651, \"lat\": 46.1664, \"long\": -103.7079, \"city_pop\": 475, \"job\": \"Illustrator\", \"dob\": \"1955-11-10\", \"trans_num\": \"4cc969942b3c9bc692fa7cae7007d8dc\", \"unix_time\": 1369614889, \"merch_lat\": 45.249048, \"merch_long\": -103.20631, \"is_fraud\": 0, \"merchant_label\": 146, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 241}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=598, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2845, timestamp=1715387614879, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-24 18:31:19\", \"cc_num\": 36722699017270, \"merchant\": \"fraud_Rau-Robel\", \"category\": \"kids_pets\", \"amt\": 10.17, \"first\": \"Jessica\", \"last\": \"Perez\", \"gender\": \"F\", \"street\": \"8172 Robertson Parkways Suite 072\", \"city\": \"Superior\", \"state\": \"AZ\", \"zip\": 85173, \"lat\": 33.2887, \"long\": -111.0985, \"city_pop\": 2872, \"job\": \"Petroleum engineer\", \"dob\": \"1987-10-28\", \"trans_num\": \"5e1d68226fc9d2b6a182e1d3f83d5c3d\", \"unix_time\": 1364149879, \"merch_lat\": 33.638678000000006, \"merch_long\": -111.382863, \"is_fraud\": 0, \"merchant_label\": 496, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 335}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=625, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2846, timestamp=1715387614880, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-21 09:46:51\", \"cc_num\": 4855488158131690372, \"merchant\": \"fraud_Mosciski, Gislason and Mertz\", \"category\": \"grocery_pos\", \"amt\": 96.05, \"first\": \"Jeremy\", \"last\": \"Roberson\", \"gender\": \"M\", \"street\": \"25887 Martin Inlet\", \"city\": \"Graniteville\", \"state\": \"VT\", \"zip\": 5654, \"lat\": 44.1554, \"long\": -72.4847, \"city_pop\": 970, \"job\": \"Agricultural consultant\", \"dob\": \"1993-09-29\", \"trans_num\": \"e2a7021c602b62dabea4d4be79537616\", \"unix_time\": 1358761611, \"merch_lat\": 44.841022, \"merch_long\": -72.35401800000001, \"is_fraud\": 0, \"merchant_label\": 442, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 16}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=641, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2847, timestamp=1715387614883, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-03 21:22:14\", \"cc_num\": 4873783502705038, \"merchant\": \"fraud_Hilpert-Conroy\", \"category\": \"kids_pets\", \"amt\": 30.69, \"first\": \"Elizabeth\", \"last\": \"Maxwell\", \"gender\": \"F\", \"street\": \"194 Goodman Fall Apt. 569\", \"city\": \"Burlington\", \"state\": \"WA\", \"zip\": 98233, \"lat\": 48.4786, \"long\": -122.3345, \"city_pop\": 14871, \"job\": \"Public house manager\", \"dob\": \"1974-03-10\", \"trans_num\": \"9af347afcab8eb18b9158926ea15b91b\", \"unix_time\": 1351977734, \"merch_lat\": 49.042438, \"merch_long\": -121.966238, \"is_fraud\": 0, \"merchant_label\": 257, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 378}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=624, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2848, timestamp=1715387614886, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-05-08 18:00:51\", \"cc_num\": 3501509250702469, \"merchant\": \"fraud_Schulist Ltd\", \"category\": \"food_dining\", \"amt\": 1.96, \"first\": \"Frank\", \"last\": \"Anderson\", \"gender\": \"M\", \"street\": \"0611 Stafford Valley Suite 504\", \"city\": \"Naples\", \"state\": \"FL\", \"zip\": 34112, \"lat\": 26.1184, \"long\": -81.7361, \"city_pop\": 276002, \"job\": \"Programme researcher, broadcasting/film/video\", \"dob\": \"1979-01-02\", \"trans_num\": \"f46bec3586cb8690784b99c03048d0be\", \"unix_time\": 1336500051, \"merch_lat\": 25.984234, \"merch_long\": -82.655188, \"is_fraud\": 0, \"merchant_label\": 569, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 366}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=645, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2849, timestamp=1715387617897, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-30 07:10:15\", \"cc_num\": 630441765090, \"merchant\": \"fraud_Bernier, Volkman and Hoeger\", \"category\": \"misc_net\", \"amt\": 360.08, \"first\": \"Susan\", \"last\": \"Washington\", \"gender\": \"F\", \"street\": \"759 Erin Mount Suite 956\", \"city\": \"May\", \"state\": \"TX\", \"zip\": 76857, \"lat\": 31.9571, \"long\": -98.9656, \"city_pop\": 1791, \"job\": \"Corporate investment banker\", \"dob\": \"1965-07-26\", \"trans_num\": \"d9908b191066b8f047abf9e305165e25\", \"unix_time\": 1375168215, \"merch_lat\": 31.799572, \"merch_long\": -98.292683, \"is_fraud\": 0, \"merchant_label\": 52, \"category_label\": 8, \"gender_label\": 0, \"job_label\": 111}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=627, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2850, timestamp=1715387617898, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-31 14:56:21\", \"cc_num\": 3560725013359375, \"merchant\": \"fraud_Daugherty-Thompson\", \"category\": \"food_dining\", \"amt\": 20.52, \"first\": \"Brooke\", \"last\": \"Smith\", \"gender\": \"F\", \"street\": \"63542 Luna Brook Apt. 012\", \"city\": \"Notrees\", \"state\": \"TX\", \"zip\": 79759, \"lat\": 31.8599, \"long\": -102.7413, \"city_pop\": 23, \"job\": \"Cytogeneticist\", \"dob\": \"1969-09-15\", \"trans_num\": \"258d3928f3bb0032b42e51cdfe71ae94\", \"unix_time\": 1388501781, \"merch_lat\": 32.665440000000004, \"merch_long\": -103.518206, \"is_fraud\": 0, \"merchant_label\": 128, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 115}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=622, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2851, timestamp=1715387617900, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-27 01:05:56\", \"cc_num\": 4740713119940984, \"merchant\": \"fraud_Boehm, Predovic and Reinger\", \"category\": \"misc_pos\", \"amt\": 516.02, \"first\": \"Heather\", \"last\": \"Hines\", \"gender\": \"F\", \"street\": \"13776 Hicks Plains\", \"city\": \"Pomona\", \"state\": \"NY\", \"zip\": 10970, \"lat\": 41.1901, \"long\": -74.0436, \"city_pop\": 9993, \"job\": \"Pensions consultant\", \"dob\": \"1962-10-16\", \"trans_num\": \"6f50e3b858dc556821516e9ade4ba47d\", \"unix_time\": 1359248756, \"merch_lat\": 41.845283, \"merch_long\": -73.323925, \"is_fraud\": 0, \"merchant_label\": 63, \"category_label\": 9, \"gender_label\": 0, \"job_label\": 333}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2852, timestamp=1715387617902, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-23 18:06:32\", \"cc_num\": 4170689372027579, \"merchant\": \"fraud_Schmeler Inc\", \"category\": \"misc_pos\", \"amt\": 1.69, \"first\": \"Samuel\", \"last\": \"Frey\", \"gender\": \"M\", \"street\": \"830 Myers Plaza Apt. 384\", \"city\": \"Edmond\", \"state\": \"OK\", \"zip\": 73034, \"lat\": 35.6665, \"long\": -97.4798, \"city_pop\": 116001, \"job\": \"Media buyer\", \"dob\": \"1993-05-10\", \"trans_num\": \"1ff36a4c04a1b921a95e8473f172aa99\", \"unix_time\": 1361642792, \"merch_lat\": 34.864422, \"merch_long\": -97.942931, \"is_fraud\": 0, \"merchant_label\": 554, \"category_label\": 9, \"gender_label\": 1, \"job_label\": 289}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=599, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2853, timestamp=1715387617906, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-27 23:01:51\", \"cc_num\": 3534330126107879, \"merchant\": \"fraud_Stark-Koss\", \"category\": \"home\", \"amt\": 74.77, \"first\": \"Jeffrey\", \"last\": \"Smith\", \"gender\": \"M\", \"street\": \"713 Scott Pike Apt. 712\", \"city\": \"Bridger\", \"state\": \"MT\", \"zip\": 59014, \"lat\": 45.2857, \"long\": -108.9082, \"city_pop\": 1446, \"job\": \"Chartered loss adjuster\", \"dob\": \"1978-01-15\", \"trans_num\": \"28dbc616650e79b18a5b72d70ffc892b\", \"unix_time\": 1351378911, \"merch_lat\": 44.690488, \"merch_long\": -109.372183, \"is_fraud\": 0, \"merchant_label\": 596, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 70}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2854, timestamp=1715387617909, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-29 18:50:22\", \"cc_num\": 4797297220948468262, \"merchant\": \"fraud_Haley, Jewess and Bechtelar\", \"category\": \"shopping_pos\", \"amt\": 1.26, \"first\": \"Erica\", \"last\": \"Briggs\", \"gender\": \"F\", \"street\": \"3310 Davidson Spurs Apt. 107\", \"city\": \"Oolitic\", \"state\": \"IN\", \"zip\": 47451, \"lat\": 38.8938, \"long\": -86.5246, \"city_pop\": 1228, \"job\": \"Counsellor\", \"dob\": \"1991-03-13\", \"trans_num\": \"5557500792eeac88bb893d9af54d8536\", \"unix_time\": 1377802222, \"merch_lat\": 38.790694, \"merch_long\": -86.347701, \"is_fraud\": 0, \"merchant_label\": 224, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 113}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=625, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2855, timestamp=1715387617911, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-11 09:47:03\", \"cc_num\": 213161231269724, \"merchant\": \"fraud_Eichmann, Bogan and Rodriguez\", \"category\": \"gas_transport\", \"amt\": 67.59, \"first\": \"Alyssa\", \"last\": \"Morgan\", \"gender\": \"F\", \"street\": \"622 Robin Run Suite 764\", \"city\": \"Gadsden\", \"state\": \"AL\", \"zip\": 35901, \"lat\": 34.048, \"long\": -85.9246, \"city_pop\": 67082, \"job\": \"Physiological scientist\", \"dob\": \"1963-02-09\", \"trans_num\": \"feb49e05d090b634d76bb14c06dd010c\", \"unix_time\": 1352627223, \"merch_lat\": 33.244628000000006, \"merch_long\": -85.112125, \"is_fraud\": 0, \"merchant_label\": 153, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 340}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=642, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2856, timestamp=1715387617914, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-05-23 01:43:23\", \"cc_num\": 4988304376504, \"merchant\": \"fraud_Gerlach Inc\", \"category\": \"shopping_net\", \"amt\": 2.1, \"first\": \"William\", \"last\": \"Thompson\", \"gender\": \"M\", \"street\": \"977 Rita Grove Apt. 000\", \"city\": \"Rock Tavern\", \"state\": \"NY\", \"zip\": 12575, \"lat\": 41.4575, \"long\": -74.1659, \"city_pop\": 2258, \"job\": \"Building surveyor\", \"dob\": \"1937-03-17\", \"trans_num\": \"176b0cfea2c57633362604528417f384\", \"unix_time\": 1337737403, \"merch_lat\": 40.925648, \"merch_long\": -74.717354, \"is_fraud\": 0, \"merchant_label\": 189, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 55}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=611, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2857, timestamp=1715387617917, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-29 23:22:43\", \"cc_num\": 213126662687660, \"merchant\": \"fraud_Lakin, Ferry and Beatty\", \"category\": \"food_dining\", \"amt\": 4.28, \"first\": \"Christopher\", \"last\": \"Luna\", \"gender\": \"M\", \"street\": \"242 Brian Mountain\", \"city\": \"Laredo\", \"state\": \"TX\", \"zip\": 78040, \"lat\": 27.5155, \"long\": -99.4986, \"city_pop\": 248858, \"job\": \"Video editor\", \"dob\": \"1971-01-28\", \"trans_num\": \"5ac29967b965b87dcba5bae0940b0091\", \"unix_time\": 1364599363, \"merch_lat\": 27.963947, \"merch_long\": -98.566904, \"is_fraud\": 0, \"merchant_label\": 368, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 486}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=612, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2858, timestamp=1715387620924, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-11-23 13:05:13\", \"cc_num\": 4683638447911, \"merchant\": \"fraud_Berge-Ullrich\", \"category\": \"home\", \"amt\": 67.13, \"first\": \"Daniel\", \"last\": \"Boyd\", \"gender\": \"M\", \"street\": \"8925 Nicholas Points\", \"city\": \"Egan\", \"state\": \"LA\", \"zip\": 70531, \"lat\": 30.251, \"long\": -92.5002, \"city_pop\": 1261, \"job\": \"Broadcast presenter\", \"dob\": \"1972-07-01\", \"trans_num\": \"d107126413df8aa86346d572df8f0a43\", \"unix_time\": 1385211913, \"merch_lat\": 29.935836, \"merch_long\": -92.035291, \"is_fraud\": 0, \"merchant_label\": 46, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 52}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=591, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2859, timestamp=1715387620926, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-04 19:35:06\", \"cc_num\": 6011109736646996, \"merchant\": \"fraud_Schroeder, Wolff and Hermiston\", \"category\": \"travel\", \"amt\": 2.45, \"first\": \"Rebecca\", \"last\": \"Erickson\", \"gender\": \"F\", \"street\": \"594 Berry Lights Apt. 392\", \"city\": \"Wilmington\", \"state\": \"NC\", \"zip\": 28405, \"lat\": 34.2651, \"long\": -77.867, \"city_pop\": 186140, \"job\": \"English as a second language teacher\", \"dob\": \"1983-02-08\", \"trans_num\": \"b6ef79d14293be9d96423c3f98b3ff30\", \"unix_time\": 1367696106, \"merch_lat\": 33.403866, \"merch_long\": -77.697404, \"is_fraud\": 0, \"merchant_label\": 568, \"category_label\": 13, \"gender_label\": 0, \"job_label\": 178}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=650, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2860, timestamp=1715387620927, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-14 06:02:52\", \"cc_num\": 3560725013359375, \"merchant\": \"fraud_Greenholt, Jacobi and Gleason\", \"category\": \"gas_transport\", \"amt\": 53.99, \"first\": \"Brooke\", \"last\": \"Smith\", \"gender\": \"F\", \"street\": \"63542 Luna Brook Apt. 012\", \"city\": \"Notrees\", \"state\": \"TX\", \"zip\": 79759, \"lat\": 31.8599, \"long\": -102.7413, \"city_pop\": 23, \"job\": \"Cytogeneticist\", \"dob\": \"1969-09-15\", \"trans_num\": \"beffa5d75879e7e366914bcdbdf86685\", \"unix_time\": 1379138572, \"merch_lat\": 31.893465000000003, \"merch_long\": -102.991517, \"is_fraud\": 0, \"merchant_label\": 208, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 115}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=635, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2861, timestamp=1715387620928, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-11 08:45:04\", \"cc_num\": 4992346398065154184, \"merchant\": \"fraud_Effertz LLC\", \"category\": \"entertainment\", \"amt\": 52.79, \"first\": \"Benjamin\", \"last\": \"Kim\", \"gender\": \"M\", \"street\": \"920 Patrick Light\", \"city\": \"Mc Nabb\", \"state\": \"IL\", \"zip\": 61335, \"lat\": 41.173, \"long\": -89.2187, \"city_pop\": 532, \"job\": \"Audiological scientist\", \"dob\": \"1956-01-09\", \"trans_num\": \"43a3dd630715632281c83f627cdc095c\", \"unix_time\": 1326271504, \"merch_lat\": 41.573743, \"merch_long\": -89.173108, \"is_fraud\": 0, \"merchant_label\": 151, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 42}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=608, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2862, timestamp=1715387620930, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-25 14:51:07\", \"cc_num\": 2235335206132667, \"merchant\": \"fraud_Dare, Casper and Bartoletti\", \"category\": \"kids_pets\", \"amt\": 44.71, \"first\": \"Maria\", \"last\": \"Rosales\", \"gender\": \"F\", \"street\": \"6611 Parrish Garden Apt. 428\", \"city\": \"Waynesfield\", \"state\": \"OH\", \"zip\": 45896, \"lat\": 40.6072, \"long\": -83.9585, \"city_pop\": 2089, \"job\": \"Building control surveyor\", \"dob\": \"1963-06-22\", \"trans_num\": \"e3adaf473b5589a852354d41871902da\", \"unix_time\": 1343227867, \"merch_lat\": 40.949684000000005, \"merch_long\": -84.032656, \"is_fraud\": 0, \"merchant_label\": 122, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 53}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=647, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2863, timestamp=1715387620933, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-03 15:06:41\", \"cc_num\": 36913587729122, \"merchant\": \"fraud_Beier-Hyatt\", \"category\": \"shopping_pos\", \"amt\": 13.48, \"first\": \"Ana\", \"last\": \"Mccormick\", \"gender\": \"F\", \"street\": \"4503 Patricia Route\", \"city\": \"Meridian\", \"state\": \"ID\", \"zip\": 83646, \"lat\": 43.6498, \"long\": -116.4306, \"city_pop\": 84106, \"job\": \"Intelligence analyst\", \"dob\": \"1971-02-11\", \"trans_num\": \"71d838eca34732cf47997f9500f761ff\", \"unix_time\": 1338736001, \"merch_lat\": 43.893115, \"merch_long\": -115.791648, \"is_fraud\": 0, \"merchant_label\": 42, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 252}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=610, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2864, timestamp=1715387620934, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-21 03:27:50\", \"cc_num\": 373043435942726, \"merchant\": \"fraud_Gottlieb, Considine and Schultz\", \"category\": \"shopping_net\", \"amt\": 95.08, \"first\": \"Vincent\", \"last\": \"Richards\", \"gender\": \"M\", \"street\": \"2064 Tyler Fork\", \"city\": \"Beasley\", \"state\": \"TX\", \"zip\": 77417, \"lat\": 29.479, \"long\": -95.9681, \"city_pop\": 2457, \"job\": \"Trading standards officer\", \"dob\": \"1981-03-04\", \"trans_num\": \"66de69d3a13e9cede974fb688835823c\", \"unix_time\": 1374377270, \"merch_lat\": 29.28991, \"merch_long\": -96.789271, \"is_fraud\": 0, \"merchant_label\": 198, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 480}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=630, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2865, timestamp=1715387620937, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-24 16:48:08\", \"cc_num\": 3596357274378601, \"merchant\": \"fraud_Gottlieb Group\", \"category\": \"kids_pets\", \"amt\": 31.69, \"first\": \"David\", \"last\": \"Everett\", \"gender\": \"M\", \"street\": \"4138 David Fall\", \"city\": \"Morrisdale\", \"state\": \"PA\", \"zip\": 16858, \"lat\": 41.0001, \"long\": -78.2357, \"city_pop\": 3688, \"job\": \"Advice worker\", \"dob\": \"1973-05-27\", \"trans_num\": \"5453bc1b290952047b8502c8602daf69\", \"unix_time\": 1369414088, \"merch_lat\": 41.619014, \"merch_long\": -77.646627, \"is_fraud\": 0, \"merchant_label\": 197, \"category_label\": 7, \"gender_label\": 1, \"job_label\": 14}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=599, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2866, timestamp=1715387623948, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-06 05:20:21\", \"cc_num\": 4740713119940984, \"merchant\": \"fraud_Schumm, Bauch and Ondricka\", \"category\": \"grocery_pos\", \"amt\": 80.69, \"first\": \"Heather\", \"last\": \"Hines\", \"gender\": \"F\", \"street\": \"13776 Hicks Plains\", \"city\": \"Pomona\", \"state\": \"NY\", \"zip\": 10970, \"lat\": 41.1901, \"long\": -74.0436, \"city_pop\": 9993, \"job\": \"Pensions consultant\", \"dob\": \"1962-10-16\", \"trans_num\": \"0d472b3dc7a604ebde3d725e638ff585\", \"unix_time\": 1365225621, \"merch_lat\": 41.766708, \"merch_long\": -73.972263, \"is_fraud\": 0, \"merchant_label\": 572, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 333}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=619, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2867, timestamp=1715387623951, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-25 16:21:39\", \"cc_num\": 676309913934, \"merchant\": \"fraud_Medhurst, Labadie and Gottlieb\", \"category\": \"travel\", \"amt\": 9.04, \"first\": \"Robert\", \"last\": \"Martinez\", \"gender\": \"M\", \"street\": \"3683 Parrish Circles\", \"city\": \"Pueblo\", \"state\": \"CO\", \"zip\": 81005, \"lat\": 38.2352, \"long\": -104.66, \"city_pop\": 151815, \"job\": \"Further education lecturer\", \"dob\": \"1988-01-04\", \"trans_num\": \"46b90defa3cc606829b07c650dac6bc9\", \"unix_time\": 1377447699, \"merch_lat\": 37.487298, \"merch_long\": -104.782087, \"is_fraud\": 0, \"merchant_label\": 423, \"category_label\": 13, \"gender_label\": 1, \"job_label\": 206}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=627, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2868, timestamp=1715387623953, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-06 18:33:10\", \"cc_num\": 343819048608995, \"merchant\": \"fraud_Nolan-Williamson\", \"category\": \"kids_pets\", \"amt\": 27.67, \"first\": \"Shelby\", \"last\": \"Cannon\", \"gender\": \"F\", \"street\": \"1535 Ryan Burgs Suite 919\", \"city\": \"Des Moines\", \"state\": \"IA\", \"zip\": 50312, \"lat\": 41.5855, \"long\": -93.6719, \"city_pop\": 222785, \"job\": \"Wellsite geologist\", \"dob\": \"1956-01-24\", \"trans_num\": \"26937feb40f7b6138548858b6a9ec6b0\", \"unix_time\": 1373135590, \"merch_lat\": 41.85921, \"merch_long\": -93.249734, \"is_fraud\": 0, \"merchant_label\": 455, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 495}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2869, timestamp=1715387623955, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-10 07:54:07\", \"cc_num\": 180084576295055, \"merchant\": \"fraud_Pfeffer and Sons\", \"category\": \"shopping_pos\", \"amt\": 21.58, \"first\": \"David\", \"last\": \"Kirby\", \"gender\": \"M\", \"street\": \"133 Alyssa Plains\", \"city\": \"Lolita\", \"state\": \"TX\", \"zip\": 77971, \"lat\": 28.7724, \"long\": -96.4793, \"city_pop\": 911, \"job\": \"Archaeologist\", \"dob\": \"1970-01-18\", \"trans_num\": \"9a735d0a8ea5f9ba90bda1b314297daa\", \"unix_time\": 1386662047, \"merch_lat\": 28.975187, \"merch_long\": -96.198481, \"is_fraud\": 0, \"merchant_label\": 480, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 30}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=599, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2870, timestamp=1715387626961, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-07 11:26:41\", \"cc_num\": 213161231269724, \"merchant\": \"fraud_Metz-Boehm\", \"category\": \"shopping_pos\", \"amt\": 42.1, \"first\": \"Alyssa\", \"last\": \"Morgan\", \"gender\": \"F\", \"street\": \"622 Robin Run Suite 764\", \"city\": \"Gadsden\", \"state\": \"AL\", \"zip\": 35901, \"lat\": 34.048, \"long\": -85.9246, \"city_pop\": 67082, \"job\": \"Physiological scientist\", \"dob\": \"1963-02-09\", \"trans_num\": \"d69e08bd2caa615727d8a8fbea562cba\", \"unix_time\": 1373196401, \"merch_lat\": 33.281277, \"merch_long\": -86.175556, \"is_fraud\": 0, \"merchant_label\": 425, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 340}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2871, timestamp=1715387626962, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-20 06:13:16\", \"cc_num\": 4450831335606294, \"merchant\": \"fraud_Streich, Hansen and Veum\", \"category\": \"gas_transport\", \"amt\": 54.21, \"first\": \"Donna\", \"last\": \"Davis\", \"gender\": \"F\", \"street\": \"6760 Donovan Lakes\", \"city\": \"Clayton\", \"state\": \"OK\", \"zip\": 74536, \"lat\": 34.5906, \"long\": -95.38, \"city_pop\": 1760, \"job\": \"Occupational psychologist\", \"dob\": \"1972-01-20\", \"trans_num\": \"7d1c9f19d96ca425a54045d1eb3e0546\", \"unix_time\": 1327039996, \"merch_lat\": 34.552522, \"merch_long\": -95.90919, \"is_fraud\": 0, \"merchant_label\": 605, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 316}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2872, timestamp=1715387626964, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-14 11:41:26\", \"cc_num\": 4536996888716062123, \"merchant\": \"fraud_Lockman, West and Runte\", \"category\": \"grocery_pos\", \"amt\": 54.45, \"first\": \"Nathan\", \"last\": \"Mendoza\", \"gender\": \"M\", \"street\": \"767 Adam Mill Apt. 115\", \"city\": \"Espanola\", \"state\": \"NM\", \"zip\": 87533, \"lat\": 35.9866, \"long\": -106.0654, \"city_pop\": 18408, \"job\": \"Historic buildings inspector/conservation officer\", \"dob\": \"1972-07-18\", \"trans_num\": \"9e4f91d02e7590eafd23ba4991636c9d\", \"unix_time\": 1352893286, \"merch_lat\": 36.084752, \"merch_long\": -106.562281, \"is_fraud\": 0, \"merchant_label\": 395, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 227}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=659, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2873, timestamp=1715387626966, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-03-12 16:47:58\", \"cc_num\": 370612217861404, \"merchant\": \"fraud_Macejkovic-Lesch\", \"category\": \"shopping_pos\", \"amt\": 52.33, \"first\": \"Amanda\", \"last\": \"Fitzgerald\", \"gender\": \"F\", \"street\": \"298 Kayla Lights\", \"city\": \"Bristol\", \"state\": \"PA\", \"zip\": 19007, \"lat\": 40.1159, \"long\": -74.8536, \"city_pop\": 21125, \"job\": \"Administrator, charities/voluntary organisations\", \"dob\": \"1985-05-25\", \"trans_num\": \"88df1a76513f2bd5110ec7d7afe881e9\", \"unix_time\": 1331570878, \"merch_lat\": 39.704089, \"merch_long\": -74.204101, \"is_fraud\": 0, \"merchant_label\": 403, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 8}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=641, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2874, timestamp=1715387626969, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-08-01 10:58:15\", \"cc_num\": 30150717898388, \"merchant\": \"fraud_Herzog Ltd\", \"category\": \"misc_pos\", \"amt\": 164.24, \"first\": \"Raymond\", \"last\": \"Lloyd\", \"gender\": \"M\", \"street\": \"5930 Rebecca Bridge Apt. 444\", \"city\": \"Paint Rock\", \"state\": \"AL\", \"zip\": 35764, \"lat\": 34.7031, \"long\": -86.3068, \"city_pop\": 653, \"job\": \"Paediatric nurse\", \"dob\": \"1966-06-19\", \"trans_num\": \"fa3fe23253467851b79e6c5ea12fc586\", \"unix_time\": 1343818695, \"merch_lat\": 35.388342, \"merch_long\": -85.614673, \"is_fraud\": 0, \"merchant_label\": 250, \"category_label\": 9, \"gender_label\": 1, \"job_label\": 328}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2875, timestamp=1715387626972, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-10 21:37:46\", \"cc_num\": 4102003771126577611, \"merchant\": \"fraud_Kessler Group\", \"category\": \"travel\", \"amt\": 387.01, \"first\": \"William\", \"last\": \"Fitzgerald\", \"gender\": \"M\", \"street\": \"715 Courtney Pike Suite 932\", \"city\": \"Keller\", \"state\": \"TX\", \"zip\": 76248, \"lat\": 32.9276, \"long\": -97.2489, \"city_pop\": 95035, \"job\": \"Probation officer\", \"dob\": \"1987-06-13\", \"trans_num\": \"c424f104ab4abbba6625b408ba5c7996\", \"unix_time\": 1347313066, \"merch_lat\": 32.814007000000004, \"merch_long\": -96.488899, \"is_fraud\": 0, \"merchant_label\": 306, \"category_label\": 13, \"gender_label\": 1, \"job_label\": 355}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=628, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2876, timestamp=1715387626974, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-19 00:29:28\", \"cc_num\": 3560318482131952, \"merchant\": \"fraud_Herman, Treutel and Dickens\", \"category\": \"misc_net\", \"amt\": 23.67, \"first\": \"William\", \"last\": \"Skinner\", \"gender\": \"M\", \"street\": \"524 Wu Spurs Suite 894\", \"city\": \"Mount Hope\", \"state\": \"AL\", \"zip\": 35651, \"lat\": 34.4793, \"long\": -87.4769, \"city_pop\": 1312, \"job\": \"Librarian, academic\", \"dob\": \"1955-02-01\", \"trans_num\": \"9c4cd4f8d5c1024b6a310034de6189b7\", \"unix_time\": 1348014568, \"merch_lat\": 35.118194, \"merch_long\": -87.131698, \"is_fraud\": 0, \"merchant_label\": 245, \"category_label\": 8, \"gender_label\": 1, \"job_label\": 271}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=627, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2877, timestamp=1715387629980, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-27 16:15:15\", \"cc_num\": 36722699017270, \"merchant\": \"fraud_Goyette-Gerhold\", \"category\": \"kids_pets\", \"amt\": 22.82, \"first\": \"Jessica\", \"last\": \"Perez\", \"gender\": \"F\", \"street\": \"8172 Robertson Parkways Suite 072\", \"city\": \"Superior\", \"state\": \"AZ\", \"zip\": 85173, \"lat\": 33.2887, \"long\": -111.0985, \"city_pop\": 2872, \"job\": \"Petroleum engineer\", \"dob\": \"1987-10-28\", \"trans_num\": \"0044a9b48f8786828e83d4ee0cdef5d9\", \"unix_time\": 1343405715, \"merch_lat\": 32.881803999999995, \"merch_long\": -110.780255, \"is_fraud\": 0, \"merchant_label\": 202, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 335}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=631, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2878, timestamp=1715387629980, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-01 18:57:14\", \"cc_num\": 4789911625179723, \"merchant\": \"fraud_Gutmann, McLaughlin and Wiza\", \"category\": \"home\", \"amt\": 15.78, \"first\": \"Dorothy\", \"last\": \"Zuniga\", \"gender\": \"F\", \"street\": \"77321 Ford Via\", \"city\": \"Moriches\", \"state\": \"NY\", \"zip\": 11955, \"lat\": 40.8095, \"long\": -72.8229, \"city_pop\": 3285, \"job\": \"Research officer, trade union\", \"dob\": \"1988-04-27\", \"trans_num\": \"b27f28bffe0ab4d41ec2db74a940fa73\", \"unix_time\": 1333306634, \"merch_lat\": 40.492156, \"merch_long\": -72.947503, \"is_fraud\": 0, \"merchant_label\": 213, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 393}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=623, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2879, timestamp=1715387629982, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-31 06:14:13\", \"cc_num\": 2383461948823908, \"merchant\": \"fraud_Langworth, Boehm and Gulgowski\", \"category\": \"shopping_net\", \"amt\": 2.25, \"first\": \"Patrick\", \"last\": \"Vaughan\", \"gender\": \"M\", \"street\": \"651 Miller Common\", \"city\": \"Parsonsfield\", \"state\": \"ME\", \"zip\": 4047, \"lat\": 43.745, \"long\": -70.9092, \"city_pop\": 1892, \"job\": \"Audiological scientist\", \"dob\": \"1956-03-02\", \"trans_num\": \"a8d483a32f29b99e2af7c3b0a90f1811\", \"unix_time\": 1356934453, \"merch_lat\": 42.985761, \"merch_long\": -70.33156899999999, \"is_fraud\": 0, \"merchant_label\": 372, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 42}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=639, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2880, timestamp=1715387629984, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-01 11:18:56\", \"cc_num\": 3583293909206278, \"merchant\": \"fraud_Koepp-Parker\", \"category\": \"grocery_pos\", \"amt\": 101.75, \"first\": \"Deborah\", \"last\": \"Fisher\", \"gender\": \"F\", \"street\": \"1911 Fisher Brook\", \"city\": \"Kirtland Afb\", \"state\": \"NM\", \"zip\": 87117, \"lat\": 35.0203, \"long\": -106.5503, \"city_pop\": 310, \"job\": \"Surveyor, land/geomatics\", \"dob\": \"1978-09-30\", \"trans_num\": \"d6ef28abc111fefabf03367ab40de0e6\", \"unix_time\": 1354360736, \"merch_lat\": 35.706709000000004, \"merch_long\": -106.241624, \"is_fraud\": 0, \"merchant_label\": 328, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 442}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=627, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2881, timestamp=1715387629985, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-04 21:26:30\", \"cc_num\": 4005676619255478, \"merchant\": \"fraud_Mohr-Bayer\", \"category\": \"shopping_net\", \"amt\": 6.48, \"first\": \"William\", \"last\": \"Perry\", \"gender\": \"M\", \"street\": \"458 Phillips Island Apt. 768\", \"city\": \"Denham Springs\", \"state\": \"LA\", \"zip\": 70726, \"lat\": 30.459, \"long\": -90.9027, \"city_pop\": 71335, \"job\": \"Herbalist\", \"dob\": \"1994-05-31\", \"trans_num\": \"b4b0eac07fffb11a2716f274a2da634b\", \"unix_time\": 1357334790, \"merch_lat\": 31.109249, \"merch_long\": -91.22679, \"is_fraud\": 0, \"merchant_label\": 430, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 223}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=611, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2882, timestamp=1715387629987, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-17 20:43:23\", \"cc_num\": 4169759661243568, \"merchant\": \"fraud_Bartoletti and Sons\", \"category\": \"personal_care\", \"amt\": 7.18, \"first\": \"Jamie\", \"last\": \"Carr\", \"gender\": \"F\", \"street\": \"55363 Aaron Circle Suite 450\", \"city\": \"Lawn\", \"state\": \"PA\", \"zip\": 17041, \"lat\": 40.2236, \"long\": -76.538, \"city_pop\": 213, \"job\": \"Special educational needs teacher\", \"dob\": \"1972-02-15\", \"trans_num\": \"580b1fcb43a3c8055b12b72868ab851d\", \"unix_time\": 1371501803, \"merch_lat\": 39.519313, \"merch_long\": -76.006844, \"is_fraud\": 0, \"merchant_label\": 23, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 431}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=630, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2883, timestamp=1715387629989, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-08-19 16:33:55\", \"cc_num\": 4646845581490336108, \"merchant\": \"fraud_Hilpert-Conroy\", \"category\": \"kids_pets\", \"amt\": 62.76, \"first\": \"Julia\", \"last\": \"Bell\", \"gender\": \"F\", \"street\": \"576 House Crossroad\", \"city\": \"West Sayville\", \"state\": \"NY\", \"zip\": 11796, \"lat\": 40.732, \"long\": -73.1, \"city_pop\": 4056, \"job\": \"Film/video editor\", \"dob\": \"1990-06-25\", \"trans_num\": \"15395dcc7301a9f9b170fa9b107794eb\", \"unix_time\": 1345394035, \"merch_lat\": 40.883381, \"merch_long\": -73.281751, \"is_fraud\": 0, \"merchant_label\": 257, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 194}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2884, timestamp=1715387632994, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-16 12:30:37\", \"cc_num\": 3521417320836166, \"merchant\": \"fraud_Monahan-Morar\", \"category\": \"personal_care\", \"amt\": 65.34, \"first\": \"Angela\", \"last\": \"Hodges\", \"gender\": \"F\", \"street\": \"08236 Kim Hill\", \"city\": \"Indianapolis\", \"state\": \"IN\", \"zip\": 46254, \"lat\": 39.849, \"long\": -86.272, \"city_pop\": 910148, \"job\": \"Firefighter\", \"dob\": \"1975-11-30\", \"trans_num\": \"faf95bb6fac26f751cdc92575f762b43\", \"unix_time\": 1353069037, \"merch_lat\": 40.72542, \"merch_long\": -86.620166, \"is_fraud\": 0, \"merchant_label\": 433, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 198}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=602, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2885, timestamp=1715387632996, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-28 06:34:13\", \"cc_num\": 30082025922891, \"merchant\": \"fraud_Raynor, Feest and Miller\", \"category\": \"gas_transport\", \"amt\": 76.94, \"first\": \"Kathleen\", \"last\": \"Thompson\", \"gender\": \"F\", \"street\": \"199 Patterson Fords Apt. 132\", \"city\": \"Naples\", \"state\": \"FL\", \"zip\": 34112, \"lat\": 26.1184, \"long\": -81.7361, \"city_pop\": 276002, \"job\": \"Pilot, airline\", \"dob\": \"1934-06-23\", \"trans_num\": \"8123b6d00a5d21ab5bf4480695222430\", \"unix_time\": 1335594853, \"merch_lat\": 25.497841, \"merch_long\": -81.89919499999999, \"is_fraud\": 0, \"merchant_label\": 497, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 343}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=636, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2886, timestamp=1715387635999, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-26 02:03:02\", \"cc_num\": 38534201672254, \"merchant\": \"fraud_Huels-Hahn\", \"category\": \"gas_transport\", \"amt\": 14.39, \"first\": \"James\", \"last\": \"Taylor\", \"gender\": \"M\", \"street\": \"4716 Tracy Bridge\", \"city\": \"Oakton\", \"state\": \"VA\", \"zip\": 22124, \"lat\": 38.8852, \"long\": -77.3233, \"city_pop\": 17558, \"job\": \"Furniture designer\", \"dob\": \"1940-03-06\", \"trans_num\": \"e8b66ce15cc605d7a1bde458db04086c\", \"unix_time\": 1351216982, \"merch_lat\": 38.501965000000006, \"merch_long\": -77.709624, \"is_fraud\": 1, \"merchant_label\": 272, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 205}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=610, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2887, timestamp=1715387636000, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-29 04:09:19\", \"cc_num\": 4502539526809429801, \"merchant\": \"fraud_Jenkins, Hauck and Friesen\", \"category\": \"gas_transport\", \"amt\": 45.96, \"first\": \"Stephanie\", \"last\": \"Cummings\", \"gender\": \"F\", \"street\": \"1025 Robin Square\", \"city\": \"Ash Flat\", \"state\": \"AR\", \"zip\": 72513, \"lat\": 36.2201, \"long\": -91.6421, \"city_pop\": 2856, \"job\": \"Hydrologist\", \"dob\": \"1926-08-27\", \"trans_num\": \"b69c479ca5457a236feba8f22dd6582a\", \"unix_time\": 1364530159, \"merch_lat\": 37.06258, \"merch_long\": -92.206444, \"is_fraud\": 0, \"merchant_label\": 285, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 238}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2888, timestamp=1715387636004, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-25 09:56:01\", \"cc_num\": 348789608637806, \"merchant\": \"fraud_Koss and Sons\", \"category\": \"gas_transport\", \"amt\": 70.69, \"first\": \"Megan\", \"last\": \"Murphy\", \"gender\": \"F\", \"street\": \"53696 Laura Radial\", \"city\": \"Holstein\", \"state\": \"NE\", \"zip\": 68950, \"lat\": 40.4542, \"long\": -98.6538, \"city_pop\": 331, \"job\": \"Telecommunications researcher\", \"dob\": \"1950-08-19\", \"trans_num\": \"2f59fe4fbe32209cb905590a0931e5cb\", \"unix_time\": 1359107761, \"merch_lat\": 40.902587, \"merch_long\": -99.26475, \"is_fraud\": 0, \"merchant_label\": 332, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 459}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2889, timestamp=1715387636006, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-15 15:28:58\", \"cc_num\": 30235268718158, \"merchant\": \"fraud_Kihn Inc\", \"category\": \"shopping_pos\", \"amt\": 1.44, \"first\": \"Kenneth\", \"last\": \"Doyle\", \"gender\": \"M\", \"street\": \"8614 Reed Glen\", \"city\": \"West Harrison\", \"state\": \"NY\", \"zip\": 10604, \"lat\": 41.0592, \"long\": -73.7395, \"city_pop\": 11250, \"job\": \"Lexicographer\", \"dob\": \"1977-08-16\", \"trans_num\": \"b5461c0138501918c7870f73cb30fc4a\", \"unix_time\": 1376580538, \"merch_lat\": 41.489374, \"merch_long\": -74.46749799999999, \"is_fraud\": 0, \"merchant_label\": 310, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 270}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=606, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2890, timestamp=1715387636007, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-27 02:24:17\", \"cc_num\": 30248898834493, \"merchant\": \"fraud_Raynor, Reinger and Hagenes\", \"category\": \"gas_transport\", \"amt\": 44.58, \"first\": \"Michael\", \"last\": \"Rodriguez\", \"gender\": \"M\", \"street\": \"172 Paula Inlet Apt. 650\", \"city\": \"Cross Plains\", \"state\": \"TX\", \"zip\": 76443, \"lat\": 32.1482, \"long\": -99.1872, \"city_pop\": 1897, \"job\": \"Chief Operating Officer\", \"dob\": \"1953-04-19\", \"trans_num\": \"d999f593d68e6e30036f987da30e0568\", \"unix_time\": 1327631057, \"merch_lat\": 33.144223, \"merch_long\": -99.292911, \"is_fraud\": 0, \"merchant_label\": 498, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 77}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=639, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2891, timestamp=1715387636009, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-15 23:20:08\", \"cc_num\": 3567697931646329, \"merchant\": \"fraud_Lakin, Ferry and Beatty\", \"category\": \"food_dining\", \"amt\": 1.54, \"first\": \"John\", \"last\": \"Stevens\", \"gender\": \"M\", \"street\": \"428 Morgan River\", \"city\": \"Hudson\", \"state\": \"NY\", \"zip\": 12534, \"lat\": 42.247, \"long\": -73.7552, \"city_pop\": 17867, \"job\": \"Travel agency manager\", \"dob\": \"1998-07-29\", \"trans_num\": \"8fa0006eaa79f675a12a7c2f7f140c7e\", \"unix_time\": 1355613608, \"merch_lat\": 43.08875, \"merch_long\": -73.127698, \"is_fraud\": 0, \"merchant_label\": 368, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 483}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2892, timestamp=1715387636010, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-22 01:34:35\", \"cc_num\": 6596735789587928, \"merchant\": \"fraud_Schuppe LLC\", \"category\": \"entertainment\", \"amt\": 30.5, \"first\": \"Spencer\", \"last\": \"Williams\", \"gender\": \"M\", \"street\": \"1145 Tony Drive Suite 080\", \"city\": \"Watertown\", \"state\": \"MN\", \"zip\": 55388, \"lat\": 44.9595, \"long\": -93.8482, \"city_pop\": 5619, \"job\": \"Licensed conveyancer\", \"dob\": \"1959-01-15\", \"trans_num\": \"0c3347359876f481622673b47004d64b\", \"unix_time\": 1327196075, \"merch_lat\": 45.333332, \"merch_long\": -94.339345, \"is_fraud\": 0, \"merchant_label\": 574, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 273}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=619, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2893, timestamp=1715387636013, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-28 01:48:30\", \"cc_num\": 3589255887819806, \"merchant\": \"fraud_Auer-Mosciski\", \"category\": \"grocery_pos\", \"amt\": 55.25, \"first\": \"David\", \"last\": \"Miller\", \"gender\": \"M\", \"street\": \"622 Bradley Knoll Apt. 758\", \"city\": \"Hancock\", \"state\": \"MD\", \"zip\": 21750, \"lat\": 39.6991, \"long\": -78.1762, \"city_pop\": 3766, \"job\": \"Press photographer\", \"dob\": \"1984-02-14\", \"trans_num\": \"480a593eefeb707b193cfb5048d5d94f\", \"unix_time\": 1367113710, \"merch_lat\": 40.38178, \"merch_long\": -78.52797, \"is_fraud\": 0, \"merchant_label\": 12, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 350}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=610, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2894, timestamp=1715387636015, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-30 04:41:02\", \"cc_num\": 3512365128314616, \"merchant\": \"fraud_Miller-Hauck\", \"category\": \"grocery_pos\", \"amt\": 64.77, \"first\": \"Francisco\", \"last\": \"Kemp\", \"gender\": \"M\", \"street\": \"9554 Flores Drive\", \"city\": \"Arnold\", \"state\": \"MO\", \"zip\": 63010, \"lat\": 38.4305, \"long\": -90.387, \"city_pop\": 35439, \"job\": \"Land/geomatics surveyor\", \"dob\": \"1985-03-31\", \"trans_num\": \"8f12dc3becf844eea4451df261bd0d53\", \"unix_time\": 1369888862, \"merch_lat\": 38.257694, \"merch_long\": -90.913709, \"is_fraud\": 0, \"merchant_label\": 427, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 261}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2895, timestamp=1715387636017, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-13 12:51:49\", \"cc_num\": 639023984367, \"merchant\": \"fraud_Schiller Ltd\", \"category\": \"personal_care\", \"amt\": 77.09, \"first\": \"Destiny\", \"last\": \"Lowe\", \"gender\": \"F\", \"street\": \"79472 Stevens Trace Apt. 120\", \"city\": \"Hannawa Falls\", \"state\": \"NY\", \"zip\": 13647, \"lat\": 44.6087, \"long\": -74.9732, \"city_pop\": 69, \"job\": \"Chief Executive Officer\", \"dob\": \"1991-06-05\", \"trans_num\": \"e171dd3235cbbf50ec062dcd9cd3d5c5\", \"unix_time\": 1326459109, \"merch_lat\": 44.638278, \"merch_long\": -75.527957, \"is_fraud\": 0, \"merchant_label\": 551, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 74}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2896, timestamp=1715387639021, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-17 21:07:42\", \"cc_num\": 4229733778084049, \"merchant\": \"fraud_Lang, Towne and Schuppe\", \"category\": \"kids_pets\", \"amt\": 14.44, \"first\": \"Tyler\", \"last\": \"Mills\", \"gender\": \"M\", \"street\": \"7838 Jason Squares\", \"city\": \"Elizabethtown\", \"state\": \"KY\", \"zip\": 42701, \"lat\": 37.6848, \"long\": -85.8784, \"city_pop\": 48194, \"job\": \"Surgeon\", \"dob\": \"1990-05-03\", \"trans_num\": \"ba08dee9ef8cbfb13982ee393f231f62\", \"unix_time\": 1350508062, \"merch_lat\": 36.738514, \"merch_long\": -85.068759, \"is_fraud\": 0, \"merchant_label\": 369, \"category_label\": 7, \"gender_label\": 1, \"job_label\": 440}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=608, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2897, timestamp=1715387639022, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-31 07:03:57\", \"cc_num\": 4792627764422477317, \"merchant\": \"fraud_Auer-Mosciski\", \"category\": \"grocery_pos\", \"amt\": 191.05, \"first\": \"Margaret\", \"last\": \"Mendez\", \"gender\": \"F\", \"street\": \"7952 Karen Pike\", \"city\": \"De Soto\", \"state\": \"KS\", \"zip\": 66018, \"lat\": 38.9462, \"long\": -94.9714, \"city_pop\": 5760, \"job\": \"Chief Executive Officer\", \"dob\": \"1978-10-01\", \"trans_num\": \"0c0598ad26b0a46ef55af16eb1f644ad\", \"unix_time\": 1369983837, \"merch_lat\": 38.044212, \"merch_long\": -95.435066, \"is_fraud\": 0, \"merchant_label\": 12, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 74}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=612, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2898, timestamp=1715387639023, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-17 20:54:31\", \"cc_num\": 5359543825610251, \"merchant\": \"fraud_Medhurst Inc\", \"category\": \"home\", \"amt\": 20.98, \"first\": \"Michael\", \"last\": \"Francis\", \"gender\": \"M\", \"street\": \"1833 Jeanette Stravenue\", \"city\": \"Belgrade\", \"state\": \"MT\", \"zip\": 59714, \"lat\": 45.7801, \"long\": -111.1439, \"city_pop\": 18182, \"job\": \"Engineer, drilling\", \"dob\": \"1975-06-29\", \"trans_num\": \"980db629a24348814fa3d46e84ea6f4e\", \"unix_time\": 1374094471, \"merch_lat\": 45.057293, \"merch_long\": -110.89797, \"is_fraud\": 0, \"merchant_label\": 420, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 163}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=608, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2899, timestamp=1715387639025, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-05 20:34:30\", \"cc_num\": 6011109736646996, \"merchant\": \"fraud_Torphy-Goyette\", \"category\": \"shopping_pos\", \"amt\": 16.98, \"first\": \"Rebecca\", \"last\": \"Erickson\", \"gender\": \"F\", \"street\": \"594 Berry Lights Apt. 392\", \"city\": \"Wilmington\", \"state\": \"NC\", \"zip\": 28405, \"lat\": 34.2651, \"long\": -77.867, \"city_pop\": 186140, \"job\": \"English as a second language teacher\", \"dob\": \"1983-02-08\", \"trans_num\": \"70869b71c5f3953be375ecb117e60592\", \"unix_time\": 1357418070, \"merch_lat\": 33.737673, \"merch_long\": -77.9186, \"is_fraud\": 0, \"merchant_label\": 627, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 178}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=639, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2900, timestamp=1715387639026, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-21 21:09:01\", \"cc_num\": 4560004149983868183, \"merchant\": \"fraud_Beier-Hyatt\", \"category\": \"shopping_pos\", \"amt\": 188.11, \"first\": \"Stacy\", \"last\": \"Villegas\", \"gender\": \"F\", \"street\": \"20581 Pena Walks\", \"city\": \"Colorado Springs\", \"state\": \"CO\", \"zip\": 80951, \"lat\": 38.8881, \"long\": -104.6556, \"city_pop\": 525713, \"job\": \"Museum/gallery exhibitions officer\", \"dob\": \"1992-05-09\", \"trans_num\": \"5361999391a8102eef5d17bac28d37f2\", \"unix_time\": 1356124141, \"merch_lat\": 38.371869, \"merch_long\": -103.929941, \"is_fraud\": 0, \"merchant_label\": 42, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 304}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=637, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2901, timestamp=1715387639028, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-26 17:18:48\", \"cc_num\": 6011399591920186, \"merchant\": \"fraud_Morissette PLC\", \"category\": \"shopping_pos\", \"amt\": 4.43, \"first\": \"Maria\", \"last\": \"Roy\", \"gender\": \"F\", \"street\": \"58665 Nicholas Ford Suite 348\", \"city\": \"Sheffield\", \"state\": \"MA\", \"zip\": 1257, \"lat\": 42.1001, \"long\": -73.3611, \"city_pop\": 2121, \"job\": \"Radio producer\", \"dob\": \"1973-10-14\", \"trans_num\": \"60cdd11c405e8eda559fbc70c02cc937\", \"unix_time\": 1340731128, \"merch_lat\": 42.278741, \"merch_long\": -73.50227199999999, \"is_fraud\": 0, \"merchant_label\": 438, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 387}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=620, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2902, timestamp=1715387639029, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-11-28 22:15:08\", \"cc_num\": 3547560454237873, \"merchant\": \"fraud_Schoen, Nienow and Bauch\", \"category\": \"personal_care\", \"amt\": 4.14, \"first\": \"Jerry\", \"last\": \"Robinson\", \"gender\": \"M\", \"street\": \"212 Mary Stream\", \"city\": \"Arcadia\", \"state\": \"MI\", \"zip\": 49613, \"lat\": 44.5232, \"long\": -86.2061, \"city_pop\": 680, \"job\": \"Designer, jewellery\", \"dob\": \"1966-12-21\", \"trans_num\": \"676ef955c607a57794b509213c545680\", \"unix_time\": 1385676908, \"merch_lat\": 45.305205, \"merch_long\": -86.526165, \"is_fraud\": 0, \"merchant_label\": 564, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 126}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2903, timestamp=1715387642033, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-02 13:18:21\", \"cc_num\": 3527063666782582, \"merchant\": \"fraud_Kozey-Kuhlman\", \"category\": \"personal_care\", \"amt\": 25.48, \"first\": \"Amanda\", \"last\": \"Alexander\", \"gender\": \"F\", \"street\": \"21810 James Mall\", \"city\": \"Camden\", \"state\": \"TX\", \"zip\": 75934, \"lat\": 30.9, \"long\": -94.7547, \"city_pop\": 99, \"job\": \"Colour technologist\", \"dob\": \"1965-11-21\", \"trans_num\": \"04d09fd3eaf7eb203197cc6d5f7ee139\", \"unix_time\": 1341235101, \"merch_lat\": 30.808629, \"merch_long\": -95.544087, \"is_fraud\": 0, \"merchant_label\": 338, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 92}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=604, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2904, timestamp=1715387645039, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-23 02:42:24\", \"cc_num\": 4560004149983868183, \"merchant\": \"fraud_Ortiz Group\", \"category\": \"grocery_net\", \"amt\": 63.46, \"first\": \"Stacy\", \"last\": \"Villegas\", \"gender\": \"F\", \"street\": \"20581 Pena Walks\", \"city\": \"Colorado Springs\", \"state\": \"CO\", \"zip\": 80951, \"lat\": 38.8881, \"long\": -104.6556, \"city_pop\": 525713, \"job\": \"Museum/gallery exhibitions officer\", \"dob\": \"1992-05-09\", \"trans_num\": \"3d3cfb092b7803217c09f3c0ac10805d\", \"unix_time\": 1350960144, \"merch_lat\": 38.714179, \"merch_long\": -105.590467, \"is_fraud\": 0, \"merchant_label\": 464, \"category_label\": 3, \"gender_label\": 0, \"job_label\": 304}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=635, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2905, timestamp=1715387645039, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-03-15 21:21:32\", \"cc_num\": 630469040731, \"merchant\": \"fraud_Wilkinson PLC\", \"category\": \"kids_pets\", \"amt\": 111.53, \"first\": \"Meredith\", \"last\": \"Ayala\", \"gender\": \"F\", \"street\": \"7107 Henderson Station\", \"city\": \"Cascade Locks\", \"state\": \"OR\", \"zip\": 97014, \"lat\": 45.67100000000001, \"long\": -121.8686, \"city_pop\": 1288, \"job\": \"Barrister\", \"dob\": \"1936-05-01\", \"trans_num\": \"808eab3144aca336a7ff9e9a01f174c3\", \"unix_time\": 1331846492, \"merch_lat\": 45.501072, \"merch_long\": -121.445555, \"is_fraud\": 0, \"merchant_label\": 667, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 44}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=614, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2906, timestamp=1715387645041, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-07 01:21:53\", \"cc_num\": 213154573301411, \"merchant\": \"fraud_Corwin-Collins\", \"category\": \"gas_transport\", \"amt\": 70.71, \"first\": \"Christopher\", \"last\": \"Sheppard\", \"gender\": \"M\", \"street\": \"39218 Baker Shoals\", \"city\": \"Bristow\", \"state\": \"IN\", \"zip\": 47515, \"lat\": 38.1981, \"long\": -86.6821, \"city_pop\": 965, \"job\": \"Horticultural therapist\", \"dob\": \"1982-02-10\", \"trans_num\": \"6d5e371fb202b64f4354ca59de1991ca\", \"unix_time\": 1346980913, \"merch_lat\": 37.360604, \"merch_long\": -87.39879599999999, \"is_fraud\": 0, \"merchant_label\": 107, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 230}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=627, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2907, timestamp=1715387645042, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-03 02:55:57\", \"cc_num\": 4292743669224718067, \"merchant\": \"fraud_Friesen-D\\'Amore\", \"category\": \"gas_transport\", \"amt\": 44.72, \"first\": \"Michael\", \"last\": \"Williams\", \"gender\": \"M\", \"street\": \"35822 Clayton Street Apt. 679\", \"city\": \"Great Mills\", \"state\": \"MD\", \"zip\": 20634, \"lat\": 38.2674, \"long\": -76.4954, \"city_pop\": 5927, \"job\": \"Art therapist\", \"dob\": \"1973-06-09\", \"trans_num\": \"4eb8266d695dd1a420e0d8e027ef5248\", \"unix_time\": 1349232957, \"merch_lat\": 37.704045, \"merch_long\": -76.948925, \"is_fraud\": 0, \"merchant_label\": 181, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 38}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=625, serialized_header_size=-1)\n",
      "Error in transaction: <Error from server: code=2000 [Syntax error in CQL query] message=\"line 1:152 mismatched input 'Amore' expecting EOF (... INTO bigdata.transaction_data JSON '{\"trans_date_trans_time\": \"2019-10-03 02:55:57\", \"cc_num\": 4292743669224718067, \"merchant\": \"fraud_Friesen-D'[Amore]...)\">\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2908, timestamp=1715387645044, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-08 21:17:56\", \"cc_num\": 30428204673351, \"merchant\": \"fraud_Labadie LLC\", \"category\": \"personal_care\", \"amt\": 70.69, \"first\": \"Greg\", \"last\": \"Villarreal\", \"gender\": \"M\", \"street\": \"2851 Foster Shoals\", \"city\": \"Schaefferstown\", \"state\": \"PA\", \"zip\": 17088, \"lat\": 40.3087, \"long\": -76.2963, \"city_pop\": 823, \"job\": \"Gaffer\", \"dob\": \"1982-07-02\", \"trans_num\": \"ef4649391e7a91387ef10e380339682c\", \"unix_time\": 1375996676, \"merch_lat\": 40.691111, \"merch_long\": -75.576769, \"is_fraud\": 0, \"merchant_label\": 366, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 208}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=601, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2909, timestamp=1715387645046, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-24 21:48:02\", \"cc_num\": 676292294938, \"merchant\": \"fraud_Padberg-Rogahn\", \"category\": \"entertainment\", \"amt\": 7.56, \"first\": \"Lisa\", \"last\": \"Fitzpatrick\", \"gender\": \"F\", \"street\": \"58761 Brewer Rapids\", \"city\": \"Skytop\", \"state\": \"PA\", \"zip\": 18357, \"lat\": 41.2336, \"long\": -75.2389, \"city_pop\": 104, \"job\": \"Financial trader\", \"dob\": \"1927-08-25\", \"trans_num\": \"0a76cc2dee8f2281667fa83fb95baf8d\", \"unix_time\": 1374702482, \"merch_lat\": 40.789888, \"merch_long\": -74.673603, \"is_fraud\": 0, \"merchant_label\": 470, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 196}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=604, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2910, timestamp=1715387645047, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-22 07:10:25\", \"cc_num\": 5580563567307107, \"merchant\": \"fraud_Boehm, Predovic and Reinger\", \"category\": \"misc_pos\", \"amt\": 45.87, \"first\": \"Stanley\", \"last\": \"Dickson\", \"gender\": \"M\", \"street\": \"078 Alex Fields\", \"city\": \"Smock\", \"state\": \"PA\", \"zip\": 15480, \"lat\": 39.9961, \"long\": -79.7678, \"city_pop\": 1946, \"job\": \"Charity fundraiser\", \"dob\": \"1990-06-21\", \"trans_num\": \"47b27b05de000ffd428e45300662cb90\", \"unix_time\": 1327216225, \"merch_lat\": 40.742651, \"merch_long\": -79.518098, \"is_fraud\": 0, \"merchant_label\": 63, \"category_label\": 9, \"gender_label\": 1, \"job_label\": 66}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=612, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2911, timestamp=1715387645049, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-07 20:06:58\", \"cc_num\": 2297447006766555, \"merchant\": \"fraud_Hermiston, Russel and Price\", \"category\": \"food_dining\", \"amt\": 15.0, \"first\": \"Laura\", \"last\": \"Walker\", \"gender\": \"F\", \"street\": \"611 Michael Rue\", \"city\": \"Cisco\", \"state\": \"IL\", \"zip\": 61830, \"lat\": 39.9972, \"long\": -88.6962, \"city_pop\": 478, \"job\": \"Landscape architect\", \"dob\": \"1960-01-13\", \"trans_num\": \"f2f23e189e01daa8904316bd6c40a264\", \"unix_time\": 1341691618, \"merch_lat\": 40.091776, \"merch_long\": -89.237749, \"is_fraud\": 0, \"merchant_label\": 249, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 262}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2912, timestamp=1715387648053, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-14 01:08:28\", \"cc_num\": 3533012926413100, \"merchant\": \"fraud_Kutch and Sons\", \"category\": \"grocery_pos\", \"amt\": 72.38, \"first\": \"Megan\", \"last\": \"Bernard\", \"gender\": \"F\", \"street\": \"128 Nathan Ramp\", \"city\": \"Barneveld\", \"state\": \"NY\", \"zip\": 13304, \"lat\": 43.2237, \"long\": -75.1612, \"city_pop\": 1684, \"job\": \"IT trainer\", \"dob\": \"1994-03-01\", \"trans_num\": \"60dd30e4b17e9aececd2e3557ef2bcf7\", \"unix_time\": 1371172108, \"merch_lat\": 42.774898, \"merch_long\": -75.518277, \"is_fraud\": 0, \"merchant_label\": 359, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 240}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=598, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2913, timestamp=1715387651059, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-16 23:38:32\", \"cc_num\": 213141712584544, \"merchant\": \"fraud_Pouros-Haag\", \"category\": \"shopping_pos\", \"amt\": 4.63, \"first\": \"Margaret\", \"last\": \"Curtis\", \"gender\": \"F\", \"street\": \"742 Oneill Shore\", \"city\": \"Florence\", \"state\": \"MS\", \"zip\": 39073, \"lat\": 32.153, \"long\": -90.1217, \"city_pop\": 19685, \"job\": \"Fine artist\", \"dob\": \"1984-12-24\", \"trans_num\": \"6d7d9e80a816dc264c03baa35ccab1aa\", \"unix_time\": 1355701112, \"merch_lat\": 31.648179, \"merch_long\": -90.439299, \"is_fraud\": 0, \"merchant_label\": 484, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 197}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=598, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2914, timestamp=1715387651060, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-07 15:40:26\", \"cc_num\": 3568255211412877, \"merchant\": \"fraud_Baumbach Ltd\", \"category\": \"personal_care\", \"amt\": 35.52, \"first\": \"Timothy\", \"last\": \"Gomez\", \"gender\": \"M\", \"street\": \"707 Anthony Causeway\", \"city\": \"Leo\", \"state\": \"IN\", \"zip\": 46765, \"lat\": 41.2249, \"long\": -85.0301, \"city_pop\": 5341, \"job\": \"Biomedical engineer\", \"dob\": \"1994-11-24\", \"trans_num\": \"fa5cf1c2c9b8f65f60ab087efbfb39ec\", \"unix_time\": 1367941226, \"merch_lat\": 41.385064, \"merch_long\": -84.034719, \"is_fraud\": 0, \"merchant_label\": 30, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 47}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=605, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2915, timestamp=1715387651061, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-05 07:04:32\", \"cc_num\": 4798937978667559470, \"merchant\": \"fraud_Rutherford-Mertz\", \"category\": \"grocery_pos\", \"amt\": 57.04, \"first\": \"Robert\", \"last\": \"Williams\", \"gender\": \"M\", \"street\": \"09419 Lewis Rapids\", \"city\": \"Bay City\", \"state\": \"MI\", \"zip\": 48706, \"lat\": 43.6088, \"long\": -83.95299999999999, \"city_pop\": 67858, \"job\": \"Water quality scientist\", \"dob\": \"1995-03-13\", \"trans_num\": \"9a202314839c9fcb1739dc73663624e3\", \"unix_time\": 1349420672, \"merch_lat\": 44.202525, \"merch_long\": -83.026154, \"is_fraud\": 0, \"merchant_label\": 543, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 493}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=631, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2916, timestamp=1715387651063, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-02-01 23:09:40\", \"cc_num\": 30135235368675, \"merchant\": \"fraud_Schneider, Hayes and Nikolaus\", \"category\": \"food_dining\", \"amt\": 88.86, \"first\": \"Amanda\", \"last\": \"Williams\", \"gender\": \"F\", \"street\": \"02018 Gary Key Apt. 911\", \"city\": \"Independence\", \"state\": \"MO\", \"zip\": 64058, \"lat\": 39.1412, \"long\": -94.3515, \"city_pop\": 123373, \"job\": \"Engineer, production\", \"dob\": \"1992-11-27\", \"trans_num\": \"c378aba9611515abf3b5552438b23624\", \"unix_time\": 1359760180, \"merch_lat\": 39.132119, \"merch_long\": -93.62374, \"is_fraud\": 0, \"merchant_label\": 561, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 171}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=635, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2917, timestamp=1715387651064, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-31 14:45:47\", \"cc_num\": 3502088871723054, \"merchant\": \"fraud_Stark-Koss\", \"category\": \"home\", \"amt\": 85.72, \"first\": \"Scott\", \"last\": \"Martin\", \"gender\": \"M\", \"street\": \"31472 Cody Place Suite 740\", \"city\": \"Kensington\", \"state\": \"MD\", \"zip\": 20895, \"lat\": 39.0298, \"long\": -77.0793, \"city_pop\": 19054, \"job\": \"Operations geologist\", \"dob\": \"1976-09-08\", \"trans_num\": \"cf62c6395ff60f176f7efb74aafc331a\", \"unix_time\": 1383230747, \"merch_lat\": 38.769892, \"merch_long\": -76.992914, \"is_fraud\": 0, \"merchant_label\": 596, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 322}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2918, timestamp=1715387651066, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-24 06:43:44\", \"cc_num\": 4716561796955522, \"merchant\": \"fraud_Lind, Huel and McClure\", \"category\": \"gas_transport\", \"amt\": 67.37, \"first\": \"Lauren\", \"last\": \"Anderson\", \"gender\": \"F\", \"street\": \"11014 Chad Lake Apt. 573\", \"city\": \"Heart Butte\", \"state\": \"MT\", \"zip\": 59448, \"lat\": 48.2777, \"long\": -112.8456, \"city_pop\": 743, \"job\": \"Water engineer\", \"dob\": \"1972-05-04\", \"trans_num\": \"df8d4d3e0307004a4fb040deaefc8cc2\", \"unix_time\": 1382597024, \"merch_lat\": 49.009481, \"merch_long\": -111.90569, \"is_fraud\": 0, \"merchant_label\": 389, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 492}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=625, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2919, timestamp=1715387651067, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-28 19:47:56\", \"cc_num\": 213112402583773, \"merchant\": \"fraud_Lind-Buckridge\", \"category\": \"entertainment\", \"amt\": 34.17, \"first\": \"Ana\", \"last\": \"Howell\", \"gender\": \"F\", \"street\": \"4664 Sanchez Common Suite 930\", \"city\": \"Bradley\", \"state\": \"SC\", \"zip\": 29819, \"lat\": 34.0326, \"long\": -82.2027, \"city_pop\": 1523, \"job\": \"Research scientist (physical sciences)\", \"dob\": \"1984-06-03\", \"trans_num\": \"d0f869d0b47b9d12eb830ffbbd4110ab\", \"unix_time\": 1356724076, \"merch_lat\": 33.382863, \"merch_long\": -82.4449, \"is_fraud\": 0, \"merchant_label\": 390, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 397}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=634, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2920, timestamp=1715387651068, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-08 23:22:26\", \"cc_num\": 630441765090, \"merchant\": \"fraud_Wilkinson Ltd\", \"category\": \"entertainment\", \"amt\": 1.65, \"first\": \"Susan\", \"last\": \"Washington\", \"gender\": \"F\", \"street\": \"759 Erin Mount Suite 956\", \"city\": \"May\", \"state\": \"TX\", \"zip\": 76857, \"lat\": 31.9571, \"long\": -98.9656, \"city_pop\": 1791, \"job\": \"Corporate investment banker\", \"dob\": \"1965-07-26\", \"trans_num\": \"6d999c943ee7824b35b958eee197610b\", \"unix_time\": 1341789746, \"merch_lat\": 31.909953, \"merch_long\": -98.247559, \"is_fraud\": 0, \"merchant_label\": 666, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 111}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2921, timestamp=1715387651069, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-02-09 22:40:39\", \"cc_num\": 3583635130604947, \"merchant\": \"fraud_Runte-Mohr\", \"category\": \"food_dining\", \"amt\": 55.5, \"first\": \"Crystal\", \"last\": \"Gamble\", \"gender\": \"F\", \"street\": \"899 Michele View Suite 960\", \"city\": \"Philadelphia\", \"state\": \"PA\", \"zip\": 19149, \"lat\": 40.0369, \"long\": -75.0664, \"city_pop\": 1526206, \"job\": \"Structural engineer\", \"dob\": \"1985-01-01\", \"trans_num\": \"9e7bb3133ad1416895529e5fd83b681b\", \"unix_time\": 1328827239, \"merch_lat\": 39.284405, \"merch_long\": -75.460474, \"is_fraud\": 0, \"merchant_label\": 541, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 438}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=620, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2922, timestamp=1715387651071, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-27 07:35:44\", \"cc_num\": 4683520018489354, \"merchant\": \"fraud_Murray Ltd\", \"category\": \"grocery_net\", \"amt\": 78.38, \"first\": \"Charles\", \"last\": \"Carrillo\", \"gender\": \"M\", \"street\": \"17547 Stephen Turnpike Apt. 846\", \"city\": \"Hawthorne\", \"state\": \"CA\", \"zip\": 90250, \"lat\": 33.9143, \"long\": -118.3493, \"city_pop\": 93193, \"job\": \"Editor, magazine features\", \"dob\": \"1995-04-19\", \"trans_num\": \"b6d96b1b5860760e6ddc89ec02b4f9b9\", \"unix_time\": 1374910544, \"merch_lat\": 33.812847999999995, \"merch_long\": -119.210995, \"is_fraud\": 0, \"merchant_label\": 446, \"category_label\": 3, \"gender_label\": 1, \"job_label\": 142}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=640, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2923, timestamp=1715387654076, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-02-13 17:15:47\", \"cc_num\": 4060579726528237, \"merchant\": \"fraud_Ernser-Lynch\", \"category\": \"food_dining\", \"amt\": 78.68, \"first\": \"Steven\", \"last\": \"Sanders\", \"gender\": \"M\", \"street\": \"25955 Amy Via\", \"city\": \"Ozawkie\", \"state\": \"KS\", \"zip\": 66070, \"lat\": 39.2136, \"long\": -95.4404, \"city_pop\": 2661, \"job\": \"Theatre director\", \"dob\": \"1948-11-14\", \"trans_num\": \"889d08cec4c1fc6a6181740b178c6b8c\", \"unix_time\": 1329153347, \"merch_lat\": 38.333969, \"merch_long\": -95.942446, \"is_fraud\": 0, \"merchant_label\": 165, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 465}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=599, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2924, timestamp=1715387654078, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-30 15:20:24\", \"cc_num\": 4488258847705225890, \"merchant\": \"fraud_Schmeler-Howe\", \"category\": \"personal_care\", \"amt\": 20.56, \"first\": \"Jessica\", \"last\": \"Shaw\", \"gender\": \"F\", \"street\": \"5745 Blair Locks\", \"city\": \"West Columbia\", \"state\": \"SC\", \"zip\": 29170, \"lat\": 33.9568, \"long\": -81.1405, \"city_pop\": 52126, \"job\": \"Chemical engineer\", \"dob\": \"1929-08-23\", \"trans_num\": \"915e5fc2ff31b61d8420b0f0563824cf\", \"unix_time\": 1341069624, \"merch_lat\": 34.257782, \"merch_long\": -80.56238499999999, \"is_fraud\": 0, \"merchant_label\": 556, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 72}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=622, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2925, timestamp=1715387654079, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-10-02 20:28:26\", \"cc_num\": 3523898249167098, \"merchant\": \"fraud_Zboncak Ltd\", \"category\": \"food_dining\", \"amt\": 118.56, \"first\": \"Joshua\", \"last\": \"Carpenter\", \"gender\": \"M\", \"street\": \"04975 Allison Shoal\", \"city\": \"Bronx\", \"state\": \"NY\", \"zip\": 10463, \"lat\": 40.8798, \"long\": -73.9067, \"city_pop\": 1382480, \"job\": \"Therapist, drama\", \"dob\": \"1990-11-09\", \"trans_num\": \"9503a4775d4da08bb4a13f0414645906\", \"unix_time\": 1380745706, \"merch_lat\": 41.335272, \"merch_long\": -73.630717, \"is_fraud\": 0, \"merchant_label\": 686, \"category_label\": 1, \"gender_label\": 1, \"job_label\": 469}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=608, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2926, timestamp=1715387654081, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-16 22:12:22\", \"cc_num\": 3517527805128735, \"merchant\": \"fraud_Reichert, Shanahan and Hayes\", \"category\": \"shopping_net\", \"amt\": 1.36, \"first\": \"Tracy\", \"last\": \"Conway\", \"gender\": \"F\", \"street\": \"6778 Campos Field\", \"city\": \"Bonfield\", \"state\": \"IL\", \"zip\": 60913, \"lat\": 41.1573, \"long\": -88.0619, \"city_pop\": 1617, \"job\": \"Medical secretary\", \"dob\": \"1990-04-25\", \"trans_num\": \"27c253ecb47f60c9559cfad178e0eced\", \"unix_time\": 1342476742, \"merch_lat\": 41.736362, \"merch_long\": -88.473692, \"is_fraud\": 0, \"merchant_label\": 504, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 293}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=620, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2927, timestamp=1715387654083, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-26 02:48:15\", \"cc_num\": 6011348830550197, \"merchant\": \"fraud_Rau and Sons\", \"category\": \"grocery_pos\", \"amt\": 296.76, \"first\": \"Samuel\", \"last\": \"Johnston\", \"gender\": \"M\", \"street\": \"16285 Jessica Lights\", \"city\": \"Birmingham\", \"state\": \"AL\", \"zip\": 35229, \"lat\": 33.4629, \"long\": -86.7904, \"city_pop\": 493806, \"job\": \"Musician\", \"dob\": \"1980-07-12\", \"trans_num\": \"dbdce12d096f0cb711b2502253bcfb38\", \"unix_time\": 1335408495, \"merch_lat\": 33.041681, \"merch_long\": -87.696151, \"is_fraud\": 1, \"merchant_label\": 494, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 307}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=605, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2928, timestamp=1715387657089, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-07 18:25:28\", \"cc_num\": 3576021480694169, \"merchant\": \"fraud_Champlin and Sons\", \"category\": \"home\", \"amt\": 37.16, \"first\": \"Dawn\", \"last\": \"Gray\", \"gender\": \"F\", \"street\": \"9486 Joel Common Suite 554\", \"city\": \"Topeka\", \"state\": \"KS\", \"zip\": 66618, \"lat\": 39.1329, \"long\": -95.7023, \"city_pop\": 163415, \"job\": \"Secondary school teacher\", \"dob\": \"2004-12-30\", \"trans_num\": \"bbd29319398b6f5fcd9b41f59cd6894b\", \"unix_time\": 1357583128, \"merch_lat\": 38.645724, \"merch_long\": -95.623097, \"is_fraud\": 0, \"merchant_label\": 89, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 418}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2929, timestamp=1715387657089, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-05-04 00:40:07\", \"cc_num\": 30501624614310, \"merchant\": \"fraud_Hackett-Lueilwitz\", \"category\": \"grocery_pos\", \"amt\": 101.36, \"first\": \"Amanda\", \"last\": \"Smith\", \"gender\": \"F\", \"street\": \"180 Graves Shore\", \"city\": \"Scotia\", \"state\": \"SC\", \"zip\": 29939, \"lat\": 32.6786, \"long\": -81.2455, \"city_pop\": 302, \"job\": \"Magazine features editor\", \"dob\": \"1973-05-04\", \"trans_num\": \"c83cda9d28906e9da46b2537e850fb75\", \"unix_time\": 1336092007, \"merch_lat\": 31.929142, \"merch_long\": -81.238501, \"is_fraud\": 0, \"merchant_label\": 217, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 278}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=610, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2930, timestamp=1715387657091, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-30 03:37:17\", \"cc_num\": 4239436242473, \"merchant\": \"fraud_Prohaska-Murray\", \"category\": \"gas_transport\", \"amt\": 74.75, \"first\": \"James\", \"last\": \"Leon\", \"gender\": \"M\", \"street\": \"826 Benjamin Stravenue\", \"city\": \"Alexandria\", \"state\": \"VA\", \"zip\": 22311, \"lat\": 38.832, \"long\": -77.12, \"city_pop\": 321490, \"job\": \"Scientist, biomedical\", \"dob\": \"1991-10-04\", \"trans_num\": \"99139f24f18148b1fa50d14f350819e9\", \"unix_time\": 1343619437, \"merch_lat\": 38.998015, \"merch_long\": -76.939809, \"is_fraud\": 0, \"merchant_label\": 488, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 411}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2931, timestamp=1715387660097, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-03-19 02:38:17\", \"cc_num\": 30248898834493, \"merchant\": \"fraud_Ankunding LLC\", \"category\": \"shopping_net\", \"amt\": 2.41, \"first\": \"Michael\", \"last\": \"Rodriguez\", \"gender\": \"M\", \"street\": \"172 Paula Inlet Apt. 650\", \"city\": \"Cross Plains\", \"state\": \"TX\", \"zip\": 76443, \"lat\": 32.1482, \"long\": -99.1872, \"city_pop\": 1897, \"job\": \"Chief Operating Officer\", \"dob\": \"1953-04-19\", \"trans_num\": \"865d31e9cd2db4ebd17b1ef96b72c99d\", \"unix_time\": 1363660697, \"merch_lat\": 32.576263, \"merch_long\": -99.323467, \"is_fraud\": 0, \"merchant_label\": 8, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 77}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=622, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2932, timestamp=1715387660098, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-02 08:07:57\", \"cc_num\": 4147608975828480, \"merchant\": \"fraud_Harris Inc\", \"category\": \"gas_transport\", \"amt\": 51.29, \"first\": \"Edward\", \"last\": \"Tapia\", \"gender\": \"M\", \"street\": \"354 Gutierrez Gateway\", \"city\": \"Comfrey\", \"state\": \"MN\", \"zip\": 56019, \"lat\": 44.1111, \"long\": -94.9134, \"city_pop\": 914, \"job\": \"Health and safety adviser\", \"dob\": \"1944-07-26\", \"trans_num\": \"e5ea6f52f7b2012acdc62f66c239da2c\", \"unix_time\": 1338624477, \"merch_lat\": 43.396612, \"merch_long\": -94.435077, \"is_fraud\": 0, \"merchant_label\": 231, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 218}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=613, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2933, timestamp=1715387660100, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-15 01:53:50\", \"cc_num\": 675909898057, \"merchant\": \"fraud_Watsica, Haag and Considine\", \"category\": \"shopping_pos\", \"amt\": 9.97, \"first\": \"Christopher\", \"last\": \"Henry\", \"gender\": \"M\", \"street\": \"1198 Robert Stravenue Apt. 479\", \"city\": \"Armonk\", \"state\": \"NY\", \"zip\": 10504, \"lat\": 41.136, \"long\": -73.7009, \"city_pop\": 7987, \"job\": \"Television/film/video producer\", \"dob\": \"1964-03-16\", \"trans_num\": \"006bca7cd4c77ae0c543100fc4a831f1\", \"unix_time\": 1379210030, \"merch_lat\": 41.442496000000006, \"merch_long\": -73.149936, \"is_fraud\": 0, \"merchant_label\": 656, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 463}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=652, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2934, timestamp=1715387660101, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-07-28 12:31:13\", \"cc_num\": 3528231451607350, \"merchant\": \"fraud_Shields-Wunsch\", \"category\": \"health_fitness\", \"amt\": 13.76, \"first\": \"Lauren\", \"last\": \"Moreno\", \"gender\": \"F\", \"street\": \"83719 Wilson Shore\", \"city\": \"Heislerville\", \"state\": \"NJ\", \"zip\": 8324, \"lat\": 39.224, \"long\": -74.9942, \"city_pop\": 526, \"job\": \"Exercise physiologist\", \"dob\": \"1940-09-06\", \"trans_num\": \"f57dcd97bcb0bf51968f1eeb3ca0ab74\", \"unix_time\": 1343478673, \"merch_lat\": 38.330198, \"merch_long\": -75.82600500000001, \"is_fraud\": 0, \"merchant_label\": 579, \"category_label\": 5, \"gender_label\": 0, \"job_label\": 187}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=623, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2935, timestamp=1715387663108, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-07 17:01:43\", \"cc_num\": 378904938837132, \"merchant\": \"fraud_Reichert, Huels and Hoppe\", \"category\": \"shopping_net\", \"amt\": 8.42, \"first\": \"Tina\", \"last\": \"Zimmerman\", \"gender\": \"F\", \"street\": \"3595 Susan Island Suite 063\", \"city\": \"Thomas\", \"state\": \"OK\", \"zip\": 73669, \"lat\": 35.7382, \"long\": -98.7388, \"city_pop\": 1675, \"job\": \"Barrister\", \"dob\": \"1986-05-01\", \"trans_num\": \"fe057523371a238ff8360c1be8dc5c36\", \"unix_time\": 1354899703, \"merch_lat\": 36.120786, \"merch_long\": -99.197262, \"is_fraud\": 0, \"merchant_label\": 502, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 44}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2936, timestamp=1715387663109, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-06 13:53:21\", \"cc_num\": 6011388901471808, \"merchant\": \"fraud_Reilly and Sons\", \"category\": \"health_fitness\", \"amt\": 38.55, \"first\": \"Jacqueline\", \"last\": \"Marsh\", \"gender\": \"F\", \"street\": \"950 Sheryl Spurs\", \"city\": \"Dunlevy\", \"state\": \"PA\", \"zip\": 15432, \"lat\": 40.1151, \"long\": -79.8627, \"city_pop\": 427, \"job\": \"Mining engineer\", \"dob\": \"1951-02-05\", \"trans_num\": \"4208d0df5187d520eb780c6ae03cadbd\", \"unix_time\": 1375797201, \"merch_lat\": 39.936554, \"merch_long\": -80.054612, \"is_fraud\": 0, \"merchant_label\": 507, \"category_label\": 5, \"gender_label\": 0, \"job_label\": 299}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=608, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2937, timestamp=1715387663110, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-09 01:19:35\", \"cc_num\": 6011438889172900, \"merchant\": \"fraud_Kemmer-Buckridge\", \"category\": \"misc_pos\", \"amt\": 245.85, \"first\": \"Allison\", \"last\": \"Allen\", \"gender\": \"F\", \"street\": \"40624 Rebecca Spurs\", \"city\": \"De Witt\", \"state\": \"AR\", \"zip\": 72042, \"lat\": 34.2853, \"long\": -91.3336, \"city_pop\": 5161, \"job\": \"Electrical engineer\", \"dob\": \"1993-04-08\", \"trans_num\": \"bfb6f805e85f8de937b62bd8c4285b2f\", \"unix_time\": 1370740775, \"merch_lat\": 34.201525, \"merch_long\": -91.862545, \"is_fraud\": 0, \"merchant_label\": 298, \"category_label\": 9, \"gender_label\": 0, \"job_label\": 147}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2938, timestamp=1715387663110, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-22 11:03:05\", \"cc_num\": 180040027502291, \"merchant\": \"fraud_Stanton, Jakubowski and Baumbach\", \"category\": \"shopping_net\", \"amt\": 2.46, \"first\": \"Mary\", \"last\": \"Schmidt\", \"gender\": \"F\", \"street\": \"022 Moore Island\", \"city\": \"New York City\", \"state\": \"NY\", \"zip\": 10162, \"lat\": 40.7699, \"long\": -73.9511, \"city_pop\": 1577385, \"job\": \"Audiological scientist\", \"dob\": \"1957-12-29\", \"trans_num\": \"1b8b417a08ce3b9d75e1055815bc2be2\", \"unix_time\": 1356174185, \"merch_lat\": 41.606335, \"merch_long\": -74.114358, \"is_fraud\": 0, \"merchant_label\": 594, \"category_label\": 11, \"gender_label\": 0, \"job_label\": 42}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=634, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2939, timestamp=1715387663112, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-05-24 04:16:25\", \"cc_num\": 4658490815480264, \"merchant\": \"fraud_Raynor, Reinger and Hagenes\", \"category\": \"gas_transport\", \"amt\": 61.31, \"first\": \"Tara\", \"last\": \"Richards\", \"gender\": \"F\", \"street\": \"4879 Cristina Station\", \"city\": \"Keisterville\", \"state\": \"PA\", \"zip\": 15449, \"lat\": 39.9636, \"long\": -79.7853, \"city_pop\": 184, \"job\": \"Systems developer\", \"dob\": \"1945-11-04\", \"trans_num\": \"89a829ca782e50c5b9e7897eec8aeb74\", \"unix_time\": 1337832985, \"merch_lat\": 39.498664, \"merch_long\": -79.217388, \"is_fraud\": 0, \"merchant_label\": 498, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 447}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=628, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2940, timestamp=1715387663114, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-09-29 21:29:23\", \"cc_num\": 6534628260579800, \"merchant\": \"fraud_Hilpert-Conroy\", \"category\": \"kids_pets\", \"amt\": 25.51, \"first\": \"Christine\", \"last\": \"Harris\", \"gender\": \"F\", \"street\": \"29606 Martinez Views Suite 653\", \"city\": \"Hinesburg\", \"state\": \"VT\", \"zip\": 5461, \"lat\": 44.3346, \"long\": -73.098, \"city_pop\": 4542, \"job\": \"Claims inspector/assessor\", \"dob\": \"1998-03-19\", \"trans_num\": \"3ba43169dbb1850fa4d78fe3ae35fd56\", \"unix_time\": 1348954163, \"merch_lat\": 43.644571, \"merch_long\": -73.30207, \"is_fraud\": 0, \"merchant_label\": 257, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 86}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=625, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2941, timestamp=1715387663115, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-02-06 20:20:39\", \"cc_num\": 4003989662068504, \"merchant\": \"fraud_Douglas-White\", \"category\": \"entertainment\", \"amt\": 12.31, \"first\": \"Chris\", \"last\": \"White\", \"gender\": \"M\", \"street\": \"98897 Bennett Lodge\", \"city\": \"Bessemer\", \"state\": \"AL\", \"zip\": 35022, \"lat\": 33.3224, \"long\": -86.9657, \"city_pop\": 71463, \"job\": \"Radio broadcast assistant\", \"dob\": \"1989-02-08\", \"trans_num\": \"ad366be5e36dfc073dbee14b1cc02ab3\", \"unix_time\": 1328559639, \"merch_lat\": 33.021044, \"merch_long\": -87.839013, \"is_fraud\": 0, \"merchant_label\": 145, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 386}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2942, timestamp=1715387663117, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-26 04:29:37\", \"cc_num\": 571365235126, \"merchant\": \"fraud_Kutch and Sons\", \"category\": \"grocery_pos\", \"amt\": 88.6, \"first\": \"Barbara\", \"last\": \"Taylor\", \"gender\": \"F\", \"street\": \"0069 Robin Brooks Apt. 695\", \"city\": \"Elberta\", \"state\": \"MI\", \"zip\": 49628, \"lat\": 44.5995, \"long\": -86.2141, \"city_pop\": 372, \"job\": \"Exhibitions officer, museum/gallery\", \"dob\": \"1995-07-12\", \"trans_num\": \"78d45b726f5a47ceba969e086e3fa385\", \"unix_time\": 1380169777, \"merch_lat\": 45.124931, \"merch_long\": -85.462125, \"is_fraud\": 0, \"merchant_label\": 359, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 189}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=627, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2943, timestamp=1715387663119, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-17 17:27:05\", \"cc_num\": 180094608895855, \"merchant\": \"fraud_Terry Ltd\", \"category\": \"home\", \"amt\": 100.28, \"first\": \"Tammie\", \"last\": \"Harper\", \"gender\": \"F\", \"street\": \"57887 Gutierrez Harbor\", \"city\": \"Westfir\", \"state\": \"OR\", \"zip\": 97492, \"lat\": 43.7575, \"long\": -122.481, \"city_pop\": 597, \"job\": \"Forensic psychologist\", \"dob\": \"1961-05-19\", \"trans_num\": \"2f20cee79395e534bcf2fa60004c7bb5\", \"unix_time\": 1339954025, \"merch_lat\": 42.948423, \"merch_long\": -122.68007, \"is_fraud\": 0, \"merchant_label\": 614, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 201}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=601, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2944, timestamp=1715387663119, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-05-31 14:32:55\", \"cc_num\": 2712209726293386, \"merchant\": \"fraud_Kutch-Wilderman\", \"category\": \"home\", \"amt\": 49.89, \"first\": \"Jenna\", \"last\": \"Brooks\", \"gender\": \"F\", \"street\": \"50872 Alex Plain Suite 088\", \"city\": \"Baton Rouge\", \"state\": \"LA\", \"zip\": 70808, \"lat\": 30.4066, \"long\": -91.1468, \"city_pop\": 378909, \"job\": \"Designer, furniture\", \"dob\": \"1977-02-22\", \"trans_num\": \"c35784afa97c6216e7a554a2479c09da\", \"unix_time\": 1370010775, \"merch_lat\": 30.189652, \"merch_long\": -90.874361, \"is_fraud\": 0, \"merchant_label\": 364, \"category_label\": 6, \"gender_label\": 0, \"job_label\": 123}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=615, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2945, timestamp=1715387666124, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-08-27 13:13:13\", \"cc_num\": 2703186189652095, \"merchant\": \"fraud_Padberg-Rogahn\", \"category\": \"entertainment\", \"amt\": 87.28, \"first\": \"Jennifer\", \"last\": \"Banks\", \"gender\": \"F\", \"street\": \"561 Perry Cove\", \"city\": \"Moravian Falls\", \"state\": \"NC\", \"zip\": 28654, \"lat\": 36.0788, \"long\": -81.1781, \"city_pop\": 3495, \"job\": \"Psychologist, counselling\", \"dob\": \"1988-03-09\", \"trans_num\": \"570fa6db6953b6be89f815bc782f39fc\", \"unix_time\": 1346073193, \"merch_lat\": 36.193472, \"merch_long\": -81.216571, \"is_fraud\": 0, \"merchant_label\": 470, \"category_label\": 0, \"gender_label\": 0, \"job_label\": 372}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=620, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2946, timestamp=1715387666126, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-11-11 08:39:12\", \"cc_num\": 213163860545705, \"merchant\": \"fraud_Wolf Inc\", \"category\": \"grocery_pos\", \"amt\": 105.39, \"first\": \"Mark\", \"last\": \"Tyler\", \"gender\": \"M\", \"street\": \"82201 Bradley Radial Suite 703\", \"city\": \"Avera\", \"state\": \"GA\", \"zip\": 30803, \"lat\": 33.141, \"long\": -82.515, \"city_pop\": 741, \"job\": \"Claims inspector/assessor\", \"dob\": \"1986-04-28\", \"trans_num\": \"b72eba19c46d653039d87d68bf31df3e\", \"unix_time\": 1384159152, \"merch_lat\": 33.120804, \"merch_long\": -82.310142, \"is_fraud\": 0, \"merchant_label\": 678, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 86}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=611, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2947, timestamp=1715387666128, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-29 19:38:25\", \"cc_num\": 377895991033232, \"merchant\": \"fraud_Lang, Towne and Schuppe\", \"category\": \"kids_pets\", \"amt\": 102.3, \"first\": \"Kimberly\", \"last\": \"Myers\", \"gender\": \"F\", \"street\": \"6881 King Isle Suite 228\", \"city\": \"Higganum\", \"state\": \"CT\", \"zip\": 6441, \"lat\": 41.4682, \"long\": -72.5751, \"city_pop\": 5438, \"job\": \"Librarian, academic\", \"dob\": \"1964-11-17\", \"trans_num\": \"20d95f2e9b2105b3941b03608988a7da\", \"unix_time\": 1372534705, \"merch_lat\": 40.795829, \"merch_long\": -72.185243, \"is_fraud\": 0, \"merchant_label\": 369, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 271}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=621, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2948, timestamp=1715387666128, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-11 01:10:21\", \"cc_num\": 4344955088481397, \"merchant\": \"fraud_Casper, Hand and Zulauf\", \"category\": \"grocery_pos\", \"amt\": 112.83, \"first\": \"Christopher\", \"last\": \"Rodgers\", \"gender\": \"M\", \"street\": \"30587 Fox Shores Apt. 627\", \"city\": \"Fenelton\", \"state\": \"PA\", \"zip\": 16034, \"lat\": 40.8555, \"long\": -79.7372, \"city_pop\": 2054, \"job\": \"Communications engineer\", \"dob\": \"1976-09-29\", \"trans_num\": \"620d65b43e2c9f4841c40dfc840d5ca2\", \"unix_time\": 1365642621, \"merch_lat\": 40.274675, \"merch_long\": -78.889988, \"is_fraud\": 0, \"merchant_label\": 87, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 96}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=634, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2949, timestamp=1715387666131, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-29 00:12:08\", \"cc_num\": 501802953619, \"merchant\": \"fraud_Raynor, Reinger and Hagenes\", \"category\": \"gas_transport\", \"amt\": 83.12, \"first\": \"Robert\", \"last\": \"Flores\", \"gender\": \"M\", \"street\": \"3277 Fields Meadows Apt. 790\", \"city\": \"Greenview\", \"state\": \"CA\", \"zip\": 96037, \"lat\": 41.5403, \"long\": -122.9366, \"city_pop\": 308, \"job\": \"Call centre manager\", \"dob\": \"1958-09-20\", \"trans_num\": \"7dae8bb2265d02e4d895f74d7640e78e\", \"unix_time\": 1375056728, \"merch_lat\": 41.856226, \"merch_long\": -123.316019, \"is_fraud\": 0, \"merchant_label\": 498, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 59}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=631, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2950, timestamp=1715387666133, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-18 21:33:00\", \"cc_num\": 180047222886866, \"merchant\": \"fraud_Haag-Blanda\", \"category\": \"food_dining\", \"amt\": 19.28, \"first\": \"Christine\", \"last\": \"Shaffer\", \"gender\": \"F\", \"street\": \"14017 Thomas Plaza\", \"city\": \"Loami\", \"state\": \"IL\", \"zip\": 62661, \"lat\": 39.6704, \"long\": -89.8588, \"city_pop\": 1213, \"job\": \"English as a foreign language teacher\", \"dob\": \"1991-04-22\", \"trans_num\": \"92b725c979636820ccd2cc03c4b8cba4\", \"unix_time\": 1376861580, \"merch_lat\": 38.914911, \"merch_long\": -89.043832, \"is_fraud\": 0, \"merchant_label\": 215, \"category_label\": 1, \"gender_label\": 0, \"job_label\": 177}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=624, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2951, timestamp=1715387666134, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-13 14:49:15\", \"cc_num\": 4996263498048679, \"merchant\": \"fraud_Labadie LLC\", \"category\": \"personal_care\", \"amt\": 12.3, \"first\": \"Kendra\", \"last\": \"King\", \"gender\": \"F\", \"street\": \"154 Hernandez Keys\", \"city\": \"Smith River\", \"state\": \"CA\", \"zip\": 95567, \"lat\": 41.9404, \"long\": -124.1587, \"city_pop\": 1930, \"job\": \"Web designer\", \"dob\": \"1983-06-13\", \"trans_num\": \"fed3eb838e5036a3c59647403d416cae\", \"unix_time\": 1371134955, \"merch_lat\": 42.089021, \"merch_long\": -124.902313, \"is_fraud\": 0, \"merchant_label\": 366, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 494}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=604, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2952, timestamp=1715387666135, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-29 10:19:03\", \"cc_num\": 30030380240193, \"merchant\": \"fraud_McDermott-Rice\", \"category\": \"misc_pos\", \"amt\": 34.83, \"first\": \"William\", \"last\": \"Jenkins\", \"gender\": \"M\", \"street\": \"50614 Kevin Point\", \"city\": \"Harper\", \"state\": \"TX\", \"zip\": 78631, \"lat\": 30.2816, \"long\": -99.241, \"city_pop\": 2395, \"job\": \"Pharmacist, community\", \"dob\": \"1993-11-17\", \"trans_num\": \"efddba216a5e67eae9860d64b7b1d24e\", \"unix_time\": 1335694743, \"merch_lat\": 30.203897, \"merch_long\": -98.395416, \"is_fraud\": 0, \"merchant_label\": 414, \"category_label\": 9, \"gender_label\": 1, \"job_label\": 336}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=604, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2953, timestamp=1715387666136, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-03-17 15:42:39\", \"cc_num\": 3529597930342630, \"merchant\": \"fraud_Johnson, Runolfsdottir and Mayer\", \"category\": \"misc_net\", \"amt\": 3.8, \"first\": \"Melissa\", \"last\": \"Rodriguez\", \"gender\": \"F\", \"street\": \"81708 Christopher Plaza\", \"city\": \"Jordanville\", \"state\": \"NY\", \"zip\": 13361, \"lat\": 42.8948, \"long\": -74.8209, \"city_pop\": 824, \"job\": \"Travel agency manager\", \"dob\": \"1985-09-01\", \"trans_num\": \"509879cb0c8d4620da038b1a8c0fe06f\", \"unix_time\": 1331998959, \"merch_lat\": 42.546055, \"merch_long\": -75.521976, \"is_fraud\": 0, \"merchant_label\": 290, \"category_label\": 8, \"gender_label\": 0, \"job_label\": 483}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=635, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2954, timestamp=1715387666137, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-04-22 02:51:39\", \"cc_num\": 4601636330889, \"merchant\": \"fraud_Ledner-Pfannerstill\", \"category\": \"gas_transport\", \"amt\": 83.56, \"first\": \"Mark\", \"last\": \"Rivera\", \"gender\": \"M\", \"street\": \"383 Contreras Hills Suite 658\", \"city\": \"Humble\", \"state\": \"TX\", \"zip\": 77338, \"lat\": 30.0041, \"long\": -95.2825, \"city_pop\": 194500, \"job\": \"Tax adviser\", \"dob\": \"1990-12-18\", \"trans_num\": \"f22b6fa6924fd02abddf600f9c595dc4\", \"unix_time\": 1366599099, \"merch_lat\": 30.925714000000003, \"merch_long\": -94.86052, \"is_fraud\": 0, \"merchant_label\": 381, \"category_label\": 2, \"gender_label\": 1, \"job_label\": 449}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=622, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2955, timestamp=1715387669144, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-04-17 22:44:45\", \"cc_num\": 6011438889172900, \"merchant\": \"fraud_Mayert Group\", \"category\": \"shopping_pos\", \"amt\": 8.9, \"first\": \"Allison\", \"last\": \"Allen\", \"gender\": \"F\", \"street\": \"40624 Rebecca Spurs\", \"city\": \"De Witt\", \"state\": \"AR\", \"zip\": 72042, \"lat\": 34.2853, \"long\": -91.3336, \"city_pop\": 5161, \"job\": \"Electrical engineer\", \"dob\": \"1993-04-08\", \"trans_num\": \"5de1cda0b250a2721583c86b511d97cf\", \"unix_time\": 1334702685, \"merch_lat\": 34.289664, \"merch_long\": -91.806186, \"is_fraud\": 0, \"merchant_label\": 409, \"category_label\": 12, \"gender_label\": 0, \"job_label\": 147}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2956, timestamp=1715387669145, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-13 15:55:59\", \"cc_num\": 3553629419254918, \"merchant\": \"fraud_Nolan-Williamson\", \"category\": \"kids_pets\", \"amt\": 30.73, \"first\": \"Sharon\", \"last\": \"Johnson\", \"gender\": \"F\", \"street\": \"7202 Jeffrey Mills\", \"city\": \"Conway\", \"state\": \"WA\", \"zip\": 98238, \"lat\": 48.34, \"long\": -122.3456, \"city_pop\": 85, \"job\": \"Research officer, political party\", \"dob\": \"1984-09-01\", \"trans_num\": \"7dd23953dc00dac8b95ffd8ff8895e0b\", \"unix_time\": 1386950159, \"merch_lat\": 48.653853000000005, \"merch_long\": -122.789544, \"is_fraud\": 0, \"merchant_label\": 455, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 392}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=629, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2957, timestamp=1715387669147, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-14 00:31:29\", \"cc_num\": 4797297220948468262, \"merchant\": \"fraud_Rau and Sons\", \"category\": \"grocery_pos\", \"amt\": 125.11, \"first\": \"Erica\", \"last\": \"Briggs\", \"gender\": \"F\", \"street\": \"3310 Davidson Spurs Apt. 107\", \"city\": \"Oolitic\", \"state\": \"IN\", \"zip\": 47451, \"lat\": 38.8938, \"long\": -86.5246, \"city_pop\": 1228, \"job\": \"Counsellor\", \"dob\": \"1991-03-13\", \"trans_num\": \"c1fb1f0ca91eef8906a4f749e2245d6c\", \"unix_time\": 1386981089, \"merch_lat\": 39.875304, \"merch_long\": -85.81849, \"is_fraud\": 0, \"merchant_label\": 494, \"category_label\": 4, \"gender_label\": 0, \"job_label\": 113}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2958, timestamp=1715387669147, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-07-11 18:32:22\", \"cc_num\": 180031190491743, \"merchant\": \"fraud_Hoppe-Parisian\", \"category\": \"kids_pets\", \"amt\": 33.32, \"first\": \"Becky\", \"last\": \"Mckinney\", \"gender\": \"F\", \"street\": \"250 Benjamin Hill Apt. 026\", \"city\": \"Mobile\", \"state\": \"AL\", \"zip\": 36617, \"lat\": 30.7145, \"long\": -88.0918, \"city_pop\": 270712, \"job\": \"Surveyor, land/geomatics\", \"dob\": \"1972-01-05\", \"trans_num\": \"2814571568741c8cff608081cc9bdb1d\", \"unix_time\": 1373567542, \"merch_lat\": 29.991101, \"merch_long\": -88.816131, \"is_fraud\": 0, \"merchant_label\": 264, \"category_label\": 7, \"gender_label\": 0, \"job_label\": 442}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=620, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2959, timestamp=1715387669150, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-08-20 22:18:26\", \"cc_num\": 4623560839669, \"merchant\": \"fraud_Goldner-Lemke\", \"category\": \"entertainment\", \"amt\": 75.84, \"first\": \"Vincent\", \"last\": \"Waller\", \"gender\": \"M\", \"street\": \"9379 Vanessa Run Apt. 400\", \"city\": \"Lohrville\", \"state\": \"IA\", \"zip\": 51453, \"lat\": 42.2619, \"long\": -94.5566, \"city_pop\": 695, \"job\": \"Administrator\", \"dob\": \"1954-07-15\", \"trans_num\": \"a1282cbc215ffd7b591d2d1882bc2517\", \"unix_time\": 1345501106, \"merch_lat\": 42.857418, \"merch_long\": -94.603469, \"is_fraud\": 0, \"merchant_label\": 195, \"category_label\": 0, \"gender_label\": 1, \"job_label\": 6}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=607, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2960, timestamp=1715387669152, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-15 16:05:43\", \"cc_num\": 4149238353975790, \"merchant\": \"fraud_O\\'Reilly, Mohr and Purdy\", \"category\": \"home\", \"amt\": 72.43, \"first\": \"Tanner\", \"last\": \"Carroll\", \"gender\": \"M\", \"street\": \"494 Burke Ports\", \"city\": \"Cokeburg\", \"state\": \"PA\", \"zip\": 15324, \"lat\": 40.1008, \"long\": -80.0652, \"city_pop\": 632, \"job\": \"Dealer\", \"dob\": \"1989-04-08\", \"trans_num\": \"502d0de0271602eb764de7a7432bc4f7\", \"unix_time\": 1387123543, \"merch_lat\": 39.995642, \"merch_long\": -80.129565, \"is_fraud\": 0, \"merchant_label\": 461, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 120}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=596, serialized_header_size=-1)\n",
      "Error in transaction: <Error from server: code=2000 [Syntax error in CQL query] message=\"line 1:141 mismatched input 'Reilly' expecting EOF (... INTO bigdata.transaction_data JSON '{\"trans_date_trans_time\": \"2020-12-15 16:05:43\", \"cc_num\": 4149238353975790, \"merchant\": \"fraud_O'[Reilly]...)\">\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2961, timestamp=1715387669154, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-06-19 23:26:00\", \"cc_num\": 30044330818990, \"merchant\": \"fraud_Hills-Boyer\", \"category\": \"personal_care\", \"amt\": 34.12, \"first\": \"Allison\", \"last\": \"Ayala\", \"gender\": \"F\", \"street\": \"87665 Karen Mill Apt. 586\", \"city\": \"Fort Myers\", \"state\": \"FL\", \"zip\": 33967, \"lat\": 26.4722, \"long\": -81.8122, \"city_pop\": 224256, \"job\": \"Paramedic\", \"dob\": \"1985-08-29\", \"trans_num\": \"2fd3e8ebad518b96952c546b4bd3982a\", \"unix_time\": 1371684360, \"merch_lat\": 25.832884, \"merch_long\": -82.590501, \"is_fraud\": 0, \"merchant_label\": 254, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 329}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=608, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2962, timestamp=1715387669156, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-09 08:43:46\", \"cc_num\": 4306586894261180, \"merchant\": \"fraud_Morissette, Weber and Wiegand\", \"category\": \"grocery_net\", \"amt\": 89.18, \"first\": \"Renee\", \"last\": \"Walls\", \"gender\": \"F\", \"street\": \"86542 Jessica Fords Apt. 706\", \"city\": \"Veedersburg\", \"state\": \"IN\", \"zip\": 47987, \"lat\": 40.1186, \"long\": -87.2602, \"city_pop\": 4049, \"job\": \"Development worker, community\", \"dob\": \"1959-10-19\", \"trans_num\": \"5366d23dee90750babec6f67d52c7020\", \"unix_time\": 1355042626, \"merch_lat\": 40.038245, \"merch_long\": -86.442449, \"is_fraud\": 0, \"merchant_label\": 439, \"category_label\": 3, \"gender_label\": 0, \"job_label\": 130}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=645, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2963, timestamp=1715387672161, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-10-10 19:46:46\", \"cc_num\": 6011652924285713, \"merchant\": \"fraud_Homenick LLC\", \"category\": \"personal_care\", \"amt\": 7.43, \"first\": \"Kathryn\", \"last\": \"Smith\", \"gender\": \"F\", \"street\": \"19838 Tonya Prairie Apt. 947\", \"city\": \"Rocky Mount\", \"state\": \"MO\", \"zip\": 65072, \"lat\": 38.2911, \"long\": -92.7059, \"city_pop\": 1847, \"job\": \"Tax inspector\", \"dob\": \"1988-10-26\", \"trans_num\": \"cee3e7746bf733aa6f7b2c8153eff5a5\", \"unix_time\": 1349898406, \"merch_lat\": 37.485574, \"merch_long\": -93.552546, \"is_fraud\": 0, \"merchant_label\": 262, \"category_label\": 10, \"gender_label\": 0, \"job_label\": 450}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=616, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2964, timestamp=1715387672163, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-01-27 12:51:34\", \"cc_num\": 6596735789587928, \"merchant\": \"fraud_Kautzer and Sons\", \"category\": \"personal_care\", \"amt\": 34.98, \"first\": \"Spencer\", \"last\": \"Williams\", \"gender\": \"M\", \"street\": \"1145 Tony Drive Suite 080\", \"city\": \"Watertown\", \"state\": \"MN\", \"zip\": 55388, \"lat\": 44.9595, \"long\": -93.8482, \"city_pop\": 5619, \"job\": \"Licensed conveyancer\", \"dob\": \"1959-01-15\", \"trans_num\": \"63f2cc51632ebd120a78a78313d359f2\", \"unix_time\": 1359291094, \"merch_lat\": 44.599993, \"merch_long\": -94.365083, \"is_fraud\": 0, \"merchant_label\": 296, \"category_label\": 10, \"gender_label\": 1, \"job_label\": 273}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=626, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2965, timestamp=1715387672164, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-09-29 07:13:51\", \"cc_num\": 639030014711, \"merchant\": \"fraud_Bailey-Morar\", \"category\": \"grocery_pos\", \"amt\": 119.23, \"first\": \"Stephen\", \"last\": \"Lopez\", \"gender\": \"M\", \"street\": \"696 Matthew Ford Suite 157\", \"city\": \"Olmsted\", \"state\": \"IL\", \"zip\": 62970, \"lat\": 37.1935, \"long\": -89.0933, \"city_pop\": 639, \"job\": \"Mechanical engineer\", \"dob\": \"1982-08-01\", \"trans_num\": \"8471f6a4be4aef5a615c8940a2d4d515\", \"unix_time\": 1380438831, \"merch_lat\": 37.999729, \"merch_long\": -89.616478, \"is_fraud\": 0, \"merchant_label\": 20, \"category_label\": 4, \"gender_label\": 1, \"job_label\": 288}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=609, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2966, timestamp=1715387672165, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-06-13 04:07:14\", \"cc_num\": 3562264947797243, \"merchant\": \"fraud_Goyette, Howell and Collier\", \"category\": \"shopping_pos\", \"amt\": 1.24, \"first\": \"Anthony\", \"last\": \"Velasquez\", \"gender\": \"M\", \"street\": \"609 Hunt Grove\", \"city\": \"Saint Francis\", \"state\": \"KY\", \"zip\": 40062, \"lat\": 37.6047, \"long\": -85.4251, \"city_pop\": 301, \"job\": \"Research officer, political party\", \"dob\": \"1967-03-17\", \"trans_num\": \"15e975600a97b218c52e4a12de060cdd\", \"unix_time\": 1339560434, \"merch_lat\": 36.900745, \"merch_long\": -85.090213, \"is_fraud\": 0, \"merchant_label\": 201, \"category_label\": 12, \"gender_label\": 1, \"job_label\": 392}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=641, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2967, timestamp=1715387672166, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-11-13 18:45:43\", \"cc_num\": 4301028321766222513, \"merchant\": \"fraud_Leannon-Nikolaus\", \"category\": \"travel\", \"amt\": 465.74, \"first\": \"Joe\", \"last\": \"Howard\", \"gender\": \"M\", \"street\": \"109 Brian Lights Apt. 504\", \"city\": \"Shippingport\", \"state\": \"PA\", \"zip\": 15077, \"lat\": 40.6025, \"long\": -80.3863, \"city_pop\": 198, \"job\": \"Secretary/administrator\", \"dob\": \"1978-10-26\", \"trans_num\": \"1529a4ff5115b266377661a9130b9bed\", \"unix_time\": 1352832343, \"merch_lat\": 41.438082, \"merch_long\": -79.765033, \"is_fraud\": 0, \"merchant_label\": 377, \"category_label\": 13, \"gender_label\": 1, \"job_label\": 419}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=622, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2968, timestamp=1715387675172, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-01-04 06:26:16\", \"cc_num\": 30546453310167, \"merchant\": \"fraud_Dach-Nader\", \"category\": \"misc_net\", \"amt\": 6.24, \"first\": \"Nicholas\", \"last\": \"Tran\", \"gender\": \"M\", \"street\": \"672 Randall Burg Suite 551\", \"city\": \"Belmont\", \"state\": \"NH\", \"zip\": 3220, \"lat\": 43.4512, \"long\": -71.48899999999999, \"city_pop\": 7430, \"job\": \"Scientist, research (medical)\", \"dob\": \"1955-01-13\", \"trans_num\": \"8347cfd69ef7fc3892cb696adf39f12d\", \"unix_time\": 1325658376, \"merch_lat\": 42.878689, \"merch_long\": -70.93820699999999, \"is_fraud\": 0, \"merchant_label\": 121, \"category_label\": 8, \"gender_label\": 1, \"job_label\": 416}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=633, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2969, timestamp=1715387675173, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-08-18 00:53:46\", \"cc_num\": 38052002992326, \"merchant\": \"fraud_Christiansen, Goyette and Schamberger\", \"category\": \"gas_transport\", \"amt\": 69.9, \"first\": \"Anna\", \"last\": \"Logan\", \"gender\": \"F\", \"street\": \"3522 Park Wells Suite 528\", \"city\": \"Cleveland\", \"state\": \"TX\", \"zip\": 77327, \"lat\": 30.33, \"long\": -95.0202, \"city_pop\": 34153, \"job\": \"Building surveyor\", \"dob\": \"1995-09-11\", \"trans_num\": \"55e049e59f102017d4606d4f6c058484\", \"unix_time\": 1345251226, \"merch_lat\": 29.948759000000003, \"merch_long\": -94.842908, \"is_fraud\": 0, \"merchant_label\": 92, \"category_label\": 2, \"gender_label\": 0, \"job_label\": 55}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=640, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2970, timestamp=1715387675176, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-08-10 12:33:15\", \"cc_num\": 3542162746848552, \"merchant\": \"fraud_Koss, Hansen and Lueilwitz\", \"category\": \"home\", \"amt\": 314.56, \"first\": \"Bradley\", \"last\": \"Anderson\", \"gender\": \"M\", \"street\": \"3896 Gilmore Mill\", \"city\": \"Emmons\", \"state\": \"MN\", \"zip\": 56029, \"lat\": 43.5089, \"long\": -93.4824, \"city_pop\": 744, \"job\": \"Communications engineer\", \"dob\": \"1968-01-28\", \"trans_num\": \"be33db7f10f5f264656f21aebf9e1d48\", \"unix_time\": 1376137995, \"merch_lat\": 42.658519, \"merch_long\": -93.475173, \"is_fraud\": 0, \"merchant_label\": 333, \"category_label\": 6, \"gender_label\": 1, \"job_label\": 96}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=617, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2971, timestamp=1715387675177, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2020-12-08 09:08:50\", \"cc_num\": 6011367958204270, \"merchant\": \"fraud_Hermann-Gaylord\", \"category\": \"misc_pos\", \"amt\": 1.74, \"first\": \"Tammy\", \"last\": \"Ayers\", \"gender\": \"F\", \"street\": \"1652 James Mews\", \"city\": \"Hinckley\", \"state\": \"OH\", \"zip\": 44233, \"lat\": 41.2419, \"long\": -81.7453, \"city_pop\": 7646, \"job\": \"Medical sales representative\", \"dob\": \"1988-09-15\", \"trans_num\": \"e473d1136ec8b5c038eba78b270a1ba5\", \"unix_time\": 1386493730, \"merch_lat\": 41.904402000000005, \"merch_long\": -81.70844, \"is_fraud\": 0, \"merchant_label\": 247, \"category_label\": 9, \"gender_label\": 0, \"job_label\": 292}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=618, serialized_header_size=-1)\n",
      "msg ConsumerRecord(topic='transaction_data', partition=0, offset=2972, timestamp=1715387675179, timestamp_type=0, key=b'null', value=b'{\"trans_date_trans_time\": \"2019-12-16 23:03:23\", \"cc_num\": 3597926034019603, \"merchant\": \"fraud_Zboncak, Rowe and Murazik\", \"category\": \"shopping_net\", \"amt\": 7.7, \"first\": \"Derrick\", \"last\": \"Flores\", \"gender\": \"M\", \"street\": \"83690 Nicholas Ports Apt. 846\", \"city\": \"Oakland\", \"state\": \"TN\", \"zip\": 38060, \"lat\": 35.2229, \"long\": -89.5518, \"city_pop\": 9496, \"job\": \"Furniture conservator/restorer\", \"dob\": \"1993-03-23\", \"trans_num\": \"44d077a3bc6c5de37cf303029ae2378f\", \"unix_time\": 1355699003, \"merch_lat\": 34.969559999999994, \"merch_long\": -89.34310500000001, \"is_fraud\": 0, \"merchant_label\": 687, \"category_label\": 11, \"gender_label\": 1, \"job_label\": 204}', headers=[], checksum=None, serialized_key_size=4, serialized_value_size=659, serialized_header_size=-1)\n"
     ]
    }
   ],
   "source": [
    "consumer = KafkaConsumer(topic_name, group_id=None, bootstrap_servers=['localhost:9092'])\n",
    "for msg in consumer:\n",
    "\ttry:\n",
    "\t\tprint('msg', msg)\n",
    "\t\tmsg=msg.value.decode(\"utf-8\")\n",
    "\t\toutput = json.loads(msg)\n",
    "\t\tdf = spark.read.json(sc.parallelize([msg]))\n",
    "\t\tstatus = predicting_status(df,newmodel)\n",
    "\n",
    "\t\tstatus = int(status.collect()[0][0])\n",
    "\t\toutput['is_fraud_prediction'] = status\n",
    "\t\toutput['inserted_at'] = int(time.time() * 1000)\n",
    "\n",
    "\t\tinsert_query = f\"INSERT INTO {keyspace}.{table} JSON '{json.dumps(output)}';\"\n",
    "\t\tsession.execute(insert_query)\n",
    "\texcept Exception as e:\n",
    "\t\tprint('Error in transaction:', e)\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "consumer.close()\n",
    "spark.stop()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "# insert_query = f\"INSERT INTO {keyspace}.{table} JSON '{json.dumps(output)}';\"\n",
    "# session.execute(insert_query)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.11.4"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 2
}