You could do a range query from "abc" to "abd" for example (in this
case, you would need to make sure to check the result form the iterator
and drop "abd" though).
Note, that range queries are executed on the raw bytes. Thus, you need
to understand how the serializes you use work. In doubt, you ma
Hello,
We have our implementation of kerberos login which also has a renewer and we
are using it, for instance, for hdfs. Is there any way to reuse the login
context?
Would kerberos authentication still work if I set security protocol to SSL or
PLAINTEXT and handle the login context on our side
Hi Guys,
I am passing along the following info from EU. If you are interested in the
event, please contact the coordinator. Thanks.
The EU via its EU-FOSSA 2 project have invited a number of communities
including Apache Kafka to consider taking one of their 3 planned Hackathons
this year, to be h
if you want to delete the messages from topic you can use
kafka-delete-records.sh.
I guess thats whay you are looking for.
Thanks,
Kiran
On Mon, 4 Feb 2019 at 11:34 AM, Soheil Pourbafrani
wrote:
> I'll try it
> For your information, I connect another single node Kafka to the same
> Zookeeper cl
Hi,
Just wondering if there is a way to do a sql like "select key,
value.fieild1 from ktable where key like abc%"
The purpose of this to select some value from a ktable without a fully
defined key. Store.all then filter on them would be very inefficient if
store is big.
Thanks,
Nan
Hello Rohit,
maybe is better to fill a JIRA with some context, details and how to
reproduce it? like this is kind of difficult to detect the root cause
unless another person in the list actually can provide some insights with
the provided information.
Cheers!
--
Jonathan
On Tue, Feb 12, 2019 a
Hello Team ,
Recently i am facing this issue .
kafka.common.KafkaException: Error processing data for partition event-35
offset 22428196775
at
kafka.server.AbstractFetcherThread.$anonfun$processFetchRequest$7(AbstractFetcherThread.scala:205)
at scala.Option.foreach(Option.scala:25