Memory leak in RedisKeysSourceTask due to unbounded sourceOffsets list growth

[sauravkumarrr]

Description

There is a memory leak in RedisKeysSourceTask where the sourceOffsets list continuously grows without ever being cleared, leading to memory exhaustion in long-running connector deployments.

Steps to Reproduce

1. Deploy a Redis Keys Source Connector monitoring high-volume key changes
2. Let it run for an extended period
3. Observe memory usage continuously increasing
4. Memory leak occurs due to sourceOffsets.add() calls in commitRecord() with no corresponding cleanup

Expected Behavior

Memory usage should remain stable for long-running connectors.

Actual Behavior

Memory continuously increases due to unbounded list growth, eventually leading to OutOfMemoryError in production deployments.

Root Cause

• commitRecord() method adds offsets to sourceOffsets list via addSourceOffset()
• commit() method is a no-op and never clears the list
• The collected offsets are never used since Redis key monitoring doesn't require acknowledgment

Environment

• Component: RedisKeysSourceTask
• Impact: Production deployments with high-volume key monitoring

Fix

I've submitted a fix in PR [#53] that removes the unused sourceOffsets field and related code, eliminating the memory leak while preserving all functionality.

[sauravkumarrr]

[sauravkumarrr]

Heap dump analysis