parse_json_redpanda.py

parse_json_redpanda.py

import json

if __name__ == "__main__":
    line_count = 0
    with open("/Users/dendisuhubdy/Downloads/redpanda/data/2/kafka/btc_usdt_spot/0_111/0-1-v1.log", "rb") as fp:
        Lines = fp.readlines()
        for line in Lines:
            print(line)
            if line_count == 1:
                break
                
# task is to parse multiple JSON messages in one line