Go to next offset position kakfa The 2019 Stack Overflow Developer Survey Results Are InNumber of commits and offset in each partition of a kafka topicReset consumer offset in kafka 0.10How to reset Kafka offsets to match tail position?KafkaConsumer position() vs committed()?Kafka: explicitly assign a non-zero initial offset at topic creationSpark: commit kafka offsets on end of batchwhy kafka offsets are stored at consumer end of application?using kafka-consumer-groups.sh to initialize offsetsKafka: What is Current Offset or Record Count of Topic?kafka offset value differs between __consumer_offset and actual topic offset
Worn-tile Scrabble
How do I free up internal storage if I don't have any apps downloaded?
Why was M87 targeted for the Event Horizon Telescope instead of Sagittarius A*?
Is Cinnamon a desktop environment or a window manager? (Or both?)
A word that means fill it to the required quantity
What is this sharp, curved notch on my knife for?
I am an eight letter word. What am I?
What information about me do stores get via my credit card?
Did the UK government pay "millions and millions of dollars" to try to snag Julian Assange?
Loose spokes after only a few rides
Why couldn't they take pictures of a closer black hole?
What is this business jet?
Unitary representations of finite groups over finite fields
Is an up-to-date browser secure on an out-of-date OS?
Are there any other methods to apply to solving simultaneous equations?
Why doesn't shell automatically fix "useless use of cat"?
Match Roman Numerals
What is the meaning of Triage in Cybersec world?
Can we generate random numbers using irrational numbers like π and e?
What do I do when my TA workload is more than expected?
Getting crown tickets for Statue of Liberty
Time travel alters history but people keep saying nothing's changed
Did Scotland spend $250,000 for the slogan "Welcome to Scotland"?
Why does the nucleus not repel itself?
Go to next offset position kakfa
The 2019 Stack Overflow Developer Survey Results Are InNumber of commits and offset in each partition of a kafka topicReset consumer offset in kafka 0.10How to reset Kafka offsets to match tail position?KafkaConsumer position() vs committed()?Kafka: explicitly assign a non-zero initial offset at topic creationSpark: commit kafka offsets on end of batchwhy kafka offsets are stored at consumer end of application?using kafka-consumer-groups.sh to initialize offsetsKafka: What is Current Offset or Record Count of Topic?kafka offset value differs between __consumer_offset and actual topic offset
.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty height:90px;width:728px;box-sizing:border-box;
How can I go to the next offset position ignoring the current position. Currently Im using ‘seektoend()’ but want to use something that goes to the next offset rather than the end.
apache-kafka
asked Mar 8 at 11:02
user3310115user3310115
267313
|
show 3 more comments
How can I go to the next offset position ignoring the current position. Currently Im using ‘seektoend()’ but want to use something that goes to the next offset rather than the end.
apache-kafka
asked Mar 8 at 11:02
user3310115user3310115
267313
using seek(). --> seek(partition, currentOffset+1)
– aran
Mar 8 at 11:05
Is current offset position retrieved by position()?
– user3310115
Mar 8 at 11:08
The current position will be given by the ConsumerRecord, thanks to its offset() method. kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/…
– aran
Mar 8 at 11:14
But if I don’t have the ConsumerRecord available?
– user3310115
Mar 8 at 11:24
consume one message in order to get the offset then.
– aran
Mar 8 at 11:31
|
show 3 more comments
How can I go to the next offset position ignoring the current position. Currently Im using ‘seektoend()’ but want to use something that goes to the next offset rather than the end.
apache-kafka
asked Mar 8 at 11:02
user3310115user3310115
267313
How can I go to the next offset position ignoring the current position. Currently Im using ‘seektoend()’ but want to use something that goes to the next offset rather than the end.
apache-kafka
apache-kafka
asked Mar 8 at 11:02
user3310115user3310115
267313
asked Mar 8 at 11:02
user3310115user3310115
267313
asked Mar 8 at 11:02
user3310115user3310115
267313
asked Mar 8 at 11:02
user3310115user3310115
267313
asked Mar 8 at 11:02
user3310115user3310115
267313
267313
using seek(). --> seek(partition, currentOffset+1)
– aran
Mar 8 at 11:05
Is current offset position retrieved by position()?
– user3310115
Mar 8 at 11:08
The current position will be given by the ConsumerRecord, thanks to its offset() method. kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/…
– aran
Mar 8 at 11:14
But if I don’t have the ConsumerRecord available?
– user3310115
Mar 8 at 11:24
consume one message in order to get the offset then.
– aran
Mar 8 at 11:31
|
show 3 more comments
using seek(). --> seek(partition, currentOffset+1)
– aran
Mar 8 at 11:05
Is current offset position retrieved by position()?
– user3310115
Mar 8 at 11:08
The current position will be given by the ConsumerRecord, thanks to its offset() method. kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/…
– aran
Mar 8 at 11:14
But if I don’t have the ConsumerRecord available?
– user3310115
Mar 8 at 11:24
consume one message in order to get the offset then.
– aran
Mar 8 at 11:31
using seek(). --> seek(partition, currentOffset+1)
– aran
Mar 8 at 11:05
using seek(). --> seek(partition, currentOffset+1)
– aran
Mar 8 at 11:05
Is current offset position retrieved by position()?
– user3310115
Mar 8 at 11:08
Is current offset position retrieved by position()?
– user3310115
Mar 8 at 11:08
The current position will be given by the ConsumerRecord, thanks to its offset() method. kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/…
– aran
Mar 8 at 11:14
The current position will be given by the ConsumerRecord, thanks to its offset() method. kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/…
– aran
Mar 8 at 11:14
But if I don’t have the ConsumerRecord available?
– user3310115
Mar 8 at 11:24
But if I don’t have the ConsumerRecord available?
– user3310115
Mar 8 at 11:24
consume one message in order to get the offset then.
– aran
Mar 8 at 11:31
consume one message in order to get the offset then.
– aran
Mar 8 at 11:31
|
show 3 more comments
0
active
oldest
votes
Your Answer
StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");
StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);
else
createEditor();
);
function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);
);
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55061855%2fgo-to-next-offset-position-kakfa%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
0
active
oldest
votes
0
active
oldest
votes
active
oldest
votes
active
oldest
votes
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55061855%2fgo-to-next-offset-position-kakfa%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
using seek(). --> seek(partition, currentOffset+1)
– aran
Mar 8 at 11:05
Is current offset position retrieved by position()?
– user3310115
Mar 8 at 11:08
The current position will be given by the ConsumerRecord, thanks to its offset() method. kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/…
– aran
Mar 8 at 11:14
But if I don’t have the ConsumerRecord available?
– user3310115
Mar 8 at 11:24
consume one message in order to get the offset then.
– aran
Mar 8 at 11:31