Add to Kafka contributor list

Hi, Could you add me to Kafka contributor list please? I want to start contributing to Kafka Jira user : vvakati Thanks, Vinay

Re: Add to kafka contributor list

Thu, Sep 1, 2022 at 6:23 AM vinay kumar > wrote: > > > Hi, > > > > Could you add me to Kafka contributor list please? > > > > > > I want to start contributing to Kafka > > > > Jira user : Vakati > > > > Thanks, > > Vinay > > >

Add to kafka contributor list

Hi, Could you add me to Kafka contributor list please? I want to start contributing to Kafka Jira user : Vakati Thanks, Vinay

RE: Re: Migrating from 2.5.0 to 2.8.0

; > Thank you. > Luke > > On Mon, Apr 11, 2022 at 12:43 PM vinay kumar > mailto:vi...@gmail.com>> > wrote: > > > Hi,, > > > > Is there any wiki to migrate from 2.5.0 to 2.8.0 In production > > > > Thanks, > > Vinay > > >

Re: Migrating from 2.5.0 to 2.8.0

We need to follow all 5 steps as part of rolling upgrade or directly can we upgrade? On Mon, 11 Apr, 2022, 11:38 am Luke Chen, wrote: > Hi Vinay, > > This doc should help: > https://kafka.apache.org/28/documentation/#upgrade > > Thank you. > Luke > > On Mon, Apr 11, 2

Migrating from 2.5.0 to 2.8.0

Hi,, Is there any wiki to migrate from 2.5.0 to 2.8.0 In production Thanks, Vinay

Upgrading kafka from 2.5 to 2.8

Hi, Is there any wiki for upgarading kafka from 2.5 to 2.8 in production

Kafka rest proxy performance impact reg.

Hi, What is the impact on performance while using kafka rest proxy. Does it affect other kafka producers (or) clients in any which way? What is the downside/disadvantages of using kafka rest proxy. Please clarify. Thanks, Vinay

Re: [ANNOUNCE] Apache Kafka 2.5.0

Hi, Can you please clarify below queries. 1. Can this be considered a stable version, and is it advisable to upgrade to 2.5.0 from 2.1 version? since it's just released. 2. Are there any breaking changes? Or changes to existing configuration needed? And any basic things to keep in mind before u

Re: [ANNOUNCE] Apache Kafka 2.2.2

Hi, May I know how would this version be different from the later versions 2.3.0, 2.3.1. I'm looking to upgrade my current Kafka 2.1.0, so can you please let me know what differences it would make for upgrading to 2.2.2 or 2.3.1? Thanks, Vinay On Monday, December 2, 2019, Vahid Hashemian wrote:

Re: log.retention.bytes not working

Yes, log.cleanup.policy is set to delete. On Wed, Sep 18, 2019, 15:12 M. Manna wrote: > And is your log.cleanup.policy set to delete ? > > On Wed, 18 Sep 2019 at 06:19, Vinay Kumar wrote: > > > I don't see log.retention.bytes only is not working. Even after th

Partitions balancing across kafka cluster reg.

Hi, Currently I have 3 node kafka cluster, and I want to add 2 more nodes to make it 5 node cluster. -After adding the nodes to cluster, I need all the topic partitions to be evenly distributed across all the 5 nodes. -In the past, when I ran kafka-reassign-partitions.sh & kafka-preferred-replica-

Re: log.retention.bytes not working

Are you saying that log.retention.bytes (broker leave - all topics) and/or > retention.bytes (topic level - individual topic) isn’t working for you ? > > Thanks, > > On Tue, 17 Sep 2019 at 20:02, Vinay Kumar wrote: > > > Hi, > > I have the same problem mentioned here

log.retention.bytes not working

Hi, I have the same problem mentioned here by Neha. Attached the comment. https://grokbase.com/t/kafka/users/138hje002v/questtion-about-log-retention-bytes Can someone please provide how effectively to impose the retention for all topics.

Restrict kafka consumers from PLAINTEXT port.

Hi, I have listeners configured with 2 ports as below: (9092 -> Plaintext, 9092 -> SASL_PLAIN) listeners=PLAINTEXT://:9092, SASL_PLAIN://:9093 For a topic, I want restrict Consumers to consume data from 9093 port only, and consuming data from 9092 port should be denied. I've gone through ACL co

Kafka ERROR after upgrade to Kafka 1.0.0 version : java.lang.OutOfMemoryError: Java heap space

ack$1(KafkaApis. scala:569) at kafka.server.KafkaApis.$anonfun$handleFetchRequest$15(KafkaA pis.scala:588) at kafka.server.KafkaApis$$Lambda$662/1703788464.apply$mcVI$sp(Unknown Source) Thanks, Vinay Kumar

Kafka Cluster- consumer issue

Hi, I setup Kafka Cluster with 3 kafka brokers in 3 separate VMs. Upon testing the Fault tolerance among the 3 brokers, I see an issue with the Consumer in displaying messages. >> The below command display the messages, along with a content stating “*Using the ConsoleConsumer with old consumer