A realtime distributed messaging platform
Upgrading
Features:
nsqd: use --tls-root-ca-file in nsqauth request (thanks @intellitrend-team)nsqadmin: upgrade supported ECMA from ES5 to ES2020 (thanks @dudleycarr)nsqadmin: add paused label to topic within the node view (thanks @dudleycarr)nsqadmin: add admin check for topic/node thombstone endpoint (thanks @dudleycarr)nsqd: add support of unix sockets for tcp, http, https listeners (thanks @telepenin)nsqd: add /debug/freememory API (thanks @guozhao-coder)nsqd: nicer tls-min-version help text defaultnsqd: allow unbuffered memory chan if ephemeral or deferrednsqd: use metadata struct for both marshal and unmarshal (thanks @karalabe)nsqd: /info api returns more info (thanks @arshabbir)nsqd: allow disabling both HTTP and HTTPS interfaces (thanks @karalabe)nsqd: enable support for TLS1.3 (thanks @karalabe)nsqadmin: new flag --dev-static-dir instead of debug build tagBugs:
Dockerfile: remove nsswitch.conf check (thanks @dudleycarr)nsqadmin: fix counter by bounding animation steps (thanks @dudleycarr)nsqadmin: fix broken graph template in nsqadmin node view (thanks @dudleycarr)nsqd: fix unsafe concurrency read in RemoveClient (thanks @gueFDF)nsqd: fix panic when statsd enabled and memstats disabled with no topics (thanks @carl-reverb)validTopicChannelNameRegex useless escape characters (thanks @sjatsh)Upgrading
dep support, drop Go 1.9 supportFeatures:
nsqadmin: switch to go:embed for static assetsnsqd: ability to skip ephemeral topics/channels in statsd outputnsqd: ability to configure auth endpoint path (thanks @tufanbarisyildirim)Context to use stdlib context
nsqd: minimize allocations on message send (thanks @imxyb)uniq (thanks @donutloop)nsqd: ability to omit memory stats from /stats (thanks @creker)nsqd: only update internal RDY count for client when it changes (thanks @andyxning)nsqd: bump go-diskqueue (interface change) (thanks @bitpeng)sort.Ints over sort.Sort (thanks @lelenanam)nsqd: configurable queue scan worker pool (thanks @andyxning)nsqd: don't buffer messages when --mem-queue-size=0 (thanks @bitpeng)nsqd: support separate broadcast ports for TCP and HTTP (thanks @shyam-king)Bugs:
nsqadmin: fix graphite key for ephemeral topics/channelslog_level support in configuration file (thanks @edoger)nsqd: handle SIGTERMnsqadmin: fix --proxy-graphite support (thanks @fanlix)nsqlookupd: fix incorrect error message for HTTP listener (thanks @TangDH03)nsqd: fix live lock for high churn ephemeral topic/channel reconnections (thanks @slayercat)nsswitch.conf to ensure go resolver uses /etc/hosts firstnsqd: improve error message when --data-path does not exist (thanks @mdh67899)nsqadmin: fix channel delete, fix source-maps in Firefox (thanks @avtrifanov)nsqadmin: fix nodes list with ipv6 addresses (thanks @andyxning)Upgrading
nsqd: removed support for old metadata scheme used in v0.3.8 and earlier
dep support still present for now, but deprecatedFeatures:
nsqd: add --max-channel-consumers (default unlimited) (thanks @andyxning)nsqd: add --min-output-buffer-timeout (default 25ms) to limit how low a timeout a consumer can request
--max-output-buffer-timeout to 30 seconds (lower timeout, more cpu usage)nsqd: add topic total message bytes to stats (thanks @andyxning)nsqd: add flag to adjust default --output-buffer-timeout (thanks @andyxning)nsqd: add random load balancing for authd requests (thanks @shenhui0509)nsqd: include client TLS cert CommonName in authd requestsnsq_to_file: include topic/channel in most log messagesnsq_to_file: add --log-level and --log-prefix flagsnsq_to_file: big refactor, more robust file switching and syncing and error handlingnsqd: add param to /stats endpoint to allow skipping per-client stats (much faster if many clients)nsqadmin, nsq_stat: use include_clients param for /stats for a big speedup for big clustersnsq_to_file: support for separate working directory with --work-dir (thanks @mccutchen)nsqadmin: add --base-path flag (thanks @blinklv)nsq_to_http: add --header flag (thanks @alwindoss)nsqd: add producer client tcp connections to stats (thanks @sparklxb)nsq_to_file: new flag --sync-interval (default same as previous behavior, 30 seconds) (thanks @alpaker)Bugs:
nsqd: close connections that don't send "magic" header (thanks @JoseFeng)nsqd: exit on all fatal Accept() errors - restart enables better recovery for some conditions (thanks @mdh67899)nsqd, nsqlookupd, nsqadmin: refactor LogLevel, general refactor to better exit on all fatal errorsnsqadmin: switch to using judwhite/go-svc like nsqd and nsqadmin donsqadmin: fix clients count and channel total message rate (new bugs introduced in this cycle)nsqd, nsqlookupd, nsqadmin: fix http error response unreliable json serializationnsqlookupd: fix orphaned ephemeral topics in registration DBnsqd: fix topic message mis-counting if there are backend write errors (thanks @SwanSpouse)nsqlookupd: optimize /nodes endpoint, much better for hundreds of nsqd (thanks @andyxning)GOFLAGS to BLDFLAGS in Makefile now that GOFLAGS is automatically used by gonsqadmin: eslint reported fixes/cleanupsUpgrading from 1.0.0-compat: Just a few backwards incompatible changes:
nsq_pubsub utilitynsqd flags --msg-timeout and --statsd-interval only take duration strings
nsqd: http /mpub endpoint binary param interprets "0" or "false" to mean text mode
The previous release, version "1.0.0-compat", was curiously-named to indicate an almost (but not quite) complete transition to a 1.0 api-stable release line. Confusingly, this follow-up release which completes the transition comes more than a year later. Because there have been a fair number of changes and improvements in the past year, an additional minor version bump seems appropriate.
Features:
nsqd: add memory stats to http /stats response (thanks @sparklxb)nsqd, nsqlookupd, nsqadmin: add --log-level option (deprecating --verbose) (thanks @antihax)nsqd, nsqlookupd, nsqadmin: logging refactor to use log levels everywherensqadmin: X-Forwarded-User based "admin" permission (thanks @chen-anders)nsqd: add topic/channel filter to /stats, use in nsqadmin and nsq_stat for efficiency (thanks @andyxning)nsq_to_file: refactor/cleanupnsq_to_nsq: support multiple --topic flags (thanks @jlr52)nsq_tail: support multiple --topic flags (thanks @soar)nsqd, nsqadmin: update internal http client with new go http.Transport features (keepalives, timeouts, dualstack)
nsqadmin, nsqd, nsqlookupd
dep (replacing gpm) (thanks @judwhite)nsqd: better memory usage when messages have different sizes (thanks @andyxning)nsqd: optimize random channel selection in queueScanLoop (thanks @vearne)nsqd: buffer and spread statsd udp sends (avoid big burst of udp, less chance of loss)nsqlookupd: optimize for many producers (thousands) (thanks @andyxning)nsqd: new topic can be unlocked faster after creationnsqadmin: update JS depsBugs:
nsqadmin: fix missing channels in topic listto_nsq: fix divide-by-zero issue when --rate not specified (thanks @adamweiner)nsqd: clamp requeue timeout to range instead of dropping connection (thanks @tsholmes)nsqd: fix race when client subscribes to ephemeral topic or channel while it is being cleaned up (reported by @slayercat)nsqd: fix deflate level handlingnsqd: fix channel shutdown flush racensq_to_file: fix connection leaks when using --topic-pattern (thanks @jxskiss)nsqlookupd: close connection when magic read fails (thanks @yc90s)nsqd: fix some races getting ChannelStats (thanks @daroot)nsqd: fix e2e timings config example, add range validation (thanks @protoss-player)nsq_tail: logging to stderr (only nsq messages to stdout)nsq_to_http: fix http connect/request timeout flags (thanks @kamyanskiy)nsqd: fix possible lookupd-identify-error busy-loop (reported by @andyxning)nsqadmin: fix typo "Delfate" in connection attrs list (thanks @arussellsaw)nsqd: fix loading metadata with messages queued on un-paused topic with multiple channels (thanks @michaelyou)nsqlookupd: exit with error when failed to listen on ports (thanks @stephens2424)nsqadmin: fix html escaping for large_graph url inside javascriptSee release v1.1.0
Upgrading from 0.3.8: Numerous backwards incompatible changes:
nsqd features removed:
/{m,}put (use /{m,}pub)/{create,delete,empty,pause,unpause}_{topic,channel} (use /{topic,channel}/<operation>)--max-message-size flag (use --max-msg-size)V2 protocol IDENTIFY command short_id and long_id properties (use client_id, hostname, and user_agent)/stats HTTP response name property (use client_id)nsqlookupd features removed:
/{create,delete}_{topic,channel} (use /{topic,channel}/<operation>)/tombstone_topic_producer (use /topic/tombstone)nsqadmin features removed:
--template-dir flag (not required, templates are compiled into binary)--use-statsd-prefixes flag (use --statsd-counter-format and --statsd-gauge-format)nsq_stat --status-every flag (use --interval)--reader-opt on all binaries that had this flag (use --consumer-opt)nsq_to_file --gzip-compression flag (use --gzip-level)nsq_to_http --http-timeout and --http-timeout-ms flags (use --http-connect-timeout and --http-request-timeout)nsq_to_http --round-robin flag (use --mode=round-robin)nsq_to_http --max-backoff-duration flag (use --consumer-opt=max_backoff_duration,X)nsq_to_http --throttle-fraction flag (use --sample=X)nsq_to_nsq --max-backoff-duration flag (use --consumer-opt=max_backoff_duration,X)nsqd --worker-id deprecated in favor of --node-id (to be fully removed in subsequent release)This is a compatibility release that drops a wide range of previously deprecated features (#367) while introducing some new deprecations (#844) that we intend to fully remove in a subsequent 1.0 release.
Of note, all of the pre-1.0 HTTP endpoints (and response formats) are gone. Any clients or tools that use these endpoints/response formats won't work with this release. These changes have been available since 0.2.29 (released in July of 2014). Clients wishing to forwards-compatibly upgrade can either use the new endpoints or send the following header:
Accept: application/vnd.nsq version=1.0
Also, many command line flags have been removed — in almost all cases an alternative is available with a (hopefully) more obvious name. These changes have the same affect on config file option names.
On Linux, this release will automatically migrate nsq.<worker-id>.dat named metadata files to nsq.dat in a way that allows users to seamlessly downgrade from this release back to 0.3.8, if necessary. A subsequent release will clean up these convenience symlinks and observe only nsq.dat. See the discussion in #741 and the changes #844 for more details.
Performance wise, #741 landed which significantly reduces global contention on internal message ID generation, providing a ~1.75x speed improvement on multi-topic benchmarks.
Finally, a number of minor issues were resolved spanning contributions from 9 community members! Thanks!
Features:
alpine base image for official Docker container (thanks @kenjones-cisco)nsqadmin: /config API (thanks @kenjones-cisco)nsqadmin, nsq_stat, nsq_to_file, nsq_to_http: HTTP client connect/request timeouts (thanks @kenjones-cisco)to_nsq: add --rate message throttling optionnsqd: per-topic message IDs (multi-topic pub benchmarks up to ~1.75x faster)nsqd, nsqlookupd, nsqadmin: add --log-prefix option (thanks @ploxiln)nsqd: deprecate --worker-id for --node-id and drop ID from nsqd.dat file (thanks @ploxiln)Bugs:
nsqlookupd: properly close TCP connection in IOLoop (thanks @JackDrogon)nsqdmin: fix root CA verification (thanks @joshuarubin)nsq_to_file: require --topic or --topic-pattern (thanks @judwhite)nsqadmin: fix handling of IPv6 broadcast addresses (thanks @magnetised)nsqd: fix requeue and deferred message accounting (thanks @sdbaiguanghe)nsqd: switch to golang/snappy to fix snappy deadlocknsqd: fix default --broadcast-address and error when nsqlookupd reqs fail (thanks @ploxiln @stephensearles)nsqd: prevent panic in binary /mpub (thanks @yangyifeng01)nsqadmin: allow ctrl/meta+click to open a new tabnsqd: check for exit before requeingUpgrading from 0.3.7: Binaries contain no backwards incompatible changes.
This release fixes a critical regression in 0.3.7 that could result in message loss when attempting to cleanly shutdown nsqd by sending it a SIGTERM. The expected behavior was for it to flush messages in internal buffers to disk before exiting. See #757 and #759 for more details.
A few performance improvements landed including #743, which improves channel throughput by ~17%, and #740, which reduces garbage when reading messages from disk.
We're now stripping debug info, reducing binary size, in the official binary downloads and Windows binaries are now bundled with the appropriate .exe extension (#726 and #751).
Features:
nsqd: remove channel messagePump
nsqd: reduce garbage when reading from diskqueue (thanks @dieterbe)Bugs:
nsqd: properly handle SIGTERM (thanks @judwhite)go-options
nsqd: diskqueue sync count on both read/writensqadmin: make rate column work without --proxy-graphite (thanks @ploxiln).exe extension to Windows binaries (thanks @ploxiln)nsqadmin: fix connected duration > 1hr
Upgrading from 0.3.6: Binaries contain no backwards incompatible changes.
This release has been built with Go 1.6.
Highlights include the various work done to reduce nsqd lock contention, significantly improving the impact of high load on the /stats endpoint, addressing issues with timeouts and failures in nsqadmin (#700, #701, #703, #709).
Thanks to @judwhite, nsqd and nsqlookupd now natively support being run as a Windows service (#718). We're also now publishing official Windows releases.
nsqd will now flock its data directory on linux, preventing two nsqd from running simultaneously pointed at the same path (#583).
On the bugfix side, the most noteworthy change is that nsqd will now correctly reset health state on a successful backend write (#671).
Features:
nsqd: reduce lock contention (thanks @zachbadgett @absolute8511)nsqd/nsqlookupd: support running as a windows service (thanks @judwhite)nsqd: support enabling/disabling block profile via HTTP (thanks @absolute8511)nsqd: support POST /debug/pprof/symbol (thanks @absolute8511)nsqadmin: add flags for formatting statsd keys (thanks @kesutton)nsqd: flock --data-path on linuxnsqd: optimize GUID generation (thanks @ploxiln)Bugs:
nsqd: fix max size accounting in diskqueue (thanks @judwhite)nsqd: reset health on successful backend write (thanks @judwhite)nsqd: prevent OOM when reading from nsqlookupd peerUpgrading from 0.3.5: Binaries contain no backwards incompatible changes.
We've adopted the Contributor Covenant 1.2 Code of Conduct (#593). Help us keep NSQ open and inclusive by reading and following this document.
We closed a few longstanding issues related to nsqadmin, namely (#323, et al.) converting it to an API and single-page app (so that it is much easier to develop), displaying fine-grained errors (#421, #657), and enabling support for --tls-required configurations (#396).
For nsqd, we added support for deferred publishing aka DPUB (#293), which allows a producer to specify a duration of time to delay initial delivery of the message. We also addressed performance issues relating to large numbers of topics/channels (#577) by removing some per-channel goroutines in favor of a centralized, periodic, garbage collection approach.
In order to provide more flexibility when deploying NSQ in dynamically orchestrated topologies, nsqd now supports the ability to configure nsqlookupd peers at runtime via HTTP (#601), eliminating the need to restart the daemon.
As part of the large nsqadmin refactoring, we took the opportunity to cleanup the internals for all of the daemon's HTTP code paths (#601, #610, #612, #641) as well as improving the test suite so that it doesn't leave around temporary files (#553).
Features:
nsqadmin: convert to API / single-page appnsqadmin: expand notification contextnsqd: add deferred pub (DPUB)nsqd: drop per-channel queue workers in favor of centralized queue GCnsqlookupd: improve registration DB performance (thanks @xiaost)nsqd: HTTP endpoints to dynamically configure nsqlookupd peersnsqd: support for filtering /stats to topic/channel (thanks @chrusty)nsqd: clarify help text for --e2e-processing-latency-percentile
--{consumer,producer}-opt to nsq.ConfigFlag
Bugs:
nsqadmin: update statsd prefix to stats.counters
nsqadmin: display upstream/partial errorsnsqdamin/nsqd: support for --tls-required
nsqd: ignore benign EOF errorsnsqd: GUID error handling / catch errors if GUID goes backwards (thanks @mpe)nsqd: fix valid range for --worker-id
nsqd: fix benchmarks (thanks @Dieterbe)nsqd: enforce diskqueue min/max message size (thanks @twmb)Upgrading from 0.3.4: Binaries contain no backwards incompatible changes.
This is another quick bug fix release to address the broken nsqadmin binary in the v0.3.4 distribution (see #578).
See the release notes for v0.3.3 for more info.