Changelog

1.6.3 (2022-08-12)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.120.11 ( #1185 ) ( 9408772 )

1.6.2 (2022-08-08)

Bug Fixes

  • CheckedApiException should not prepend com.google.api.gax.rpc.ApiException to its message. ( #1178 ) ( b264d4a )
  • declaring test-scope artifact as runtime ( #1186 ) ( d3b0244 )
  • enable longpaths support for windows test ( #1485 ) ( #1173 ) ( b0f5a0d )

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.176.0 ( #1171 ) ( 1b905d8 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.120.0 ( #1168 ) ( 4aa90ce )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.120.10 ( #1184 ) ( 94b6268 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.120.5 ( #1181 ) ( a3dd68f )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.120.8 ( #1182 ) ( 9f80889 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.120.9 ( #1183 ) ( 59b2f60 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v3 ( #1179 ) ( b3cb990 )

1.6.1 (2022-06-30)

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.175.0 ( #1152 ) ( 283c263 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.119.1 ( #1150 ) ( 2859e72 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.13.0 ( #1159 ) ( 0844ae8 )

1.6.0 (2022-05-23)

Features

  • add build scripts for native image testing in Java 17 ( #1440 ) ( #1141 ) ( ae9aff7 )
  • ensure large message batches can be received by subscribers ( #1133 ) ( 3276d47 )

Dependencies

  • error_prone_annotations from shared deps BOM ( #1128 ) ( 32f7f4f )
  • update dependency com.google.cloud:google-cloud-bom to v0.174.0 ( #1136 ) ( 00c2737 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.117.0 ( #1134 ) ( 312224e )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.118.0 ( #1139 ) ( ac83f8d )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.11.0 ( #1140 ) ( 869b4ee )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.12.0 ( #1142 ) ( 577af94 )
  • update dependency com.google.errorprone:error_prone_core to v2.13.1 ( #1107 ) ( 484ca3e )

1.5.5 (2022-04-26)

Bug Fixes

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.173.0 ( #1123 ) ( 7f2ced1 )
  • update dependency com.google.errorprone:error_prone_annotations to v2.13.1 ( #1106 ) ( ab92e3f )

1.5.4 (2022-04-21)

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.172.0 ( #1105 ) ( 850ecfa )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.116.3 ( #1104 ) ( 2f74db1 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.116.4 ( #1114 ) ( 832bbad )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.10.0 ( #1111 ) ( 23665c2 )

1.5.3 (2022-03-29)

Dependencies

  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.9.0 ( #1100 ) ( 80327b5 )

1.5.2 (2022-03-25)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.116.1 ( #1094 ) ( 4286d46 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.116.2 ( #1096 ) ( 2195d3c )

1.5.1 (2022-03-17)

Bug Fixes

  • Flush messages in serial executor before handling admin seek ( #1079 ) ( 49bed38 )

1.5.0 (2022-03-16)

Features

  • add explicit duplicate subscriber handling to SubscriberImpl for beam ( #1088 ) ( f808056 )

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.171.0 ( #1085 ) ( 88551c6 )

1.4.12 (2022-03-08)

Bug Fixes

  • Committer stuck in retry loop on shutdown ( #1062 ) ( cbad789 )

Dependencies

  • remove no longer needed explicit overrides ( #1069 ) ( 15c7de7 )
  • update actions/github-script action to v6 ( #1058 ) ( 8b28569 )
  • update dependency com.google.cloud:google-cloud-bom to v0.168.1 ( #1070 ) ( edd3bdc )
  • update dependency com.google.cloud:google-cloud-bom to v0.169.0 ( #1075 ) ( 9f9f774 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.115.4 ( #1056 ) ( 152a793 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.115.5 ( #1061 ) ( 597bdc2 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.116.0 ( #1077 ) ( 1034612 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.8.0 ( #1074 ) ( 8b2a4df )

1.4.11 (2022-02-09)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.115.3 ( #1051 ) ( aac8966 )

1.4.10 (2022-02-08)

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.167.0 ( #1047 ) ( 49dcd9c )
  • update dependency org.checkerframework:checker-qual to v3.21.2 ( #1039 ) ( 3753757 )

1.4.9 (2022-02-04)

Bug Fixes

  • Ensure messages are delivered in order ( #1031 ) ( a8a969e )
  • mitigate gRPC stream connection issues ( #1038 ) ( f3678b7 )
  • Reinitialize streams in an unbounded executor ( #1027 ) ( 6377c1d )

Documentation

  • Update comments for regional topics ( #967 ) ( 7220439 )

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.166.0 ( #1017 ) ( 03ae03a )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.115.1 ( #1014 ) ( 59e74c9 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.115.2 ( #1041 ) ( 1f46ca9 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.7.0 ( #1037 ) ( 15d4215 )
  • update dependency com.google.errorprone:error_prone_annotations to v2.11.0 ( #1032 ) ( 677b96b )
  • update dependency com.google.errorprone:error_prone_core to v2.11.0 ( #1033 ) ( 088cc62 )
  • update dependency org.checkerframework:checker-qual to v3.21.1 ( #1015 ) ( ffa1f0b )

1.4.8 (2022-01-07)

Dependencies

  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.6.0 ( #1011 ) ( 0640a3e )

1.4.7 (2021-12-22)

Bug Fixes

  • Numerous publish path performance issues ( #998 ) ( 2cd8b85 )
  • Restructure java client stream creation to reuse clients for different partitions ( #1002 ) ( a45a179 )
  • Use an unbounded pool for the GRPC executor ( #997 ) ( 6f3946d )

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.165.0 ( #1005 ) ( b1ba967 )
  • update dependency com.google.flogger:flogger-system-backend to v0.7.4 ( #1004 ) ( 8ae651d )
  • update dependency com.google.flogger:google-extensions to v0.7.4 ( #1003 ) ( e8295c5 )
  • update dependency org.checkerframework:checker-qual to v3.21.0 ( #1001 ) ( 255817f )

1.4.6 (2021-12-16)

Dependencies

  • update dependency com.google.auto.value:auto-value to v1.9 ( #989 ) ( d2cc54a )
  • update dependency com.google.flogger:flogger-system-backend to v0.7.3 ( #992 ) ( 98a1cf7 )
  • update dependency com.google.flogger:google-extensions to v0.7.3 ( #993 ) ( 34f08bf )

1.4.5 (2021-12-14)

Dependencies

  • update dependency com.google.flogger:flogger-system-backend to v0.7.2 ( #983 ) ( 6faf2dd )
  • update dependency com.google.flogger:google-extensions to v0.7.2 ( #984 ) ( d6004c6 )

1.4.4 (2021-12-09)

Bug Fixes

  • Add a timeout to getTopicPartitionCount ( #979 ) ( 0301d55 )

1.4.3 (2021-12-08)

Bug Fixes

  • Change PublisherImpl and SerialBatcher interplay to not call into the network layer on the downcall ( #975 ) ( e771c49 )

Dependencies

  • update dependency com.google.cloud:google-cloud-bom to v0.164.0 ( #973 ) ( e1139e9 )

1.4.2 (2021-12-07)

Bug Fixes

  • Add a really long timeout to PartitionLookupUtils ( #965 ) ( 1c0678d )
  • Partition assignment stream does not require an initial response ( #966 ) ( 8227d31 )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.115.0 ( #969 ) ( 2f78d56 )
  • update dependency org.checkerframework:checker-qual to v3.20.0 ( #964 ) ( 38a7fde )

1.4.1 (2021-12-03)

Bug Fixes

  • remove local copy of beam I/O now that it is merged to upstream ( #873 ) ( 0bd9d52 )

Dependencies

  • update beam.version to v2.34.0 ( #950 ) ( 527f77f )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.5.0 ( #952 ) ( 41ebb30 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.5.1 ( #960 ) ( 9e46dbc )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.23.0 ( #951 ) ( c62c79c )

1.4.0 (2021-11-11)

Features

  • Introduce Native Image testing build script changes ( #924 ) ( 5801212 )

Bug Fixes

  • Fail early when publishing to already failed publishers ( #934 ) ( 6ab2754 )

Dependencies

  • Bump assorted dependencies which need to be incremented together ( #943 ) ( ab63bf2 )
  • Correct BOM deps ( #946 ) ( fa6bbbe )
  • update beam.version to v2.33.0 ( #920 ) ( 91289d2 )
  • update dependency com.google.auto.service:auto-service to v1.0.1 ( #935 ) ( b72dcf6 )
  • update dependency com.google.auto.service:auto-service-annotations to v1.0.1 ( #936 ) ( 30b4ab0 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.114.7 ( #926 ) ( 80becc5 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.4.0 ( #925 ) ( 50a36f3 )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.22.0 ( #915 ) ( b9f7727 )
  • update dependency com.google.errorprone:error_prone_annotations to v2.10.0 ( #939 ) ( eea5f38 )
  • update dependency com.google.errorprone:error_prone_core to v2.10.0 ( #940 ) ( c5359e8 )
  • update dependency com.google.flogger:flogger-system-backend to v0.7.1 ( #917 ) ( 580aa0a )
  • update dependency org.checkerframework:checker-qual to v3.19.0 ( #933 ) ( 5b49749 )

1.3.0 (2021-10-06)

Features

  • Remove BetaApi from reservation methods ( #906 ) ( 2d5b594 )

Documentation

  • Update ReassignmentHandler comments ( #892 ) ( a79ffff )

Dependencies

  • bump beam.version and restucture snippets POM to not break ( #893 ) ( 3dcf839 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.114.4 ( #891 ) ( 86e95d5 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.114.5 ( #904 ) ( b4d7497 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.114.6 ( #912 ) ( 160fdc9 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.3.0 ( #896 ) ( 2c7afd3 )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.21.0 ( #890 ) ( f574d1d )
  • update dependency joda-time:joda-time to v2.10.11 ( #897 ) ( 6a9e041 )
  • update dependency joda-time:joda-time to v2.10.12 ( #908 ) ( dc2f721 )
  • update dependency org.checkerframework:checker-qual to v3.18.1 ( #910 ) ( 0ddc6e9 )

1.2.0 (2021-09-16)

Features

  • Add ReassignmentHandler which is notified on client reassignment ( #886 ) ( 5bfef8d ), closes #869
  • Batch commit requests ( #883 ) ( 5abd97d )

Dependencies

  • update dependency com.google.cloud:pubsublite-beam-io to v0.20.0 ( #885 ) ( 66d23e3 )

1.1.0 (2021-09-15)

Features

  • Allow regional path creation for when the backend supports this ( #881 ) ( 8bcbe26 )

Bug Fixes

  • catch more possible errors in AssigningSubscriber and don't have hard errors on stopping subscribers ( #880 ) ( 22db237 )

Dependencies

  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.2.1 ( #878 ) ( b38b501 )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.19.6 ( #876 ) ( debf7a4 )

1.0.6 (2021-09-13)

Bug Fixes

  • simplify AckSetTrackerImpl and make acks after shutdown not cause a permanent error ( #872 ) ( 98ceff0 )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.114.3 ( #857 ) ( d312080 )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.19.5 ( #830 ) ( 3a74d32 )

1.0.5 (2021-09-08)

Bug Fixes

  • Ensure notifyFailed is called and all services are stopped when a permanent error happens ( #860 ) ( a046b53 )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.114.1 ( #843 ) ( 04415ec )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.114.2 ( #848 ) ( 074488e )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.1.0 ( #842 ) ( e5e66bc )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.2.0 ( #854 ) ( 4ef86a6 )
  • update dependency com.google.errorprone:error_prone_annotations to v2.9.0 ( #838 ) ( 47e48d6 )
  • update dependency com.google.errorprone:error_prone_core to v2.9.0 ( #839 ) ( ebb1bb1 )
  • update dependency org.checkerframework:checker-qual to v3.18.0 ( #855 ) ( c3c8400 )

1.0.4 (2021-08-11)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.113.8 ( #822 ) ( 61de65d )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2.0.1 ( #827 ) ( 516debb )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.19.3 ( #823 ) ( ab28d1a )

1.0.3 (2021-08-11)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.113.7 ( #817 ) ( 39e6429 )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.19.2 ( #816 ) ( d8ec4c2 )

1.0.2 (2021-08-10)

Dependencies

  • update dependency com.google.cloud:pubsublite-beam-io to v0.19.1 ( #810 ) ( 7764c1d )

1.0.1 (2021-08-09)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.113.6 ( #806 ) ( 7394bcf )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.19.0 ( #802 ) ( 7fbf9e5 )

1.0.0 (2021-08-04)

Features

Miscellaneous Chores

  • deps:update dependency com.google.cloud:google-cloud-pubsublite to v0.18.0 ( #782 ) ( 76a238a )

Dependencies

  • update dependency com.google.cloud:google-cloud-shared-dependencies to v2 ( #795 ) ( 8f81925 )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.18.0 ( #783 ) ( 1fd9834 )
  • update dependency com.google.errorprone:error_prone_annotations to v2.8.1 ( #789 ) ( cd5c628 )
  • update dependency com.google.errorprone:error_prone_core to v2.8.1 ( #790 ) ( 573e288 )
  • update dependency org.checkerframework:checker-qual to v3.17.0 ( #788 ) ( 50ce4dc )

0.18.0 (2021-07-29)

Features

  • split versions.txt to independently release the Beam IO ( #766 ) ( b6e48dc )
  • Update CloudPubsubChecks to CloudPubsubTransforms ( #730 ) ( 2e10924 )

Bug Fixes

  • deflake SubscriptionPartitionProcessorImplTest ( #768 ) ( c34e430 )
  • remove DlqProvider which should remain in the beam repo and bump beam version ( #772 ) ( a540c1d )

Dependencies

  • define Beam version as a Maven property in pom ( #714 ) ( 69106fe )
  • update dependency com.google.apis:google-api-services-bigquery to v2-rev20210617-1.32.1 ( #773 ) ( e904392 )
  • Version bump cloud BOM and remove no longer needed dependency management settings ( #777 ) ( 1cd23cb )

0.17.0 (2021-07-26)

Features

  • Add SeekSubscription and Operations to API ( #705 ) ( 92d0246 )
  • Blocking pull subscribe is AutoCloseable ( #748 ) ( fc52221 )
  • Support seek subscription in AdminClient ( #740 ) ( 5fe36cb )

Bug Fixes

  • Add shopt -s nullglob to dependencies script ( #726 ) ( c860ae9 )
  • Change all DirectExecutors to use a SystemExecutor and fix service shutdowns ( #744 ) ( c8541aa )
  • create a hard failure when batching settings with flow control are used ( #758 ) ( 459378d )
  • Fail the partition watcher if its consumer throws an exception ( #728 ) ( c297c77 )
  • Make the one breaking change required to allow regions on TopicPath or SubscriptionPath ( #729 ) ( 5cf5783 )
  • Move BacklogLocation enum to standalone file ( #736 ) ( 70749d8 )
  • Updates for import ( #743 ) ( 245004e )

Dependencies

  • update dependency com.google.auto.value:auto-value to v1.8.2 ( #753 ) ( f88c7c0 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.113.4 ( #724 ) ( 5b0c122 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.113.5 ( #738 ) ( 542c2c7 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.113.4 ( #725 ) ( f6dcbd1 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.113.5 ( #737 ) ( 496e2b6 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v1.4.0 ( #731 ) ( 2ac33c6 )
  • update dependency com.google.cloud:pubsublite-beam-io to v0.16.1 ( #718 ) ( db7e718 )
  • update dependency com.google.errorprone:error_prone_annotations to v2.8.0 ( #756 ) ( 61ef3a3 )
  • update dependency com.google.errorprone:error_prone_core to v2.8.0 ( #757 ) ( a3c8579 )
  • update dependency org.checkerframework:checker-qual to v3.15.0 ( #721 ) ( 2bb7b04 )
  • update dependency org.checkerframework:checker-qual to v3.16.0 ( #747 ) ( 39de840 )
  • update dependency org.slf4j:slf4j-api to v1.7.31 ( #719 ) ( 43506a0 )
  • update dependency org.slf4j:slf4j-api to v1.7.32 ( #755 ) ( 829053e )

0.16.1 (2021-06-17)

Bug Fixes

  • Make PubsubLiteIO not final and have protected constructor ( #715 ) ( a6a7fc2 )

Dependencies

  • update dependency com.google.cloud:pubsublite-beam-io to v0.16.0 ( #709 ) ( 5050dfa )

0.16.0 (2021-06-16)

Features

  • Change restriction to OffsetByteRange to allow functioning with runnerv2. ( #674 ) ( 1749ca9 )

Bug Fixes

  • ManagedChannel shutdown issues ( #700 ) ( 2d0cbde )
  • update codeowner team in repo metadata ( #699 ) ( eead488 )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.113.3 ( #689 ) ( b5bd126 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.113.3 ( #690 ) ( 3d05801 )

Documentation

0.15.0 (2021-06-08)

Features

  • Ability to reset subscriber upon out of band seek ( #662 ) ( 2d89341 )
  • add gcf-owl-bot[bot] to ignoreAuthors ( #645 ) ( 13ff53b )
  • Add InitialSubscribeRequest.initial_location field ( #649 ) ( b5fe795 )
  • Add reservation support. ( #661 ) ( 79bb58c )
  • Set initial location when connecting subscribe streams ( #664 ) ( 65ced46 )

Bug Fixes

  • Add RunWith annotation ( #678 ) ( ef85581 )
  • Remove explicit partitions which are not particularly useful and add Watch workaround. ( #675 ) ( 587c91c )
  • Respect lock annotations in RetryingConnection ( #669 ) ( d583623 )
  • Update POMs to run errorprone analyzers and fix found issues ( #677 ) ( fb1cab4 )
  • Use correct string formatting for log message ( #668 ) ( da98b0f )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.113.0 ( #655 ) ( fa59973 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.113.1 ( #672 ) ( d9e265b )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.113.0 ( #656 ) ( ed53f16 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.113.1 ( #673 ) ( d679411 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v1.2.0 ( #644 ) ( 505f545 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v1.3.0 ( #663 ) ( 06573d1 )
  • update dependency com.google.errorprone:error_prone_annotations to v2.7.1 ( #641 ) ( 12cbed0 )
  • update dependency com.google.truth.extensions:truth-java8-extension to v1.1.3 ( #651 ) ( 5fc9d65 )
  • update dependency org.checkerframework:checker-qual to v3.14.0 ( #657 ) ( f20ae9c )

Documentation

  • bump version in PubsubLiteIO readme ( #665 ) ( 5eef903 )

0.14.2 (2021-05-14)

Dependencies

  • update dependency com.google.auto.value:auto-value to v1.8.1 ( #605 ) ( 1a07c89 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.112.5 ( #636 ) ( c8dd3a2 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.112.5 ( #637 ) ( 38c4054 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v1.1.0 ( #631 ) ( b6263e6 )
  • update dependency org.apache.beam:beam-runners-direct-java to v2.29.0 ( #610 ) ( 92b298c )
  • update dependency org.apache.beam:beam-sdks-java-extensions-protobuf to v2.29.0 ( #612 ) ( 723f602 )
  • update dependency org.checkerframework:checker-qual to v3.13.0 ( #625 ) ( bd4d59b )

0.14.1 (2021-05-03)

Dependencies

  • update dependency com.google.flogger:flogger-system-backend to v0.6 ( #568 ) ( ccec87a )

0.14.0 (2021-04-28)

Features

  • Compute cursors for publish and event timestamps ( #618 ) ( ded756e )
  • ComputeTimeCursor RPC for Pub/Sub Lite ( #615 ) ( f74b73c )

Bug Fixes

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.112.1 ( #593 ) ( a546cfd )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.112.3 ( #613 ) ( 4a3307f )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.112.1 ( #594 ) ( 4fccc65 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.112.3 ( #614 ) ( c025599 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.21.1 ( #602 ) ( 0e7eeba )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v1 ( #609 ) ( 25585d9 )
  • update dependency org.apache.beam:beam-sdks-java-core to v2.29.0 ( #611 ) ( f5e9cb9 )

0.13.2 (2021-04-12)

Documentation

Dependencies

  • update dependency com.google.auto.service:auto-service to v1.0 ( #583 ) ( b567402 )
  • update dependency com.google.auto.service:auto-service-annotations to v1.0 ( #584 ) ( b146c37 )
  • update dependency com.google.auto.value:auto-value to v1.8 ( #585 ) ( d15db39 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.21.0 ( #588 ) ( 0601f66 )
  • update dependency org.checkerframework:checker-qual to v3.12.0 ( #577 ) ( 643849b )

0.13.1 (2021-04-01)

Bug Fixes

  • Allow setting framework tags on cloud pubsub shim. ( #571 ) ( 2231fbd )

Dependencies

  • update dependency com.google.errorprone:error_prone_annotations to v2.6.0 ( #570 ) ( 0ea0415 )
  • update dependency com.google.flogger:google-extensions to v0.6 ( #569 ) ( 583a37b )

0.13.0 (2021-03-30)

Features

  • Adding ability to create a subscription at HEAD ( #545 ) ( c526235 )

Bug Fixes

  • Centralize alarm executor creation for Pub/Sub Lite ( #565 ) ( 5f73967 )
  • Set batching settings on SinglePartitionPublisher ( #563 ) ( 3b099d0 )

Dependencies

  • update dependency com.google.auto.value:auto-value to v1.7.5 ( #560 ) ( 37f6da5 )

0.12.0 (2021-03-18)

Features

  • add skip_backlog field to allow subscriptions to be created at HEAD ( #543 ) ( f0190db )

Bug Fixes

  • Two QOL issues with PubsubLiteIO ( #552 ) ( d4682b6 )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.112.0 ( #550 ) ( 9f53f6a )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.112.0 ( #551 ) ( 0593aca )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.20.1 ( #546 ) ( 261ae47 )

0.11.1 (2021-03-01)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.111.3 ( #511 ) ( 29b696f )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.111.4 ( #530 ) ( 69e60cd )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.111.3 ( #512 ) ( 795dab3 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.111.4 ( #531 ) ( c082672 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.20.0 ( #526 ) ( 58fbc1c )
  • update dependency joda-time:joda-time to v2.10.10 ( #515 ) ( b6890ec )
  • update dependency org.checkerframework:checker-qual to v3.11.0 ( #516 ) ( 756fd2b )
  • update dependency org.hamcrest:hamcrest-core to v2 ( #518 ) ( c9c3d2d )

0.11.0 (2021-02-24)

Features

  • Re-fork the beam repo from upstream ( #513 ) ( 041b3a5 )

Bug Fixes

Documentation

  • generate sample code in the Java microgenerator ( #498 ) ( b42165e )

Dependencies

  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.19.0 ( #508 ) ( 2ea9e1a )

0.10.0 (2021-02-04)

Features

  • Change message id on PubsubMessages to be an encoded MessageMetadata and rename PublishMetadata to MessageMetadata ( #482 ) ( a5cedf9 )
  • remove beam I/O from repo and redirect to beam ( #479 ) ( 246e4e7 )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.111.0 ( #487 ) ( 7d41486 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.111.0 ( #488 ) ( fe29e70 )

0.9.0 (2021-02-01)

Features

  • Add CredentialsProvider to Publisher and Subscriber settings ( #475 ) ( ba16af8 )
  • remove Spark connector module from this repo ( #467 ) ( ae82cbe )

Dependencies

  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.18.0 ( #458 ) ( 6642cc6 )
  • update dependency com.google.errorprone:error_prone_annotations to v2.5.1 ( #454 ) ( d1c7d33 )
  • update dependency com.google.truth.extensions:truth-java8-extension to v1.1.2 ( #463 ) ( 7b87407 )

0.8.0 (2021-01-14)

Features

  • Add ComputeHeadCursor RPC for Pub/Sub Lite. ( #429 ) ( 34d8d02 )
  • Add non google default creds provider to subscribers in Spark Connector ( #440 ) ( 2099751 )
  • Adds examples and fixes bugs in spark connector ( #456 ) ( d1c2a24 )
  • BlockingPullSubscriber in Spark Continuous Processing ( #408 ) ( 36684c4 )
  • Changed assert to Preconditions check ( #457 ) ( f6f1bc4 )
  • Compute head offset for Spark connector micro batch mode. ( #439 ) ( f484754 )
  • fix bug where blockingpullsubscriber doesn't refill flowcontrol quota. ( #449 ) ( 109bd83 )
  • Major classes for Spark continuous streaming ( #396 ) ( 0c0d928 )
  • Multiple fixes to make continuous mode work ( #432 ) ( 9df4ccf )
  • Separates Offsets from different context (Spark vs PSL) ( #404 ) ( b745f58 )
  • Spark connector readme ( #441 ) ( 2ab6e3e )
  • Spark micro batch processing ( #426 ) ( 86aecc9 )
  • Update spark connector pom.xml ( #445 ) ( 624b123 )
  • Use the partition watching publisher in the cps client ( #409 ) ( b85ceb4 )

Bug Fixes

  • adding a method to the internal wire publisher that will attempt to cancel all outstanding publishes ( #434 ) ( 7b9776e )
  • Attempt to start the publisher and publish in the ITVPC test ( #420 ) ( 8ebc9f1 )
  • Extract the rpc exception from IllegalStateExceptins in publish/subscribe ( #430 ) ( ff05b1a )
  • Remove per-message byte limit in client ( #435 ) ( f7f36eb )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.110.1 ( #416 ) ( 92b4076 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.110.3 ( #442 ) ( cf78009 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.110.1 ( #417 ) ( c90e506 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.110.3 ( #443 ) ( 594f79c )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.16.1 ( 19cae17 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.17.0 ( #428 ) ( e56d2c2 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.17.1 ( #452 ) ( ecdaef2 )
  • update dependency joda-time:joda-time to v2.10.9 ( #436 ) ( a5a305b )
  • update dependency org.slf4j:slf4j-api to v1.7.30 ( #401 ) ( 2d9803b )
  • update jackson dependencies to v2.12.1 ( #447 ) ( d62cd7f )

Documentation

0.7.0 (2020-12-08)

Features

  • Add the PartitionCountWatchingPublisher ( #387 ) ( 74a8504 )
  • PSL spark sql streaming utility classes ( #391 ) ( 0e4cb93 )
  • The TopicConfigWatcher polls the topic config and calls a handler whenever it changes ( #377 ) ( b98c501 )

Bug Fixes

  • Deadlock in RetryingConnectionImpl when tearing down a connection ( #406 ) ( af77486 )
  • Remove extra logic to convert to project numbers now that this is handled in the backend ( #397 ) ( 14e5ab4 )

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.110.0 ( #393 ) ( 98aa9b2 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.110.0 ( #392 ) ( 9e71b67 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.16.0 ( #394 ) ( 6890f2a )
  • update dependency commons-codec:commons-codec to v1.15 ( #399 ) ( 00a18a6 )

0.6.5 (2020-11-19)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.109.0 ( #374 ) ( 2361b30 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.109.0 ( #375 ) ( 79ffdab )
  • update dependency com.google.cloud:google-cloud-resourcemanager to v0.118.4-alpha ( #373 ) ( 3e8c459 )

0.6.4 (2020-11-11)

Dependencies

  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.15.0 ( #364 ) ( 6ed1eea )

0.6.3 (2020-11-10)

Dependencies

  • update dependency com.google.cloud:google-cloud-pubsub to v1.108.7 ( #351 ) ( 259f814 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.108.7 ( #352 ) ( 25eefe8 )
  • update dependency com.google.cloud:google-cloud-resourcemanager to v0.118.3-alpha ( #353 ) ( 26ea294 )

0.6.2 (2020-11-02)

Dependencies

  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.14.1 ( #345 ) ( a18cf47 )

0.6.1 (2020-10-27)

Dependencies

  • update dependency joda-time:joda-time to v2.10.8 ( #327 ) ( 0d0a47f )

0.6.0 (2020-10-26)

Features

  • All changes required to change library to use ApiException and gapic internals ( #295 ) ( 313bfc6 )

Bug Fixes

  • Change Kafka{Producer/Consumer} to fix the number of partitions instead of looking it up. ( #322 ) ( 3f27c86 )

Documentation

  • Add a basic readme for kafka client ( #320 ) ( 6073810 )

Dependencies

  • Increment beam version on pubsublite-io ( #317 ) ( d0db6c2 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.108.6 ( #324 ) ( 4e318bb )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.108.6 ( #325 ) ( b7ef47d )
  • update dependency com.google.truth:truth to v1.1 ( #307 ) ( 1a556ef )
  • update dependency com.google.truth.extensions:truth-java8-extension to v1.1 ( #306 ) ( 21cf834 )
  • update dependency org.apache.beam:beam-runners-direct-java to v2.25.0 ( #328 ) ( 675cd60 )
  • update dependency org.apache.beam:beam-sdks-java-core to v2.25.0 ( #329 ) ( 03b09ff )

0.5.0 (2020-10-21)

Features

  • Add nextOffset method to BufferingPullSubscriber ( #272 ) ( 5c0e7cc )
  • Add pubsublite-kafka-shim directory and disable deployment ( #273 ) ( 8bf29f8 )
  • Add SharedBehavior class which handles the PartitionsFor method on consumers and producers ( #278 ) ( b42da5f )
  • Implement interfaces and utilities needed for Pub/Sub Lite Kafka shim ( #276 ) ( 3c43ef3 )
  • Implement PubsubLiteConsumer. ( #287 ) ( eed9656 )
  • Implement PubsubLiteProducer ( #280 ) ( 1879470 )
  • Implement SingleSubscriptionConsumerImpl ( #281 ) ( 0e409c2 )

Bug Fixes

  • Change internals to throw StatusException instead of return Status ( #300 ) ( 96ad02c )
  • Fix PubsubLiteUnboundedSource to create n partitions not partitions of n size ( #313 ) ( dbebc4b )
  • Implement ApiResourceAggregation to deduplicate logic for BackgroundResources. ( #301 ) ( 09578b5 )
  • Implement TrivialProxyService to remove duplicate ProxyService logic for the trivial case. ( #302 ) ( ed74c6f )
  • Make connections start up asynchronously ( #289 ) ( 27b1fec )

Dependencies

  • Move common dependencies into parent dependency management section ( #275 ) ( d72bea8 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.108.3 ( #282 ) ( cd9d943 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.108.4 ( #291 ) ( b18ba85 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.108.5 ( #303 ) ( 50857a0 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.108.3 ( #283 ) ( e98aa25 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.108.4 ( #292 ) ( ed876b7 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.108.5 ( #304 ) ( 58e55da )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.10.1 ( #284 ) ( d4be4a3 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.10.2 ( #285 ) ( 30c6f83 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.12.1 ( #296 ) ( 273a07a )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.13.0 ( #308 ) ( ed9d961 )
  • update dependency joda-time:joda-time to v2.10.7 ( #310 ) ( d8e319c )
  • update dependency junit:junit to v4.13.1 ( #290 ) ( 578bc73 )
  • update dependency org.apache.kafka:kafka-clients to v2.6.0 ( #279 ) ( 1985946 )
  • update dependency org.mockito:mockito-core to v3.5.15 ( #299 ) ( a9baa99 )

0.4.1 (2020-09-28)

Bug Fixes

  • Make BufferingPullSubscriber use List instead of ImmutableList so it is beam friendly. ( #256 ) ( a23e26f )
  • Make flogger a runtime dependency by default. ( #265 ) ( 747bc66 ), closes #213

Dependencies

  • update dependency com.google.cloud:google-cloud-resourcemanager to v0.118.2-alpha ( #259 ) ( 634116c )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.10.0 ( #260 ) ( f4442a0 )
  • update dependency io.grpc:grpc-testing to v1.32.1 ( #261 ) ( 2f73e2f )
  • update dependency org.mockito:mockito-core to v3.5.13 ( #262 ) ( 43bdd1e )

0.4.0 (2020-09-24)

Features

  • Implement internal CursorClient which will be used by kafka shim. ( #252 ) ( eabe900 )
  • Use TopicStats to implement getSplitBacklog ( #228 ) ( 9a889a9 )

Bug Fixes

  • Assorted warnings. ( #246 ) ( a65da39 )
  • Fix BufferingPullSubscriber to not seek after sending flow control tokens. ( #253 ) ( 0e20d80 )
  • Fix warning due to unchecked cast. ( #241 ) ( a3a21b4 )
  • Move settings for the topic backlog reader to TopicBacklogReaderSettings ( #254 ) ( 0ee60eb )

0.3.1 (2020-09-10)

Bug Fixes

  • Create a pool of Channels for each target. ( 36b472b )
  • Split retryable codes for streams, and retry RESOURCE_EXHAUSTED errors. ( e4efe0b )

Documentation

0.3.0 (2020-09-03)

Features

  • Enable project id usage by performing lookups where necessary. ( #223 ) ( e30896e )

Bug Fixes

  • Add Documentation ( #221 ) ( 6c430da )
  • Add more coverage ( #220 ) ( f92f828 )
  • add test coverage for cloudpubsub folder. ( #218 ) ( a70a60f )
  • change toString to value in TopicStatsClient ( #210 ) ( 30f0b10 )
  • Embed builder in path classes and make components directly accessible ( #231 ) ( e5e7d7d )
  • Implement DefaultRoutingPolicyTest ( #188 ) ( fa49931 )
  • Improve test coverage for internal/wire folder. ( #214 ) ( db2bc7a )
  • temporarily disable reporting to unblock releases ( #225 ) ( 2b66535 )

Reverts

  • Revert "samples: update samples for automatic subscriber assignment (#189)" (#198) ( eefe717 ), closes #189 #198

Dependencies

  • update dependency io.grpc:grpc-testing to v1.31.1 ( #205 ) ( 219c832 )
  • update dependency org.mockito:mockito-core to v3.5.0 ( #206 ) ( 7b3d297 )
  • update dependency org.mockito:mockito-core to v3.5.2 ( #209 ) ( a4ca349 )
  • update dependency org.mockito:mockito-core to v3.5.5 ( #217 ) ( a6afc60 )
  • update dependency org.mockito:mockito-core to v3.5.6 ( #222 ) ( f25077d )
  • update dependency org.mockito:mockito-core to v3.5.7 ( #224 ) ( e4061ba )
  • update shared-dependencies to a version with a working GRPC version. ( 89f6582 )

0.2.0 (2020-08-11)

Features

  • add api client headers to outbound requests ( #182 ) ( 0b47e06 )
  • Add the ability to use automatic subscriber assignment to the subscriber settings ( #163 ) ( a396f24 )
  • Add the TopicStats client ( #179 ) ( 7eb7861 )
  • Implement Assigner, which delivers partition assignments to a PartitionAssignmentReceiver ( #133 ) ( a4485d9 )

Bug Fixes

  • add clirr ignored diffs files ( #184 ) ( 0122757 )
  • Add missing monitor from startSubscriber. ( #142 ) ( d2a90d8 )
  • Fix assorted lint errors. ( #143 ) ( 403efb6 )
  • Update SingleConnection to not hold the monitor on upcalls ( #151 ) ( 8274753 )
  • Update synth.py and run synthtool to get new pubsublite sources. ( #171 ) ( 90bb70d )

Dependencies

  • update dependency com.google.auto.value:auto-value to v1.7.3 ( #129 ) ( c9492a0 )
  • update dependency com.google.auto.value:auto-value to v1.7.4 ( #156 ) ( cb4cd9f )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.107.0 ( #123 ) ( 5c3e977 )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.108.0 ( #158 ) ( 924052b )
  • update dependency com.google.cloud:google-cloud-pubsub to v1.108.1 ( #186 ) ( c466e2f )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.107.0 ( #124 ) ( b7e9e91 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.108.0 ( #157 ) ( 56a8003 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.108.1 ( #187 ) ( 24ab8e2 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.8.1 ( #138 ) ( 176101e )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.8.2 ( #154 ) ( 6739d11 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.8.3 ( #159 ) ( 8d3e0de )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.8.5 ( #192 ) ( 9894260 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.8.6 ( #195 ) ( 8effb81 )
  • update dependency io.grpc:grpc-testing to v1.30.2 ( #145 ) ( ff77de9 )
  • update dependency io.grpc:grpc-testing to v1.31.0 ( #177 ) ( f3c4f79 )
  • update dependency org.mockito:mockito-core to v3.4.0 ( #161 ) ( c3c2c6f )
  • update dependency org.mockito:mockito-core to v3.4.2 ( #164 ) ( f0f1e06 )
  • update dependency org.mockito:mockito-core to v3.4.3 ( #165 ) ( 6d0554a )
  • update dependency org.mockito:mockito-core to v3.4.4 ( #167 ) ( 8815e9e )
  • update dependency org.mockito:mockito-core to v3.4.6 ( #176 ) ( 5de006f )

Documentation

0.1.8 (2020-06-09)

Bug Fixes

  • Return an error on publish if the publisher's state is not RUNNING ( #81 ) ( 74d61fd )

Dependencies

  • update dependency com.google.auto.service:auto-service-annotations to v1.0-rc7 ( #102 ) ( 081c4d7 )
  • update dependency com.google.auto.value:auto-value to v1.7.2 ( #103 ) ( ee6bad1 )
  • update dependency com.google.cloud:google-cloud-pubsub-bom to v1.106.0 ( #104 ) ( dd31d70 )
  • update dependency com.google.cloud:google-cloud-shared-dependencies to v0.7.0 ( #105 ) ( 27cf47c )
  • update dependency com.google.errorprone:error_prone_annotations to v2.4.0 ( #107 ) ( 8c8666f )
  • update dependency io.grpc:grpc-testing to v1.29.0 ( #108 ) ( 45e019a )
  • update dependency io.grpc:grpc-testing to v1.30.0 ( #119 ) ( eb1fee5 )
  • update dependency joda-time:joda-time to v2.10.6 ( #109 ) ( 9dd6266 )
  • update dependency org.apache.beam:beam-runners-direct-java to v2.22.0 ( #117 ) ( a19619f )
  • update dependency org.apache.beam:beam-sdks-java-core to v2.22.0 ( #118 ) ( 395f02f )
  • update dependency org.mockito:mockito-core to v3.3.3 ( #110 ) ( 118d48c )

0.1.7 (2020-06-05)

Bug Fixes

  • Modify CommitterImpl to exit early in case of permanent failure to avoid waiting on its own actions to complete. ( #90 ) ( 8858d58 )

0.1.6 (2020-05-27)

Bug Fixes

0.1.5 (2020-05-21)

Bug Fixes

  • Implement ChannelCache, which aggregates stubs to a single channel, and properly cleans them up on teardown. ( #72 ) ( 502484a )
  • Modify UnboundedRreader to correctly initialize committers. ( #74 ) ( 5fa68c7 )
  • use appropriate x-version-update in POM files ( #68 ) ( 12edb04 )

Documentation

  • Update sample code snippets in the main readme ( #71 ) ( 603b4a7 )

0.1.4 (2020-05-20)

Bug Fixes

  • Propogate context in SinglePartitionPublisherBuilder. ( #63 ) ( 8b2d525 )

0.1.3 (2020-05-20)

Bug Fixes

  • fix the regex in Versions.java to actually split on '.' ( #57 ) ( b9371b1 )

0.1.2 (2020-05-19)

Documentation

0.1.1 (2020-05-19)

Bug Fixes

  • bump shared config version to trigger a release ( #48 ) ( 7f2fdef )

0.1.0 (2020-05-18)

Features

  • add exponential backoff to stream retries ( #34 ) ( bdb0995 )

Bug Fixes

Reverts

  • Revert "chore: release 0.1.0 (#36)" (#43) ( 66313ae ), closes #36 #43

Documentation

Create a Mobile Website
View Site in Mobile | Classic
Share by: