mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2025-11-09 03:19:14 +08:00
7a509adc23
## What's New This enhanced Java diagnostic client adds detailed logging to understand exactly what the Kafka consumer is waiting for during seekToBeginning() + poll(): ### Features 1. **Detailed Exception Diagnosis** - Catches TimeoutException and reports what consumer is blocked on - Shows exception type and message - Suggests possible root causes 2. **Request/Response Tracking** - Shows when each operation completes or times out - Tracks timing for each poll() attempt - Reports records received vs expected 3. **Comprehensive Output** - Clear separation of steps (assign → seek → poll) - Summary statistics (successful/failed polls, total records) - Automated diagnosis of the issue 4. **Faster Feedback** - Reduced timeout from 30s to 15s per poll - Reduced default API timeout from 60s to 10s - Fails faster so we can iterate ### Expected Output **Success:** **Failure (what we're debugging):** ### How to Run ### Debugging Value This test will help us determine: 1. Is seekToBeginning() blocking? 2. Does poll() send ListOffsetsRequest? 3. Can consumer parse Metadata? 4. Are response messages malformed? 5. Is this a gateway bug or Kafka client issue?
14 lines
555 B
Properties
14 lines
555 B
Properties
# Set everything to debug
|
|
log4j.rootLogger=INFO, CONSOLE
|
|
|
|
# Enable DEBUG for Kafka client internals
|
|
log4j.logger.org.apache.kafka.clients.consumer=DEBUG
|
|
log4j.logger.org.apache.kafka.clients.producer=DEBUG
|
|
log4j.logger.org.apache.kafka.clients.Metadata=DEBUG
|
|
log4j.logger.org.apache.kafka.common.network=WARN
|
|
log4j.logger.org.apache.kafka.common.utils=WARN
|
|
|
|
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
|
|
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
|
|
log4j.appender.CONSOLE.layout.ConversionPattern=[%d{HH:mm:ss}] [%-5p] [%c] %m%n
|