Releases: zendesk/racecar
Releases · zendesk/racecar
v2.0.0
- Replace
ruby-kafka
withrdkafka-ruby
as the low-level library underneath Racecar (#97). - Fix
max_wait_time
usage (#179). - Removed config option
sasl_over_ssl
. - [Racecar::Consumer] Do not pause consuming partitions on exception.
- [Racecar::Consumer]
topic
,payload
andkey
are mandadory to methodproduce
. - [Racecar::Consumer]
process_batch
retrieves an array of messages instead of batch object. - [Racecar::Consumer] Remove
offset_retention_time
. - [Racecar::Consumer] Allow providing
additional_config
for subscriptions. - [Racecar::Consumer] Provide access to
producer
andconsumer
. - [Racecar::Consumer] Enforce delivering messages with method
deliver!
. - [Racecar::Consumer] instead of raising when a partition EOF is reached, the result can be queried through
consumer.last_poll_read_partition_eof?
. - [Racecar::Config] Remove
offset_retention_time
,connect_timeout
andoffset_commit_threshold
. - [Racecar::Config] Pass config to
rdkafka-ruby
viaproducer
andconsumer
. - [Racecar::Config] Replace
max_fetch_queue_size
withmin_message_queue_size
. - [Racecar::Config] Add
synchronous_commits
to control blocking ofconsumer.commit
(defaultfalse
). - [Racecar::Config] Add
security_protocol
to control protocol between client and broker. - [Racecar::Config] SSL configuration via
ssl_ca_location
,ssl_crl_location
,ssl_keystore_location
andssl_keystore_password
. - [Racecar::Config] SASL configuration via
sasl_mechanism
,sasl_kerberos_service_name
,sasl_kerberos_principal
,sasl_kerberos_kinit_cmd
,sasl_kerberos_keytab
,sasl_kerberos_min_time_before_relogin
,sasl_username
andsasl_password
. - [Instrumentation]
produce_message.racecar
sent whenever a produced message is queued. Payload includestopic
,key
,value
andcreate_time
. - [Instrumentation]
acknowledged_message.racecar
send whenever a produced message was successfully received by Kafka. Payload includesoffset
andpartition
, but no message details. - [Instrumentation]
rdkafka-ruby
does not yet provide instrumentation rdkafka-ruby#54. - [Instrumentation] if processors define a
statistics_callback
, it will be called once every second for every subscription or producer connection. The first argument will be a Hash, for contents see librdkafka STATISTICS.md. - Add current directory to
$LOAD_PATH
only when--require
option is used (#117). - Remove manual heartbeat support, see Long-running message processing section in README.
v2.0.0.beta1
Version 2.0.0.beta1
v1.0.1
v2.0.0.alpha3
Version 2.0.0.alpha3
v2.0.0.alpha2
Version 2.0.0.alpha2
v2.0.0.alpha1
Version 2.0.0.alpha1
v1.0.0
racecar v0.5.0
Version 0.5.0.beta2
Merge pull request #116 from zendesk/jtopige_v0.5.0.beta2 Update version to v0.5.0.beta2