Commit Graph

4 Commits

Author SHA1 Message Date
Cwen Yin 0fa7a8eebe
Kafka attack: support more auth mechanisms (#233)
* kafka attack: support more auth mechanism

Signed-off-by: cwen0 <cwenyin0@gmail.com>

* fix typo

Signed-off-by: cwen0 <cwenyin0@gmail.com>

* format header

Signed-off-by: cwen0 <cwenyin0@gmail.com>

* format header

Signed-off-by: cwen0 <cwenyin0@gmail.com>

---------

Signed-off-by: cwen0 <cwenyin0@gmail.com>
2023-02-01 19:15:19 +08:00
Cwen Yin 31631c3178
kafka io attack: add username and password flags (#231)
* add username and password flags

Signed-off-by: cwen0 <cwenyin0@gmail.com>

* fix ci

Signed-off-by: cwen0 <cwenyin0@gmail.com>

---------

Signed-off-by: cwen0 <cwenyin0@gmail.com>
2023-01-29 18:07:55 +08:00
xixi adea8d5043
kafka attack: fill action support change retention bytes (#181)
* kafka attack: fill action support change retention bytes

Signed-off-by: xixi <i@hexilee.me>

* modify retentionBytes successfully

Signed-off-by: xixi <i@hexilee.me>

* support recover retention bytes

Signed-off-by: xixi <i@hexilee.me>
2022-07-13 22:55:06 +08:00
xixi c9dcbc36f7
implement kafka chaos (#154)
* add kafka chaos

Signed-off-by: xixi <i@hexilee.me>

* register all options

Signed-off-by: xixi <i@hexilee.me>

* move some global flags to local

Signed-off-by: xixi <i@hexilee.me>

* set default rps to 1 << 32

Signed-off-by: xixi <i@hexilee.me>

* complete flood

Signed-off-by: xixi <i@hexilee.me>

* add --no-silent option

Signed-off-by: xixi <i@hexilee.me>

* complete fill subcommand

Signed-off-by: xixi <i@hexilee.me>

* add partition option

Signed-off-by: xixi <i@hexilee.me>

* fix headers

Signed-off-by: xixi <i@hexilee.me>

* add config file

Signed-off-by: xixi <i@hexilee.me>

* complete io inject

Signed-off-by: xixi <i@hexilee.me>

* mod tidy

Signed-off-by: xixi <i@hexilee.me>

* handle errors

Signed-off-by: xixi <i@hexilee.me>

* fix executable mode

Signed-off-by: xixi <i@hexilee.me>

* fix io fault

Signed-off-by: xixi <i@hexilee.me>

* modify perm of dir

Signed-off-by: xixi <i@hexilee.me>

* change default threads and tps

Signed-off-by: xixi <i@hexilee.me>

* support SASL

Signed-off-by: xixi <i@hexilee.me>

* add MaxBytes for fill

Signed-off-by: xixi <i@hexilee.me>

* fix headers

Signed-off-by: xixi <i@hexilee.me>

* fix headers

Signed-off-by: xixi <i@hexilee.me>

* remove NoSilent flag

Signed-off-by: xixi <i@hexilee.me>

* return error in attack

Signed-off-by: xixi <i@hexilee.me>

* split Validate of KafkaCommand

Signed-off-by: xixi <i@hexilee.me>

* remove empty line

Signed-off-by: xixi <i@hexilee.me>

* use writer instead of connection

Signed-off-by: xixi <i@hexilee.me>

* use conn instead of writer

Signed-off-by: xixi <i@hexilee.me>

* fix bugs

Signed-off-by: xixi <i@hexilee.me>

* fix description

Signed-off-by: xixi <i@hexilee.me>

* fix some bugs

Signed-off-by: xixi <i@hexilee.me>

* return err when reading dir fails

Signed-off-by: xixi <i@hexilee.me>

* save origin file mode

Signed-off-by: xixi <i@hexilee.me>

* add unit-test for attackKafkaIO

Signed-off-by: xixi <i@hexilee.me>

* rename newFs to originFs in kafka_test

Signed-off-by: xixi <i@hexilee.me>

* remove rps limit

Signed-off-by: xixi <i@hexilee.me>

Co-authored-by: WangXiang <xiang13225080@163.com>
2022-05-24 17:14:47 +08:00