diff --git a/src/Microsoft.Azure.WebJobs.Extensions.EventHubs/Triggers/EventHubAsyncCollector.cs b/src/Microsoft.Azure.WebJobs.Extensions.EventHubs/Triggers/EventHubAsyncCollector.cs
index ff25a25..7057acd 100644
--- a/src/Microsoft.Azure.WebJobs.Extensions.EventHubs/Triggers/EventHubAsyncCollector.cs
+++ b/src/Microsoft.Azure.WebJobs.Extensions.EventHubs/Triggers/EventHubAsyncCollector.cs
@@ -23,8 +23,8 @@ internal class EventHubAsyncCollector : IAsyncCollector<EventData>
               
         private const int BatchSize = 100;
 
-        // Suggested to use 1008k instead of 1024k to leave padding room for headers.
-        private const int MaxByteSize = 1008 * 1024; 
+        // Suggested to use 240k instead of 256k to leave padding room for headers.
+        private const int MaxByteSize = 240 * 1024; 
         
         /// <summary>
         /// Create a sender around the given client. 
diff --git a/test/Microsoft.Azure.WebJobs.Extensions.EventHubs.Tests/EventHubAsyncCollectorTests.cs b/test/Microsoft.Azure.WebJobs.Extensions.EventHubs.Tests/EventHubAsyncCollectorTests.cs
index 5937381..73877a3 100644
--- a/test/Microsoft.Azure.WebJobs.Extensions.EventHubs.Tests/EventHubAsyncCollectorTests.cs
+++ b/test/Microsoft.Azure.WebJobs.Extensions.EventHubs.Tests/EventHubAsyncCollectorTests.cs
@@ -95,7 +95,7 @@ public async Task FlushAfterSizeThreshold()
         {
             var collector = new TestEventHubAsyncCollector();
 
-            // Trip the 1024k EventHub limit.
+            // Trip the 256k EventHub limit.
             for (int i = 0; i < 10; i++)
             {
                 var e1 = new EventData(new byte[10 * 1024]);
@@ -106,7 +106,7 @@ public async Task FlushAfterSizeThreshold()
             Assert.Empty(collector.SentEvents);
 
             // This will push it over the theshold
-            for (int i = 0; i < 100; i++)
+            for (int i = 0; i < 20; i++)
             {
                 var e1 = new EventData(new byte[10 * 1024]);
                 await collector.AddAsync(e1);
@@ -120,8 +120,8 @@ public async Task CantSentGiantEvent()
         {
             var collector = new TestEventHubAsyncCollector();
 
-            // event hub max is 1024k payload.
-            var hugePayload = new byte[1100 * 1024];
+            // event hub max is 256k payload.
+            var hugePayload = new byte[300 * 1024];
             var e1 = new EventData(hugePayload);
 
             try