v0.7.0

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)

v0.6.5

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)

v0.6.4

0.6.4 (2020-11-11)

Dependencies

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

v0.6.3

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)

v0.6.2

0.6.2 (2020-11-02)

Dependencies

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

v0.6.1

0.6.1 (2020-10-27)

Dependencies

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

v0.6.0

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)

v0.5.0

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)

v0.4.1

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)

v0.4.0

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)