runWith(Sink.ignore)
}
--
Kind regards
*Josh Meraj Maidana*
lly by a consumer or a producer,
> > how
> > >> is
> > >> > the number of partitions specified?
> > >> > 3. If it is not or can't be specified, how does KAFKA decide the
> > number
> > >> of
> > >> > partitions to create?
> > >> > 4. If a producer doesn't specify a partition, how does KAFKA decide
> to
> > >> > which partition the message is allocated.
> > >> > 5. On consumption, do I need to explicitly create multiple consumers
> > to
> > >> > attain parallelism?
> > >> > 6. If yes, would KAFKA allocate different partition to different
> > >> consumers
> > >> > who are part of the same consumer group?
> > >> > 7. If one of those consumers exit, would KAFKA reallocate the
> > >> partitions to
> > >> > remaining consumers?
> > >> > 8. How are the offsets propagated from an exited to consumer to the
> > new
> > >> > consumer to which the partition is reallocated?
> > >> > 9. Is there a listener based API for consumption instead os a
> blocking
> > >> > poll?
> > >> >
> > >> > Kind regards
> > >> > Josh
> > >> >
> > >>
> > >
> > >
> >
>
--
Kind regards
*Josh Meraj Maidana*
