You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Frederic Tardif (JIRA)" <ji...@apache.org> on 2019/05/09 14:29:00 UTC
[jira] [Commented] (KAFKA-7849) Warning when adding GlobalKTable
[ https://issues.apache.org/jira/browse/KAFKA-7849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836432#comment-16836432 ]
Frederic Tardif commented on KAFKA-7849:
----------------------------------------
got the same issue:
{code:java}
[2019-05-08 09:54:24.212] WARN [uepg-catalog_program-snapshot-connector-7ddde56e-7dff-4a14-aa11-6c8fb22b40ce-StreamThread-2] [Consumer clientId=uepg-catalog_program-snapshot-connector-7ddde56e-7dff-4a14-aa11-6c8fb22b40ce-StreamThread-2-consumer, groupId=uepg-catalog_program-snapshot-connector] The following subscribed topics are not assigned to any members: [livecms.program.snapshot] - (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:?) {code}
My topology is a globalTable:
{code:java}
streamBuilder.globalTable(config.getTopicName(), Materialized.as(config.getStoreName()));{code}
{quote}I confirm my consumer lag in the rocksdb checkpoint file did indeed show the expected partition offset. In addition the warning disappeared the third time I had restarted it (maybe however caused by the store already in sync). I would be surprised in that case that fiddling with the number of stream thread configuration is required. So it looks like a self healed kind of warning. The message however does not sound that reassuring... Next time I'll get this I'll try enabling debug logs to correlate the warning.
{quote}
> Warning when adding GlobalKTable
> --------------------------------
>
> Key: KAFKA-7849
> URL: https://issues.apache.org/jira/browse/KAFKA-7849
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.1.0
> Reporter: Dmitry Minkovsky
> Priority: Minor
> Labels: newbie
>
> Per https://lists.apache.org/thread.html/59c119be8a2723c501e0653fa3ed571e8c09be40d5b5170c151528b5@%3Cusers.kafka.apache.org%3E
>
> When I add a GlobalKTable for topic "message-write-service-user-ids-by-email" to my topology, I get this warning:
>
> [2019-01-19 12:18:14,008] WARN (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:421) [Consumer clientId=message-write-service-55f2ca4d-0efc-4344-90d3-955f9f5a65fd-StreamThread-2-consumer, groupId=message-write-service] The following subscribed topics are not assigned to any members: [message-write-service-user-ids-by-email]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)