Re: quick start does not work...

2019-05-23 Thread Tom Kwong
I was unable to create the test topic. No error message though... $ bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test $ bin/kafka-topics.sh --list --bootstrap-server localhost:9092 $ I was curious what happens if I continue with

Restart of kafka-streams with more than one partition on topic is reprocessing the data from beginning of the topic

2019-05-23 Thread kalyani yarlagadda
Hi, I need assistance in the below scenario. Please help me with this. I am using the hopping time window in Kafka streams. I am facing an issue on the restart of my Kafka application, the application is processing the data from the beginning offset. However, it is happening only when the topic

Re: apache kafka community container image

2019-05-23 Thread M. Manna
There’s no official image signed by ASF Kafka community like we have for some other projects. Containerising Kafka has been more of a casual project than open source initiative (e.g. tomcat containers). On Thu, 23 May 2019 at 16:48, Zain Malik wrote: > I was hoping to just get a hold on some

Re: [VOTE] 2.2.1 RC1

2019-05-23 Thread Harsha
+1 (binding) 1. Ran unit tests 2. System tests 3. 3 node cluster with few manual tests. Thanks, Harsha On Wed, May 22, 2019, at 8:09 PM, Vahid Hashemian wrote: > Bumping this thread to get some more votes, especially from committers, so > we can hopefully make a decision on this RC by the end

Re: apache kafka community container image

2019-05-23 Thread Zain Malik
I was hoping to just get a hold on some official image of kafka where the community can rely on rather than images living in 3rd party repos. On 2019/05/23 15:35:33, Pavel Sapozhnikov wrote: > If you're running on Kubernetes or Openshift check out strimzi project. > > On Thu, May 23, 2019,

Re: apache kafka community container image

2019-05-23 Thread Pavel Sapozhnikov
If you're running on Kubernetes or Openshift check out strimzi project. On Thu, May 23, 2019, 11:23 AM Zain Malik wrote: > Hi, > > Is there any plans to support a community container image for kafka? > > Right now there are bitnami and confluent based images but nothing > official without

Re: quick start does not work...

2019-05-23 Thread Jonathan Santilli
Hello Tom, did you follow all the steps as instructed in the quickstart? the log is an INFO, while doing it, you will notice logs with the message "Error:KeeperErrorCode = NoNode" in different places, this is normal, is the way it works or how have been designed the interaction from the Broker to

apache kafka community container image

2019-05-23 Thread Zain Malik
Hi, Is there any plans to support a community container image for kafka? Right now there are bitnami and confluent based images but nothing official without bitnami/confluent flavors. Were there any plans to have one official container image? or any reasons to oppose that?

Re: quick start does not work...

2019-05-23 Thread Tom Kwong
Yes, i first noticed that it failed at step 3 (creating topic) but when I reviewed the log, the error already happened by step 2. https://kafka.apache.org/quickstart On May 23, 2019, at 1:52 AM, Robin Moffatt wrote: Hi Tom, Can you link to which quickstart instructions you're following?

Re: quick start does not work...

2019-05-23 Thread Robin Moffatt
Hi Tom, Can you link to which quickstart instructions you're following? thanks. -- Robin Moffatt | Developer Advocate | ro...@confluent.io | @rmoff On Thu, 23 May 2019 at 07:35, Tom Kwong wrote: > Hi, > I’m getting the following error (NoNode for /brokers) on a fresh new > install of

Re: Kafka delaying message

2019-05-23 Thread Adrien Ruffie
Thank a lot ! That's what I thought, out of the box ... but it's clearly logic I will take your solution in the consumer, but I will refactor my Java code part, because, it's a spring message listener with annotation. So, I think, I couldn't do it simply with spring. thank again, best regards

quick start does not work...

2019-05-23 Thread Tom Kwong
Hi, I’m getting the following error (NoNode for /brokers) on a fresh new install of kafka. There are more similar errors after that. Is there any specific requirements to run Kafka? [2019-05-23 06:13:58,199] INFO Accepted socket connection from /127.0.0.1:47078