Curtis Wan

``` 2024-01-22 02:36:23.383 | beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)   |   | 2024-01-22 02:36:23.383 | Stopping socket server request processors (kafka.network.SocketServer) |     |   | 2024-01-22 02:36:23.391 | Not processing HandleCommitsEvent...

### Who is this for and what problem do they have today? ### Why is solving this problem impactful? Frequent offset commitments by a consumer, such as committing offsets immediately...

#### Compiling requirements - JDK 17 - Scala 2.13 #### Running requirements - JDK 17

Operation on S3ObjectControlManager#objectsMetadata may not be thread-safe

1

class TimelineHashMap requires external synchronization. ReplicationControlManager#maybeFenceOneStaleBroker can be a reference to S3ObjectControlManager#triggerCheckEvent.

Problems may exist when node is suddenly shut down, especially some log is creating or opening. Here are some possible relative cases. ## problems in log creating 1) meta stream...

In long running test, producers can not send any record. logs of producers are: ``` 08:25:48.490 [kafka-producer-network-thread | producer-135] WARN Sender - [Producer clientId=producer-135] Got error produce response with correlation...