Re: Can I query ktable/stream/store with SQL like statment.

2019-02-12 Thread Matthias J. Sax
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

Kafka Kerberos Login

2019-02-12 Thread nunoragoncalves
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

Hackathons with funding of the EU

2019-02-12 Thread Jun Rao
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

Re: Kafka topic data automatically restore after deleting topics

2019-02-12 Thread kiran kumar
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

Can I query ktable/stream/store with SQL like statment.

2019-02-12 Thread Nan Xu
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

Re: Caused by: java.lang.IllegalArgumentException: Out of order offsets found in List

2019-02-12 Thread Jonathan Santilli
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

Caused by: java.lang.IllegalArgumentException: Out of order offsets found in List

2019-02-12 Thread rohit garg
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