[KAFKA-14771] Include current thread ids in ConcurrentModificationException message

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 2.8.2, 3.2.3
• Fix Version/s: 3.5.0
• Component/s: clients
• Labels: consumer

Language

java

• Assignee: Pierangelo Di Pilato
• Reporter: Pierangelo Di Pilato
• Created: 01/Mar/23 12:15
• Updated: 03/Apr/23 10:35
• Resolved: 03/Apr/23 10:35

Description

In the KafkaConsumer.acquire method a ConcurrentModificationException exception is thrown when

 

threadId != currentThread.get() && !currentThread.compareAndSet(NO_CURRENT_THREAD, threadId)

however, the exception message doesn't include:

 

• Thread.currentThread().getId()

• currentThread.get() 

 

I think including the aforementioned variables is very useful for debugging the issue.

Issue Links

• links to: GitHub Pull Request #13325