[
https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15849098#comment-15849098
]
Steven Schlansker commented on KAFKA-4722:
------------------------------------------
I have multiple different functional sections of my application. Each has
their own KStreamBuilder / KafkaStreams / KStream / KTable instances. An error
thrown from one part of the application is very hard to differentiate from the
others. For example right now I have:
{code}
2017-02-01T14:41:22.120Z ERROR [StreamThread-2]
o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-2] Streams
application error during processing:
java.lang.IllegalArgumentException: Assigned partition public.chat.message-0
for non-subscribed topic.
at
org.apache.kafka.clients.consumer.internals.SubscriptionState.assignFromSubscribed(SubscriptionState.java:187)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:215)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:313)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:277)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:259)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1013)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:407)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:242)
{code}
and it is not clear which instance of {{KafkaStreams}} produced this.
> StreamThread should allow customization of thread prefix
> --------------------------------------------------------
>
> Key: KAFKA-4722
> URL: https://issues.apache.org/jira/browse/KAFKA-4722
> Project: Kafka
> Issue Type: New Feature
> Components: streams
> Affects Versions: 0.10.1.1
> Reporter: Steven Schlansker
>
> StreamThread currently sets its name thusly:
> {code}
> super("StreamThread-" + STREAM_THREAD_ID_SEQUENCE.getAndIncrement());
> {code}
> When you have multiple KStream / KTables in an application, it would be nice
> to customize the "StreamThread" prefix. The id is a good start but a
> human-recognizable name would make logs much easier to read.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
