topic schema
transaction_id VARCHAR(255) PRIMARY KEY,
user_id VARCHAR(255),
transaction_type VARCHAR(255),
amount DOUBLE,
timestamp BIGINT