[
https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286904#comment-16286904
]
Neerja Khattar commented on KAFKA-6336:
---------------------------------------
m_partitionlist.contains(partition.partition())) {
obj = new JSONObject();
obj.put("partition", partition.partition());
TopicPartition topic_partition =
new TopicPartition(topic, partition.partition());
OffsetAndMetadata offset =
m_consumer.committed(topic_partition);
if (offset != null) {
obj.put("commited_offset", offset.offset());
} else {
obj.put("commited_offset", -1);
}
arr.put(obj);
}
}
info.put("assigned_partitions_info", arr);
}
ret.put(uuid, info);
return ret;
}
As far as I know we are committing offset. I noticed consumerGroup command only
shows active consumer may be thats why? Or does assign works differently it
doesnt capture it well.
Any other alternative?
Do you still want me to run with DEBUG?
> when using assign() with kafka consumer the KafkaConsumerGroup command doesnt
> show those consumers
> --------------------------------------------------------------------------------------------------
>
> Key: KAFKA-6336
> URL: https://issues.apache.org/jira/browse/KAFKA-6336
> Project: Kafka
> Issue Type: Bug
> Reporter: Neerja Khattar
>
> The issue is when using assign rather than subscribe for kafka consumers
> commit not able to get the lag using ConsumerGroup command. It doesnt even
> list those groups.
> JMX tool also doesnt show lag properly.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
