Kcat timestamp parser

kcat-timestamps.py

#!/usr/bin/env python3
# Use with kcat -f "%p,%o,%T\n" to parse message timestamps

from sys import argv
from datetime import datetime
import csv

for row in csv.reader(open(argv[1], 'r'), delimiter=','):
  print(f"Partition {row[0]} offset {row[1]}: {datetime.fromtimestamp(int(row[2])/1000)}")