Disable token streaming for the time being

gallery-so · Apr 24, 2024 · 6d91720 · 6d91720
1 parent 07c23f7
commit 6d91720
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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),
 	}