diff --git a/core/services/chainlink/application.go b/core/services/chainlink/application.go
index 74168bdd70e..028eb23a45c 100644
--- a/core/services/chainlink/application.go
+++ b/core/services/chainlink/application.go
@@ -379,7 +379,9 @@ func NewApplication(ctx context.Context, opts ApplicationOpts) (Application, err
 
 	// Wire DurableEmitter for persistent chip ingress delivery when enabled
 	if cfg.Telemetry().DurableEmitterEnabled() && cfg.Telemetry().ChipIngressEndpoint() != "" {
+		maxBatchSize := 1000
 		emitterCfg := durableemitter.DefaultConfig()
+		emitterCfg.RetransmitBatchSize = maxBatchSize
 		emitterCfg.Metrics = &durableemitter.DurableEmitterMetricsConfig{}
 		durableCfg := durableemitter.SetupConfig{
 			Endpoint:           cfg.Telemetry().ChipIngressEndpoint(),
@@ -393,6 +395,8 @@ func NewApplication(ctx context.Context, opts ApplicationOpts) (Application, err
 			RetransmitEnabled: true, // host process owns retransmit
 			EmitterConfig:     &emitterCfg,
 			Meter:             meter,
+			BatchSize:         maxBatchSize, // batch emitter config
+			MaxPublishTimeout: 10 * time.Second,
 		}
 		pgStore := durableemitter.NewPgDurableEventStore(opts.DS)
 		durableEmitter, setupErr := durableemitter.Setup(pgStore, durableCfg, globalLogger)