THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
From the reporter of KAFKA-6690:
We
...
use
...
Kafka
...
to
...
process
...
the
...
asynchronous
...
events
...
of
...
our
...
Document
...
Management
...
System
...
such
...
as
...
preview
...
generation,
...
indexing
...
for
...
search
...
etc.
...
The
...
traffic
...
gets
...
generated
...
via
...
Web
...
and
...
Desktop
...
Sync
...
application.
...
In
...
such
...
cases,
...
we
...
had
...
to
...
prioritize
...
the
...
traffic
...
from
...
web
...
and
...
consume
...
them
...
first.
...
But
...
this
...
might
...
lead
...
to
...
the
...
starvation
...
of
...
events
...
from
...
sync
...
if
...
the
...
consumer
...
speed
...
is
...
slow
...
and
...
the
...
event
...
rate
...
is
...
high
...
from
...
web.
...
A
...
solution
...
to
...
handle
...
the
...
starvation
...
with
...
a
...
timeout
...
after
...
which
...
the
...
events
...
are
...
consumed
...
normally
...
for
...
a
...
specified
...
period
...
of
...
time
...
would
...
be
...
great
...
and
...
help
...
us
...
use
...
our
...
resources
...
effectively.
Public Interfaces
The addition of new subscribe API that allows caller to prioritize topics. New class TopicPriority constructor
...