Minor Description
Currently, class org.apache.kafka.streams.processor.internals.assignment.ClientState<T> uses a generic type. However, within actual Streams code base the type will always be TaskId (from package org.apache.kafka.streams.processor).
Thus, this ticket is about removing the generic type and replace it with TaskId, to simplify the code base.
There are some tests, that use ClientState<Integer> (what allows for a slightly simplified test setup). Those tests need to be updated to work properly using TaskId instead of Integer.
Attachments
Issue Links
- links to
