Tags: zhaopinglu/fluvio
Tags
Change default max_bytes in consumer (infinyon#2276) This changes `MAX_FETCH_BYTES` to be the same value of `STORAGE_MAX_BATCH_SIZE` + the size of the other felds in a `FetchableTopicResponse` in order to be able to receive responses with at least a batch of that size. Fixes infinyon#2259
Topic level compression fix (infinyon#2264) Closes infinyon#2265 Adding #[fluvio(min_version) in Replica struct was provoking using the default for compression type. This changes fixes that
add compression support to fluvio produce cli (infinyon#2246) Closes infinyon#2245 adds a `--compression` flag to `fluvio produce` command. Supported values are `none`, `gzip`, `snap` and `lz4`
fluvio-test data generator (infinyon#2187) Resolves infinyon#2129 Add test `generator`. Uses a topic as event bus to synchronize all producers (as foundation for perf testing) ``` FLAGS: -h, --help Prints help information --multi-run When set, unique topics will be used so multiple instances of generator against cluster won't collide -V, --version Prints version information -v, --verbose Opt-in to detailed output printed to stdout OPTIONS: --linger <batch-linger-ms> Producer linger (ms) --batch-size <batch-size> Producer batch size (bytes) --producers <producers> Number of producers to create [default: 1] --record-size <record-size> Record payload size used by test (bytes) [default: 1000] --runtime-seconds <runtime-seconds> Max time we want the producer to run, in seconds - Default: forever --topics <topics> Number of topics for producers to send traffic to [default: 1] ``` Additional flag `--multi-run` provided for the case of running multiple instances of generator against the same cluster w/o collision.
fix zero copy problem (infinyon#2182) resolves infinyon#2181
feat: translate _ in connector parameters keys to - (infinyon#2150) Also remove the `.clone()` calls in that line Fixes infinyon#2149
Don't HTML escape consumer data with `--format` (infinyon#2098) Resolves infinyon#1628 Added testcase in cli-smoke test
Set TLS domain in installer (infinyon#1992) Co-authored-by: Nick Cardin <nick@cardin.email>
PreviousNext