Classification: Public

Hi All,

We have a kafka cluster where we are using consumer.subscribe() for a group id. 
We also are trying to write a simple monitoring tool running as a separate 
instance on a different host than the consumers for checking the consumer 
offsets and for that we have used below code which as I  understand is mixing 
assign and subscribe here.

I wanted to understand what problems/issues will happen if I have the below 
code where I have assigned a partition in to a new instance (which would have 
been assigned to a consumer, what happens to that consumers ownership of the 
partition?) belonging to the same group but not calling poll() but just getting 
the current position.

Code snippet:

try (KafkaConsumer<String, String> consumer = createConsumer(consumerGroup)) {
   TopicPartition topicPartition = new TopicPartition(topic, 
Integer.parseInt(partition));
   consumer.assign(Collections.singletonList(topicPartition));
   return consumer.position(topicPartition);
} catch (Exception ex) {
   log.error("Error occurres when try to get consumer group position");
   return -1;
}


Thanks,
Shailesh
Lloyds Banking Group plc. Registered Office: The Mound, Edinburgh EH1 1YZ. 
Registered in Scotland no. SC95000. Telephone: 0131 225 4555.

Lloyds Bank plc. Registered Office: 25 Gresham Street, London EC2V 7HN. 
Registered in England and Wales no. 2065. Telephone 0207626 1500.

Bank of Scotland plc. Registered Office: The Mound, Edinburgh EH1 1YZ. 
Registered in Scotland no. SC327000. Telephone: 03457 801 801.

Lloyds Bank Corporate Markets plc. Registered office: 25 Gresham Street, London 
EC2V 7HN. Registered in England and Wales no. 10399850.

Scottish Widows Schroder Personal Wealth Limited. Registered Office: 25 Gresham 
Street, London EC2V 7HN. Registered in England and Wales no. 11722983.

Lloyds Bank plc, Bank of Scotland plc and Lloyds Bank Corporate Markets plc are 
authorised by the Prudential Regulation Authority and regulated by the 
Financial Conduct Authority and Prudential Regulation Authority.

Scottish Widows Schroder Personal Wealth Limited is authorised and regulated by 
the Financial Conduct Authority.

Lloyds Bank Corporate Markets Wertpapierhandelsbank GmbH is a wholly-owned 
subsidiary of Lloyds Bank Corporate Markets plc. Lloyds Bank Corporate Markets 
Wertpapierhandelsbank GmbH has its registered office at Thurn-und-Taxis Platz 
6, 60313 Frankfurt, Germany. The company is registered with the Amtsgericht 
Frankfurt am Main, HRB 111650. Lloyds Bank Corporate Markets 
Wertpapierhandelsbank GmbH is supervised by the Bundesanstalt für 
Finanzdienstleistungsaufsicht.

Halifax is a division of Bank of Scotland plc.

HBOS plc. Registered Office: The Mound, Edinburgh EH1 1YZ. Registered in 
Scotland no. SC218813.



This e-mail (including any attachments) is private and confidential and may 
contain privileged material. If you have received this e-mail in error, please 
notify the sender and delete it (including any attachments) immediately. You 
must not copy, distribute, disclose or use any of the information in it or any 
attachments. Telephone calls may be monitored or recorded.
  • mixing assig... Ranjan, Shailesh (Contractor - CB - Front Office L, Group IT)

Reply via email to