Re: [Streams] TimeWindows ignores gracePeriodMs in windowsFor(timestamp)

2019-04-30 Thread John Roesler
Hi Ashok, I think some people may be able to give you advice, but please start a new thread instead of replying to an existing message. This just helps keep all the messages organized. Thanks! -John On Thu, Apr 25, 2019 at 6:12 AM ASHOK MACHERLA wrote: > Hii, > > what I asking > > I want to kn

Re: [Streams] TimeWindows ignores gracePeriodMs in windowsFor(timestamp)

2019-04-30 Thread John Roesler
Hey, Jose, This is an interesting thought that I hadn't considered before. I think (tentatively) that windowsFor should *not* take the grace period into account. What I'm thinking is that the method is supposed to return "all windows that contain the provided timestamp" . When we keep window1 op

My IDE which is sitting outside of the kube cluster creates a producer that attempts to connect to kafka using the cluster dns name of the headless service

2019-04-30 Thread Janitha Jayaweera
Hi! The Kafka chart being used is here https://github.com/bitnami/charts/tree/master/bitnami/kafka | chart | application | | kafka-1.10.1 | 2.2.0 | $ kubectl get svc -n kafka NAME TYPECLUSTER-IP EXTERNAL-IP PORT(S) AGE kafka-

Re: KSQL Question

2019-04-30 Thread Vahid Hashemian
Hi Shalom, This is the Github repo for KSQL: https://github.com/confluentinc/ksql However, in order to get that running you have to download few libraries KSQL depends on. And you'll need Kafka. For the sake of experimentation you are probably better off using the all-in-one Confluent Platform. It

KSQL Question

2019-04-30 Thread shalom sagges
Hi All, I'm new to Kafka and wanted to experience with KSQL. However, I can't find a place to download it without downloading the entire Confluent Platform package. Please correct me if I'm wrong, but I understand that KSQL is free, so there must be a place where I can download only KSQL. Can some

RE: Required guidelines for kafka upgrade

2019-04-30 Thread ASHOK MACHERLA
Dear Team Members Currently we are using Kafka 0.10.1, Zookeeper 3.4.5 versions, we are planning to upgrade to Kafka 2.2.0 version. We have 3 node Kafka cluster(3 Zookeeper nodes , 3 Kafka nodes) As suggested by you, Can I follow these steps 1. First, I have to download, new Kafka 2.1

Mirror Maker tool is not running

2019-04-30 Thread ASHOK MACHERLA
Dear Team Please help us , our mirror maker tool is not running properly Please look into this belowmirror maker log file exceptions ** [2019-03-11 18:34:31,906] ERROR Error when sending message to topic audit-logs with key: nul