Re: [VOTE] 0.11.0.1 RC0

Hi Guozhang, from what i'm looking at the {{fullDotVersion}} is replaced with 0.11.0.1 On Sat, 9 Sep 2017 at 00:55 Guozhang Wang wrote: > Verified the quickstart and streams tutorial, +1. > > One minor comment on the web docs of streams tutorial, that when I edited > the mvn archetype command I

Re: [VOTE] 0.11.0.1 RC0

However, it looks like this section: > tree streams.examples streams-quickstart ├── pom.xml └── src └── main ├── java │ └── myapps │ ├── LineSplit.java │ ├── Pipe.java

Re: Classloading Error with Kotlin and Streams

> On Sep 8, 2017, at 17:57, Bill Bejeck wrote: > > I'm not super familiar with Kotiln, but I'm taking a look. Thanks Bill! I appreciate the help, and I look forward to your findings. Avi Software Architect @ Park Assist » http://tech.parkassist.com/

kafka broker not available at starting

Hi, I set on a ubuntu node of a cluster a kafka 0.11.0.0 instance. Until some weeks ago everything worked fine, today I'm trying to starting it and I obtain this error after the boot: [2017-09-11 16:21:13,894] INFO [Kafka Server 0], started (kafka.server.KafkaServer) [2017-09-11 16:21:18,998] W

Re: kafka broker not available at starting

Could you try with the following: listeners=PLAINTEXT:hidden_ip:55091 advertised.listeners=PLAINTEXT://localhost:55091 listener.security.protocol.map=PLAINTEXT:PLAINTEXT,SSL:SSL "Until some weeks ago everything worked fine" - means you have accidentaly changed something. On 11 September 2017 at

Re: kafka broker not available at starting

I’m sure I haven’t touched anything. Is it probably a fault with the proxy? The cluster is not managed by me. this is the result: java.lang.IllegalArgumentException: Error creating broker listeners from ‘PLAINTEXT:hidden_ip:55091': Unable to parse PLAINTEXT:hidden_ip:55091 to a broker endpoint

Re: kafka broker not available at starting

There was a typo in my previous email. Try with this (and replace your ip address and hostname appropriately): listeners=PLAINTEXT://hidden_ip:55091 advertised.listeners=PLAINTEXT://localhost:55091 listener.security.protocol.map=PLAINTEXT:PLAINTEXT,SSL:SSL On 11 September 2017 at 17:15, Andrea G

Re: kafka broker not available at starting

Crashes again. [2017-09-11 18:26:44,386] FATAL [Kafka Server 0], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.common.KafkaException: Socket server failed to bind to hidden_ip:55091: Cannot assign requested address. Maybe I can better clarify: Thi

Re: Kafka Connect sink connector in distributed mode: how are records distributed to workers?

Connect uses Kafka's group coordination mechanism and normal consumers to balance/assign to the various sink tasks the topic partitions for the subscribed topics. A task will continue to receive the records from its assigned topic partitions until a rebalance occurs, which can happen when any conne

Re: Classloading Error with Kotlin and Streams

Hi Avi, I've done a little digging. Unfortunately, I don't have any answers at this point. Here's what I did: 1. I replicated your CLI command in a standalone class (TestDeserializerLoader.kt in IntelliJ) and created an uber-jar file. I can reproduce your error with "kotlin -cp Te

Re: Classloading Error with Kotlin and Streams

> On Sep 11, 2017, at 14:31, Bill Bejeck wrote: > > I've done a little digging. Unfortunately, I don't have any answers at this > point. > > ... > > For us to go further, I think you'll need to put a JIRA ticket in, sorry this > isn't very helpful at this point. Thanks for putting the time

Re: [VOTE] 0.11.0.1 RC0

Okay, maybe it's my local apache server's cache. Thanks for confirming. For the folder tree bash outputs, could you push a fix to it then? For web doc fixes like this we would not need another RC. Guozhang On Mon, Sep 11, 2017 at 1:12 AM, Damian Guy wrote: > However, it looks like this sectio

Re: [VOTE] 0.11.0.1 RC0

Hi, Damian, Thanks for running the release. Verified the quickstart from the src distribution. +1 Jun On Tue, Sep 5, 2017 at 1:34 PM, Damian Guy wrote: > Hello Kafka users, developers and client-developers, > > This is the first candidate for release of Apache Kafka 0.11.0.1. > > This is a bug

Identifying Number of Kafka Consumers

All, I am very new to kafka . We have a case where we need to ingest multiple avro record types . These avro record types vary vastly in volume and size and I am thinking of sending each of these message types to a different topic and creating partitions based on volume and through put needed.

Re: Upgrading Kafka to 11.0

[re-posting] Hi All, 1. Upgrade the brokers one at a time: shut down the broker, update the code, and restart it. What does it mean to "update the code". Does it mean replace the old lib folder with latest ? or replace lib and bin with latest? Could someone clarify ? On Fri, Sep 8, 2017

Re: Upgrading Kafka to 11.0

Hi, Yes, you can replace bin and libs folders. or you can untar to a new folder and update config/server.properties config file. On Tue, Sep 12, 2017 at 12:21 PM, kiran kumar wrote: > [re-posting] > > Hi All, > >1. Upgrade the brokers one at a time: shut down the broker, update the >cod