Re: Adding a new sub-topolgy requires reset?

Thanks Boyang I created this ticket: https://issues.apache.org/jira/browse/KAFKA-9518 I attached a sample maven application that reproduces the issue. Thanks Murilo On Thu, Feb 6, 2020 at 11:38 AM Boyang Chen wrote: > Hey Murilo, > > feel free to file a JIRA and paste your full topology. It seem

Re: Mistake in official documentation ?

Hello Fares, I remember there's a JIRA ticket for this part, is that what you saw as well? https://issues.apache.org/jira/browse/KAFKA-9304 Guozhang On Thu, Feb 6, 2020 at 8:25 AM Fares Oueslati wrote: > Thanks for your quick feedback. > > Here is a link to the hosted screenshot https://we.tl

Re: Adding a new sub-topolgy requires reset?

Hey Murilo, feel free to file a JIRA and paste your full topology. It seems like a bug to me. Boyang On Thu, Feb 6, 2020 at 8:17 AM Murilo Tavares wrote: > Answering my own question, obviously this is a stateless application, so > there’s no reset needed. Mu bad. > But the NPE does seem to be

Re: Mistake in official documentation ?

Thanks for your quick feedback. Here is a link to the hosted screenshot https://we.tl/t-TDiRc7jOmV Regards, Fares On Thu, Feb 6, 2020 at 5:16 PM Adam Bellemare wrote: > Screenshot didn't arrive for me - you may need to host it in an image site > (ie: imgur), not sure if the mailing list will

Re: Mistake in official documentation ?

Screenshot didn't arrive for me - you may need to host it in an image site (ie: imgur), not sure if the mailing list will allow it to be attached. It could very well be a mistake. highlight it and send it to d...@kafka.apache.org and if it is, we'll make a ticket and address it. On Thu, Feb 6, 20

Re: Adding a new sub-topolgy requires reset?

Answering my own question, obviously this is a stateless application, so there’s no reset needed. Mu bad. But the NPE does seem to be linked to the fact that the topics were not sorted, therefore different instances could have different topologies in respect to the order. Sorting the topics seems t

Mistake in official documentation ?

Hello, While going through the official docs https://kafka.apache.org/documentation/#messageformat If I'm not wrong, I believe there is a mismatch between description of a segment and the diagram illustrating the concept. I pointed out the issue in the attached screenshot. Didn't really know wh

Re: Initializing a consumer groups committed offset with -1

Hi Gabriele, Thanks a lot for the protocol reference to the default value. It looks like this case isn't handled in the Java AdminClient then. I'll follow up on the dev list. Regards, Sean On Wed, Feb 5, 2020 at 1:35 AM Gabriele Paggi wrote: > Hi Sean, > > Unless this has changed, this is th

kafka-configs to update broker ssl.truststore.location

Hi, Using kafka-configs, i wanted to update the broker truststore location to the new truststore: C:\>kafka-configs.cmd --bootstrap-server kafka-server:9443 --entity-type brokers --entity-name 1 --command-config kafka-brokers.properties --alter --add-config 'listener.name.ssl.ssl.truststore.

Re: Zookeeper uses TCP 8080 from 2.4.0

Apologies but we think we've found the information here (Jetty based admin server) http://kafka.apache.org/documentation/#Additional+Upgrade+Notes Sorry for spamming. Regards, On Thu, 6 Feb 2020 at 12:31, M. Manna wrote: > Hey all, > > We have a test ecosystem which uses two app instances

Zookeeper uses TCP 8080 from 2.4.0

Hey all, We have a test ecosystem which uses two app instances with port 80 and 8080 engaged. Since, Kafka 2.4.0 we are always having issues since Zookeeper is using port 8080. We are not sure why this is the case since port 8080 usage was never there before 2.4.0. Before we dig into the code, co

Re: Config producer for kafka connect

Hi Patrick, You need to use the producer prefix in your connect.distributed properties file. The same file you have your Kafka connect config in which applies it to all producers. Thanks,   Jamje Sent from AOL Mobile Mail Get the new AOL app: mail.mobile.aol.com On Thursday, 6 February 2020, Pat

Config producer for kafka connect

Hello everyone,   probably this is a misunderstanding from my side, but what I'm currently trying: we create a new connector with the REST-API, the connector has a ProducerConfig which I would like to configure based on the confluence white paper for durability but no matter what I'm trying, it

SSL from Kafka to Zookeeper

Hi, I have enabled SSL on zookeeper nodes using reference: https://zookeeper.apache.org/doc/r3.5.6/zookeeperAdmin.html#Quorum+TLS After doing this I started getting logs in zookeeper logs. 10.xx.yy.ss this is my kafka broker Now I want to enable SSL communication between Kafka and the zookeepe