Is there any change in consumer offsets if a new partition(s) is added to a Kafka topic?

0 votes
Jul 9, 2018 in Apache Kafka by coldcode
• 2,050 points

edited Jul 9, 2018 by coldcode 470 views

1 answer to this question.

0 votes

Yes, it stays the same.

An offset is maintained for each partition separately, so your new partition's offset will start from 0 and won't affect other offsets.

For each topic, the Kafka cluster maintains a partitioned log that looks like this:

image

Hope this will help!​​

answered Jul 9, 2018 by nitinrawat895
• 10,840 points

Related Questions In Apache Kafka

0 votes
1 answer

I tried to do configration for retation log in kafkA ,BUT kafka broker shuts Down.Is there any solution for that??

Hi@Parth, There are mainly two types of retention ...READ MORE

answered 4 days ago in Apache Kafka by MD
• 2,870 points
35 views
+1 vote
10 answers

Writing the Kafka consumer output to a file

System.out.println(String.valueOf(output.offset()) + ": " + new String(bytes, ...READ MORE

answered Dec 7, 2018 in Apache Kafka by Harsh
10,152 views
0 votes
1 answer

How to commit message offsets in Kafka for reliable data pipeline?

You can use auto.commit.enable to allow Kafka ...READ MORE

answered Jul 9, 2018 in Apache Kafka by Shubham
• 13,370 points
521 views
0 votes
1 answer

Explain to me the functionality of Kafka in a Big-Data Cluster

Let me explain to you about Apache ...READ MORE

answered Apr 30, 2019 in Apache Kafka by ravikiran
• 4,600 points
169 views
0 votes
0 answers

How to check pending messages in KAFKA topic?

Let say we have first_topic which has kafka_server_brokertopicmetrics_messagesin_total{instance="localhost:1120",job="kafka",topic="first_topic"}  ...READ MORE

May 2, 2019 in Apache Kafka by anonymous
1,234 views
+1 vote
1 answer

Kafka consumer not able to start reading messages from the last uncommitted offsets

Hi@prasant, I am not sure it will work ...READ MORE

answered 4 days ago in Apache Kafka by MD
• 2,870 points
72 views
0 votes
1 answer

How can I create a topic in apache kafka?

Hi@akhtar, To create kafka topic you can use ...READ MORE

answered Feb 6 in Apache Kafka by MD
• 2,870 points
29 views
0 votes
1 answer

How to delete a topic in Kafka 0.8.1.1?

Deleting topic isn't always working in 0.8.1.1 Deletion ...READ MORE

answered Sep 4, 2018 in Apache Kafka by nitinrawat895
• 10,840 points
327 views
0 votes
1 answer

What is the optimum number of producers to create in Kafka?

In general, a single producer for all ...READ MORE

answered Jul 10, 2018 in Apache Kafka by nitinrawat895
• 10,840 points
1,948 views