0.5.2

sea-streamer-types

• Added From<Url> and FromIterator<Url> for StreamerUri #28
• Impl Default for Payload
• Impl serde Serialize & Deserialize for StreamKey

sea-streamer-socket

• Compile socket without stdio backend #35

sea-streamer-redis

• Support nanosecond timestamp in Redis (under feature flag nanosecond-timestamp)
• Support custom message field
• Added RedisProducer::send_with_ts to specify custom timestamp
• Added RedisProducer::flush_immut
• Added RedisProducer::trim to perform XTRIM MAXLEN
• Fixed capacity overflow error in some cases

sea-streamer-file

• Added a special SEA_STREAMER_WILDCARD stream key to subscribe to all streams in a file

sea-streamer-fuse

• Added a StreamJoin component for joining multiple streams by timestamp

Full Changelog: 0.5.0...0.5.2

socket-0.5.1

• Compile socket without stdio backend #35

0.5.0

Upgrades

• Migrate to clap #19
• Upgrade flume to 0.11
• Upgrade rdkafka to 0.36 #22
• Upgrade redis to 0.25 #21

Enhancements

• Use impl Future instead of async-trait #20

House keeping

• Fix clippy warnings #23

Contributors

• @tyt2y3
• @scrogson
• @negezor

Full Changelog: 0.3.2...0.5.0

file-0.5.1

• Fix executables feature

kafka-0.3.2

• Added KafkaProducer::send_record, KafkaProducer::send_message #17

file-0.3.7

• Added FileProducer::path(), FileConsumer::file_id(), FileProducer::file_id()

file-0.3.6

• Added create_only to FileConnectOptions

file-0.3.5

• Fixed a potential race condition

file-0.3.4

• impl std::io::Write for FileSink
• more precise FileEvent::Remove
• end streamer properly after EOS

file-0.3.3

• used a faster CRC implementation
• added option prefetch_message to FileConnectOptions