[KAFKA-13248] Class name mismatch for LoggerFactory.getLogger method in TimeOrderedWindowStoreBuilder.java

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: streams
• Assignee: Unassigned
• Reporter: S. B. Hunter
• Created: 29/Aug/21 03:51
• Updated: 08/Sep/21 03:59

Description

I have noticed a mismatch with the class name passed to the LoggerFactory.getLogger method. This would make it hard to track the source of log messages.

public class TimeOrderedWindowStoreBuilder<K, V> extends AbstractStoreBuilder<K, V, WindowStore<K, V>> {
private final Logger log = LoggerFactory.getLogger(WindowStoreBuilder.class);

private final WindowBytesStoreSupplier storeSupplier;

public TimeOrderedWindowStoreBuilder(final WindowBytesStoreSupplier storeSupplier,
final Serde<K> keySerde,

Issue Links

• is fixed by: KAFKA-13216 Streams left/outer joins cause new internal changelog topic to grow unbounded