Zhanhui Li

Why ARM hardware acceleration is guarded by nightly

3

Is there anything that blocks ARM hardware acceleration feature from being stable? Will it be better to guard it using a feature?

fix #49

Refer https://reveng.sourceforge.io/crc-catalogue/all.htm and https://github.com/mrhooray/crc-rs/blob/7e4b1b4879e3bb881f150b550f150df1ff199f04/src/crc32.rs#L60 The initial value should consider `refin = true`.

Guard hardware acceleration with features is preferable, allowing application developers to make the final decision. In addition, it would be convenient to compare pure software implementation performance with alternative crates.

As per title.

HA service data transfer is not reliable.

multiple broker stop/start, client rebalance fails.

[Feature] Implement PushConsumer for Rust SDK

4

### Programming Language of the Client Rust ### Is Your Feature Request Related to a Problem? We need to align features with Java/C++/... ### Describe the Solution You'd Like N/A...

[INFO] Running com.automq.stream.s3.ObjectReaderTest [main] ERROR io.netty.util.ResourceLeakDetector - LEAK: ByteBuf.release() was not called before it's garbage-collected. See https://netty.io/wiki/reference-counted-objects.html for more information. Recent access records: Created at: io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:402) io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:188) io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:179) com.automq.stream.s3.DirectByteBufAlloc.byteBuffer(DirectByteBufAlloc.java:50) com.automq.stream.s3.DirectByteBufAlloc.byteBuffer(DirectByteBufAlloc.java:42)...

2023-11-03 10:07:51,909 INFO commitWalObject with walObject=[broker_id: 2 object_id: -1 sequence_id: -1 sub_streams { }], streamObjects=[end_offset: 4202 object_id: 1 object_size: 107631499], compactedObjects=[] 2023-11-03 10:07:51,913 ERROR Yuck, S3StreamObject is having invalid stream-id:...