Re: Kafka Streams & Processor API

Hey Navneeth, thank you for your interest in trying out Kafka Streams! Normally we will redirect new folks to the stream FAQ first in case you haven't checked it out. For details to your question: 1. Joining 2 topics using processor API (we cal

upgrading kafka & zookeeper

Hi kafka Users, I have a novice question in kafka upgrade.. This is the 1st time i'm upgrading my kafka in Linux. My current version is "kafka_2.11-1.0.0.tgz".. when i initially setup i had a folder named kafka_2.11-1.0.0. Now i downloaded a new version "kafka_2.12-2.3.0.tgz". If i extract it is

Re: (Re-)joining group for a longer time

Thanks Boyang & Ivan for responding and providing your inputs. There were many consumers in the consumer group, I think that is one of the reasons for this long group rebalances. I have resized this number of consumers to a reasonable size, I am testing the behavior again. Thanks & Regards Kamesh

NETWORK_EXCEPTION for cloud deployment

Hello Users, I am trying to deploy a 3 node cluster on GCP platform using helm chart. We forked it from github. our relevant broker configs are: listeners=INTERNAL://0.0.0.0:19092,EXTERNAL://0.0.0.0:9092 listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT advertised.listeners= I

Re: (Re-)joining group for a longer time

Hi, Kamesh, does one of worker's logs look like in https://issues.apache.org/jira/browse/KAFKA-7941?focusedCommentId=16899851&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-16899851 ? I.e. INFO [Worker clientId=connect-1, groupId=connect] Was selected to perform a