diff --git a/db/migrations/00014_create_cid_indexes.sql b/db/migrations/00014_create_cid_indexes.sql
index c5f559544..bc38c5a26 100644
--- a/db/migrations/00014_create_cid_indexes.sql
+++ b/db/migrations/00014_create_cid_indexes.sql
@@ -25,8 +25,6 @@ CREATE INDEX tx_dst_index ON eth.transaction_cids USING btree (dst);
 
 CREATE INDEX tx_src_index ON eth.transaction_cids USING btree (src);
 
-CREATE INDEX tx_data_index ON eth.transaction_cids USING btree (tx_data);
-
 -- receipt indexes
 CREATE INDEX rct_tx_id_index ON eth.receipt_cids USING btree (tx_id);
 
@@ -107,7 +105,6 @@ DROP INDEX eth.rct_cid_index;
 DROP INDEX eth.rct_tx_id_index;
 
 -- transaction indexes
-DROP INDEX eth.tx_data_index;
 DROP INDEX eth.tx_src_index;
 DROP INDEX eth.tx_dst_index;
 DROP INDEX eth.tx_mh_index;
diff --git a/db/schema.sql b/db/schema.sql
index 2ca0f50d6..02e92f209 100644
--- a/db/schema.sql
+++ b/db/schema.sql
@@ -886,13 +886,6 @@ CREATE INDEX timestamp_index ON eth.header_cids USING brin ("timestamp");
 CREATE INDEX tx_cid_index ON eth.transaction_cids USING btree (cid);
 
 
---
--- Name: tx_data_index; Type: INDEX; Schema: eth; Owner: -
---
-
-CREATE INDEX tx_data_index ON eth.transaction_cids USING btree (tx_data);
-
-
 --
 -- Name: tx_dst_index; Type: INDEX; Schema: eth; Owner: -
 --
diff --git a/pkg/eth/streamer.go b/pkg/eth/streamer.go
index 729f2e955..d0ec90bf4 100644
--- a/pkg/eth/streamer.go
+++ b/pkg/eth/streamer.go
@@ -25,7 +25,7 @@ import (
 )
 
 const (
-	PayloadChanBufferSize = 20000 // the max eth sub buffer size
+	PayloadChanBufferSize = 10000 // half the max eth sub buffer size
 )
 
 // StreamClient is an interface for subscribing and streaming from geth
diff --git a/pkg/eth/transformer.go b/pkg/eth/transformer.go
index 570f63f0c..722db812a 100644
--- a/pkg/eth/transformer.go
+++ b/pkg/eth/transformer.go
@@ -119,7 +119,7 @@ func (sdt *StateDiffTransformer) Transform(workerID int, payload statediff.Paylo
 			traceMsg += fmt.Sprintf("postgres transaction commit duration: %s\r\n", tDiff.String())
 		}
 		traceMsg += fmt.Sprintf(" TOTAL PROCESSING TIME: %s\r\n", time.Now().Sub(start).String())
-		logrus.Info(traceMsg)
+		logrus.Trace(traceMsg)
 	}()
 	tDiff = time.Now().Sub(t)
 	prom.SetTimeMetric("t_free_postgres", tDiff)
diff --git a/pkg/sync/service.go b/pkg/sync/service.go
index 8007bc28c..e9b28ad52 100644
--- a/pkg/sync/service.go
+++ b/pkg/sync/service.go
@@ -31,10 +31,6 @@ import (
 	"github.com/vulcanize/ipld-eth-indexer/pkg/shared"
 )
 
-const (
-	PayloadChanBufferSize = 2000
-)
-
 // Indexer is the top level interface for streaming, converting to IPLDs, publishing, and indexing all chain data at head
 // This service is compatible with the Ethereum service interface (node.Service)
 type Indexer interface {
@@ -97,7 +93,7 @@ func (sap *Service) Sync(wg *sync.WaitGroup) error {
 		return err
 	}
 	// spin up publish worker goroutines
-	publishPayload := make(chan statediff.Payload, PayloadChanBufferSize)
+	publishPayload := make(chan statediff.Payload, eth.PayloadChanBufferSize)
 	for i := 1; i <= int(sap.Workers); i++ {
 		go sap.transform(wg, i, publishPayload)
 		log.Debugf("ethereum sync worker %d successfully spun up", i)
diff --git a/version/version.go b/version/version.go
index 8a65b014a..2aae85725 100644
--- a/version/version.go
+++ b/version/version.go
@@ -20,7 +20,7 @@ import "fmt"
 
 const (
 	Major = 0       // Major version component of the current release
-	Minor = 5       // Minor version component of the current release
+	Minor = 6       // Minor version component of the current release
 	Patch = 0       // Patch version component of the current release
 	Meta  = "alpha" // Version metadata to append to the version string
 )