automq

automq copied to clipboard

WIP, it only supports tail-read now.

Chillax-0v0

ShadowySpirits

Log level & isXXEnable

4

Search all LOGGER.debug in s3stream module and add LOGGER.isDebugEnabled() check for them

superhx

close #1244

warr99

Pre-check for Configuration Validity: - `s3.block.cache.size` should not exceed the JVM memory limit (Heap Buffer / Direct Buffer). - `s3.wal.cache.size` should not exceed the JVM memory limit (Heap Buffer /...

superhx

Long-running tasks found that deleting topics that had data of several TBs may block the event loop in the controller. Although the problem is already fixed, we should add some...

ShadowySpirits

### Who is this for and what problem do they have today? * The current kafka-producer-perf-test.sh cannot send messages to partitions on the specified broker. ### Why is solving this...

warr99

feat(issues1101): argparse4j downgr…

3

issues: https://github.com/AutoMQ/automq/issues/1101

Shuimo03

superhx

Controller should return the correct number of sub-responses when an error occurs

1

related #603 server.log ``` [2023-12-27 03:31:44,875] ERROR Response size: 0 not match request size: 1 (kafka.log.stream.s3.network.ControllerRequestSender) [2023-12-27 03:31:44,882] ERROR [Stream id=14886 epoch=2] trim fail (com.automq.stream.s3.S3Stream) java.lang.RuntimeException: Response size not match...

Chillax-0v0