From 6d91720ea356973c98546a199c5698482f3f99c3 Mon Sep 17 00:00:00 2001 From: Ezra Smith Date: Wed, 24 Apr 2024 16:06:46 -0400 Subject: [PATCH] Disable token streaming for the time being --- kafka-streamer/main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka-streamer/main.go b/kafka-streamer/main.go index 195a6b1e7..a319d064b 100644 --- a/kafka-streamer/main.go +++ b/kafka-streamer/main.go @@ -135,8 +135,8 @@ func runStreamer(ctx context.Context, pgx *pgxpool.Pool) { // Creating multiple configs for each topic allows them to process separate partitions in parallel configs := []*streamerConfig{ newEthereumOwnerConfig(deserializer, queries), - newEthereumTokenConfig(deserializer, queries), - newEthereumTokenConfig(deserializer, queries), + //newEthereumTokenConfig(deserializer, queries), + //newEthereumTokenConfig(deserializer, queries), newBaseOwnerConfig(deserializer, queries), newZoraOwnerConfig(deserializer, queries), }