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), }