This is kind of boring I'm sorry I subscribed but I'll keep them because I
might learn from you
On Wed, Nov 30, 2022 at 9:41 AM Tecno Brain <cerebrotecnologico@gmail.com>
wrote:
> By the way, we use Avro for the messages.
>
>
>
> On Wed, Nov 30, 2022 at 9:35 AM Tecno Brain <cerebrotecnologico@gmail.com>
> wrote:
>
> > Hi,
> > I'm using Kafka 2.8
> > I have a topic with an original retention of 1 day with a large amount
> > of messages.
> >
> > We had a problem with some messages being corrupted and we decided to
> > skip about 3.5 hours of messages; but not all of them are corrupted. So,
> we
> > would like to process this period of time again with a modified version
> of
> > our consumer application.
> >
> > In order to avoid the messages being deleted, we extended the retention
> > to 3 days.
> > But we are now again close to have the messages being deleted and we
> > cannot extend the retention anymore (we would go over the limit of the
> disk
> > space).
> >
> > So, I would like to extract the messages between the offsets that cover
> > the 3.5h
> >
> > Is there a quick way to extract these messages and copy them into
> > another topic ?
> > (After that, I want to set the retention back to the original 1 day)
> >
> > Would kcat help?
> >
> >
> >
> >
> >
>
might learn from you
On Wed, Nov 30, 2022 at 9:41 AM Tecno Brain <cerebrotecnologico@gmail.com>
wrote:
> By the way, we use Avro for the messages.
>
>
>
> On Wed, Nov 30, 2022 at 9:35 AM Tecno Brain <cerebrotecnologico@gmail.com>
> wrote:
>
> > Hi,
> > I'm using Kafka 2.8
> > I have a topic with an original retention of 1 day with a large amount
> > of messages.
> >
> > We had a problem with some messages being corrupted and we decided to
> > skip about 3.5 hours of messages; but not all of them are corrupted. So,
> we
> > would like to process this period of time again with a modified version
> of
> > our consumer application.
> >
> > In order to avoid the messages being deleted, we extended the retention
> > to 3 days.
> > But we are now again close to have the messages being deleted and we
> > cannot extend the retention anymore (we would go over the limit of the
> disk
> > space).
> >
> > So, I would like to extract the messages between the offsets that cover
> > the 3.5h
> >
> > Is there a quick way to extract these messages and copy them into
> > another topic ?
> > (After that, I want to set the retention back to the original 1 day)
> >
> > Would kcat help?
> >
> >
> >
> >
> >
>
Comments
Post a Comment