fix: update exception handling exposed by underlying API translating changes (#53)

* fix: Incorrect exception handling exposed by underlying API translating ExecutionException differently.

* fix: reformat

Author: dpcollins-google

pom.xml

@@ -17,12 +17,12 @@
     <dependency>
       <groupId>com.google.api.grpc</groupId>
       <artifactId>proto-google-cloud-pubsublite-v1</artifactId>
-      <version>0.7.0</version>
+      <version>0.8.0</version>
     </dependency>
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-pubsublite</artifactId>
-      <version>0.7.0</version>
+      <version>0.8.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.kafka</groupId>

src/test/java/com/google/cloud/pubsublite/kafka/SharedBehaviorTest.java

@@ -31,7 +31,7 @@
 import java.time.Duration;
 import java.util.List;
 import org.apache.kafka.common.PartitionInfo;
-import org.apache.kafka.common.errors.BrokerNotAvailableException;
+import org.apache.kafka.common.errors.InvalidRequestException;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -71,7 +71,7 @@ public void partitionsForFailure() {
             ApiFutures.immediateFailedFuture(
                 new CheckedApiException(StatusCode.Code.FAILED_PRECONDITION).underlying));
     assertThrows(
-        BrokerNotAvailableException.class,
+        InvalidRequestException.class,
         () -> shared.partitionsFor(example(TopicPath.class), Duration.ofMillis(10)));
   }