Most but not all requests made via the 0.13.0-alpha client are throwing a DEADLINE_EXCEEDED exception. Ive set log levels to FINE yet have no logging outside of the exceptions themselves. On startup my application shows the following warning: ``` io.grpc.Context: Storage override doesn't exist. Using default. java.lang.ClassNotFoundException: io.grpc.override.ContextStorageOverride at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ``` However from cursory reading this appears normal. Im using: "com.google.cloud" % "google-cloud-pubsub" % "0.13.0-alpha" "com.google.guava" % "guava" % "19.0" "com.google.api" % "gax" % "0.10.0" My current test code is sending fixed size messages of 3894 bytes. When I attempt to use any batch settings beyond the defaults of 1000Bytes, 100messages, 1 ms, all messages are rejected with DEADLINE_EXCEEDED. When using the default BatchingSettings from Publisher.defaultBuilder, ~90% of messages are rejected though some do succeed. ``` package com.google.cloud.examples.pubsub.snippets import com.google.api.gax.core.ApiFuture import com.google.cloud.pubsub.spi.v1.Publisher import com.google.protobuf.ByteString import com.google.pubsub.v1.PubsubMessage import com.google.pubsub.v1.TopicName import java.util.ArrayList import java.util.Arrays import java.util.List import java.util.logging.{Level, Logger} import com.google.api.gax.bundling.BundlingSettings import org.joda.time.Duration /** * A snippet for Google Cloud Pub/Sub showing how to create a Pub/Sub topic and asynchronously * publish messages to it. */ object CreateTopicAndPublishMessages extends App { val topic = TopicName.newBuilder().setProject("my-application").setTopic("my-development-topic").build() Logger.getLogger("").setLevel(Level.FINE) val batchSettings = BundlingSettings.newBuilder .setIsEnabled(true) .setDelayThreshold(Duration.standardSeconds(1)) .setRequestByteThreshold(Publisher.getApiMaxRequestBytes) .setElementCountThreshold(250L) .build() val publisher = Publisher.newBuilder(topic).setBundlingSettings(batchSettings).build() val msg = """ /// LARGE MESSAGE """ val messages = Seq("first message", "second message") val futures = (0 to 2000).map { message => val data = ByteString.copyFromUtf8(msg.toString) val pubsubMessage = PubsubMessage.newBuilder().setData(data).build() val messageIdFuture = publisher.publish(pubsubMessage) messageIdFuture } futures.foreach{ messageId => System.out.println("published with message ID: " + messageId.get()) } }