v1.6.0-beta.7

What's Changed

• upgrade protobufjs to 7.6.5 by @YashGajera in #408
• Release of 1.6.0-beta.7 by @YashGajera in #409

Full Changelog: v1.6.0-beta.6...v1.6.0-beta.7

v1.6.0-beta.6

What's Changed

• Bump up the versions for google cloud NPM packages by @k-gupta in #11
• Integration command exits with jest exit code by @plameniv in #40
• Fix failing Kafka integration test by @plameniv in #43
• Remove Deprecated new buffer usage by @cross311 in #46
• Support Changes in Metrics Tags for Prometheus by @plameniv in #38
• kubernetes: adjust logic for creating a watch by @talam in #48
• Revert commit of incorrect yarn.lock from #48 by @talam in #50
• kubernetes: fix kubernetes-client package build issue with Node 8 by @talam in #51
• build: fix grep check to only match if we're using node 8 by @talam in #53
• kubernetes: update @kubernetes/client-node package to 0.11.1 by @talam in #54
• kubernetes: add in additional logging details for watch errors by @talam in #56
• improve timeout of k8s watch by @sklose in #59
• Allow opt-in to creating Azure queues dynamically on write by @chrnola in #55
• core: update ConsoleLogger to correctly log out nested objects by @talam in #60
• kubernetes: create k8sPollSource that periodically polls for resources instead of using a watch by @talam in #61
• Add preprocessor concept for Azure Queues to support messages not following the envelope format by @butorine in #65
• fix missing bind when creating new azure queues by @sklose in #63
• fix lint errors by @sklose in #67
• refactor queue client to avoid exporting type from azure library as p… by @sklose in #68
• kubernetes: add in timeout to poll request in case request to k8s hangs by @talam in #70
• Fix bug when options are ignored in QueueClient by @butorine in #69
• Decorator returning class with empty string name by @plameniv in #73
• support multiple concurrent writers for BoundedPriorityQueue by @talam in #76
• core: version bump to 1.2.0-beta.11 by @talam in #77
• Update Cookie Cutter Dependencies by @plameniv in #75
• better throughput in RPC mode while guaranteeing correctness of state by @sklose in #83
• Update dependencies for Node 8 by @plameniv in #86
• Reveal az blob & queue service url params, to allow for pointing at a local emulator. by @sean-halpin in #89
• Way to Inspect 'Invalid' Messages by @plameniv in #82
• Better Log Message when a Message Fails to Process and fix to upsertSproc SeqConErr details by @plameniv in #91
• Update CHANGELOG.md by @sklose in #98
• bump develop to 1.3 by @sklose in #106
• Add Dead Letter Queue to QueueInputSource by @plameniv in #93
• merge release/1.2 into develop by @sklose in #112
• Remove support for node 8 by @emmalynch in #113
• core: unable to close bounded priority queue by @talam in #116
• ConcurrentMessageProcessor suppresses error details by @sklose in #124
• Fix breaking API change in Azure Queues by @plameniv in #122
• Add RedisStreamSink & RedisStreamSource by @dmmulroy in #126
• Add GCP PubSub Sink by @k-gupta in #125
• Bump Redis version to publish new package by @sklose in #127
• prometheus module should not throw an error when incrementing by 0 by @sklose in #130
• Prevent config.parse() output from being used as input by @chrnola in #134
• multi cosmos collections (#81) by @emmalynch in #117
• fix MsSqlSink throws wrong error by @sklose in #140
• Add AMQP Sink + Source by @plameniv in #136
• Add metrics to AMQP by @plameniv in #144
• Add docs to AMQP package by @plameniv in #147
• Add cookie-cutter-jaeger by @mag415 in #151
• cookie-cutter-redis: add support for multiple streams by @mag415 in #155
• cookie-cutter-redis: add metrics by @mag415 in #156
• Have separate queue capacity per priority level by @plameniv in #160
• Fix lz4 error by adding resolution by @plameniv in #161
• Add new Jaeger package to README by @chrnola in #158
• fix broken metrics, reclaim PEL messages less often by @sklose in #163
• fix pending list not fully drained on startup, added password config by @sklose in #164
• fix messages are acked on error by @sklose in #168
• check for failed acks to redis by @sklose in #169
• fix xReadGroup ignores all but first message from batch by @sklose in #170
• Implement IEncodedMessageEmbedder for ProtoMessageEncoder by @plameniv in #174
• cleanup redis stream implementation by @sklose in #171
• make some redis options nullable so the default value can be overwrit… by @sklose in #177
• troubleshoot redis stream issue by @sklose in #179
• Allow negative values in Prometheus histogram by @plameniv in #181
• Prevent BoundedPriorityQueue from deprioritizing waiting enqueue calls by @plameniv in #180
• Fix backwards compatibility for ProtoMessageEncoder by @plameniv in #182
• Version bump for Proto change by @plameniv in #183
• Change LogLevel from Error -> Warn when retrieving Kafka watermarks by @sklose in #184
• fix 'yarn audit' issues [full ci] by @sklose in #187
• fix sec vuln in node-fetch by @sklose in #189
• Add auth for amqp source and sink by @prachi30 in #192
• Add AMQP package to README by @plameniv in #193
• Add vhost support for amqp by @prachi30 in #194
• kubernetes: adjust logging to be less verbose by @talam in #195
• detect when kafkajs is stuck with stale broker metadata by @sklose in #186
• Ensure RedisClient's "type" metric label is always a string by @chrnola in #196
• Fix wrong string function in Kafka by @plameniv in #197
• address vulnerability in node-forge package [full ci] by @sklose in #200
• bump develop to 1.4 by @sklose in #201
• Don't extract data field in QueueInputSource when encoder isEmbeddable by @plameniv in #203
• Azure module integration tests by @plameniv in #204
• fix redis client skipping over messages when there is an invalid mess… by @sklose in #209
• Fix: pass string error message to metrics by @k-gupta in #210
• [kafka] Expose compression settings for producers via kafkaSink by @chrnola in #215
• force application to restart on redis disconnect by @sklose in #217
• upgrading gcp dependencies in pack...