Re: How to perform keytool operation using Java code

Hi Raghav, You could take a look at https://github.com/apache/kafka/blob/trunk/clients/src/test/java/org/apache/kafka/test/TestSslUtils.java Regards, Rajini On Wed, Jul 12, 2017 at 10:23 PM, Raghav wrote: > Guys, Would anyone know about it ? > > On Tue, Jul 11, 2017 at 6:20 AM, Raghav wrote:

Re: How to perform keytool operation using Java code

Thanks. On Thu, Jul 13, 2017 at 2:41 AM, Rajini Sivaram wrote: > Hi Raghav, > > You could take a look at https://github.com/apache/ > kafka/blob/trunk/clients/src/test/java/org/apache/kafka/ > test/TestSslUtils.java > > Regards, > > Rajini > > On Wed, Jul 12, 2017 at 10:23 PM, Raghav wrote: > >

Re: Is this a decent use case for Kafka Streams?

From just looking at your description of the problem, I'd say yes, this looks like a typical scenario for Kafka Streams. Kafka Streams supports exactly once semantics too in 0.11. Cheers Eno > On 12 Jul 2017, at 17:06, Stephen Powis wrote: > > Hey! I was hoping I could get some input from peo

Re: Is this a decent use case for Kafka Streams?

Unf this notion isn't applicable: "...At the end of a time window..." If you comb through the archives of this group you'll see many questions about notifications for the 'end of an aggregation window' and a similar number of replies from the Kafka group stating that such a notion doesn't really e

How to merge multiple kafka streams in order to do a session windowing over all events of the resulting stream

We have multiple input topics with different business events (page views, clicks, scroll events etc). As far as I understood Kafka streams they all get an event timestamp, which can be used for KStream joins with other streams or tables to align the times. What we want to do is: Merge all differen

[kafka question] leader of partitions is none

Hi,I need some help about kafka. Kafka is a very nice software , and we have been using it for a long time. But now ,I encountered a problem. When I create a topic on kafka server cluster, the leader of every partition is none . like this: [cid:image001.png@01D2FBF9.136859C0] The command is :

decreasing loglevel for basic creation-roll-delete events

Hi While testing Kafka in our environment, we have noticed it creates A LOT of "debug" logs (not to be confused with topic logs!). eg: Jul 13 16:44:26 host kafka[28511]: [2017-07-13 16:44:26,879] INFO Deleting index /data/kafka-1/group-index-type.2017-07-13-12-0/00439596.timei

Logs truncated at o'clock

Hi With swiss precission, our kafka test environment seems to truncate topics at o'clock hours. This might be confirmed with the following trace, which states "Truncating log ... to offset 0" We are still using Kafka 0.10.2.1, but I was wondering if this is resolved in recent versions, it'

State management & restore functionality

Hi - I have a question which is mostly to clarify some conceptions regarding state management and restore functionality using Kafka Streams .. When I have multiple instances of the same application running (same application id for each of the instances), are the following assumptions correct ?