ommit offsets (automatically or manually) will extend
the lifecycle of a group.
--Vahid
From: "ÅíÅô(Peyton)"
To: Vahid S Hashemian
Cc: "彭鹏" , users@kafka.apache.org
Date: 08/13/2018 07:11 PM
Subject:Re: Question how to drop a unused group id?
Yes
consumer-groups.sh --bootstrap-server [broker]:9092 --list
--Vahid
From: "ÅíÅô(Peyton)"
To: Vahid S Hashemian
Cc: users@kafka.apache.org, "彭鹏"
Date: 08/13/2018 09:18 AM
Subject:Re: Question how to drop a unused group id?
Thanks! Hmmm.. the last qu
If you did not set the config, the default will be used.
For your version of Kafka (0.10.2.1) the default is 1 day:
https://github.com/apache/kafka/blob/0.10.2.1/core/src/main/scala/kafka/server/KafkaConfig.scala#L152
--Vahid
From: "ÅíÅô(Peyton)"
To: Vahid S Hashemian
Cc:
Hi Peyton,
Yes, if you'd like to change the value a broker restart is required for
the change to take effect.
--Vahid
From: "ÅíÅô(Peyton)"
To: Vahid S Hashemian
Cc: users@kafka.apache.org, "彭鹏"
Date: 08/13/2018 08:49 AM
Subject:Re: Question h
Hi Peyton,
What version of Kafka are you using?
Starting from version 1.1.0 there is a DELETE_GROUP API:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-229%3A+DeleteGroups+API
You can also use the consumer group command with `--delete` to delete a
group.
For prior versions, the safest op
l
rest my case.
Thanks!
--Vahid
From: Colin McCabe
To: users@kafka.apache.org
Date: 08/06/2018 12:44 PM
Subject:Re: ConsumerGroupCommand tool improvement?
On Mon, Aug 6, 2018, at 12:04, Vahid S Hashemian wrote:
> Hi Colin,
>
> Thanks for considering the idea and sh
d?
best,
Colin
On Thu, Aug 2, 2018, at 14:23, Vahid S Hashemian wrote:
> Hi all,
>
> A requirement has been raised by a colleague and I wanted to see if
there
> is any interest in the community in adding the functionality to Apache
> Kafka.
>
> ConsumerGroupComma
Hi all,
A requirement has been raised by a colleague and I wanted to see if there
is any interest in the community in adding the functionality to Apache
Kafka.
ConsumerGroupCommand tool in describe ('--describe' or '--describe
--offsets') mode currently lists all topics the group has consumed
Such a good news on a Monday morning ...
Thank you Rajini for driving the release!
--Vahid
From: Mickael Maison
To: Users
Cc: dev , annou...@apache.org, kafka-clients
Date: 07/30/2018 04:37 AM
Subject:Re: [ANNOUNCE] Apache Kafka 2.0.0 Released
Great news! Thanks for
+1 (non-binding)
Built from source and ran quickstart successfully with both Java 8 and
Java 9 on Ubuntu.
Thanks Rajini!
--Vahid
From: Rajini Sivaram
To: dev , Users ,
kafka-clients
Date: 07/24/2018 08:33 AM
Subject:[VOTE] 2.0.0 RC3
Hello Kafka users, developers and cli
+1 (non-binding)
Built executables from source and ran quickstart (Ubuntu / Java 8)
Thanks!
--Vahid
From: Brett Rann
To: d...@kafka.apache.org
Cc: Users , kafka-clients
Date: 07/10/2018 09:53 PM
Subject:Re: [VOTE] 2.0.0 RC2
+1 (non binding)
rolling upgrade of tiny sh
Hi Nicholas,
The quickstart is meant to run in terminals. The two commands in Step 2
should be run in different terminals unless you're sending the ZooKeeper
process to the backgroud.
If you are facing particular errors please share so we can better assist
you.
Thanks.
--Vahid
From: Nich
+1 (non-binding)
Built from source and ran quickstart successfully on Ubuntu (with Java 8).
Minor: It seems this doc update PR is not included in the RC:
https://github.com/apache/kafka/pull/5280
Guozhang seems to have wanted to cherry-pick it to 2.0.
Thanks Rajini!
--Vahid
From: Rajini S
0.11.0-jdk7/385/
System tests:
https://jenkins.confluent.io/job/system-test-kafka/job/0.11.0/217/
/**
Thanks,
-Matthias
[attachment "signature.asc" deleted by Vahid S Hashemian/Silicon
Valley/IBM]
+1 (non-binding)
Built from source and ran quickstart successfully on Ubuntu (with Java 8
and Java 9).
Thanks Rajini!
--Vahid
+1 (non-binding)
Built from source and ran quickstart successfully on Ubuntu (with Java 8).
Thanks Dong!
--Vahid
From: Dong Lin
To: d...@kafka.apache.org, users@kafka.apache.org,
kafka-clie...@googlegroups.com
Date: 06/22/2018 10:10 AM
Subject:[VOTE] 1.1.1 RC1
Hello Kafka
1/
System tests:
https://jenkins.confluent.io/job/system-test-kafka/job/1.0/217/
/**
Thanks,
-Matthias
[attachment "signature.asc" deleted by Vahid S Hashemian/Silicon
Valley/IBM]
Hi Nitin,
1) A Kafka Consumer uses a poll loop to pull messages from the topics it
is subscribed to. You can see examples of how this can be implemented in
Java here:
https://www.confluent.io/blog/tutorial-getting-started-with-the-new-apache-kafka-0-9-consumer-client/
2,3) Consumers normally c
Hi Rajini,
+1 (non-binding)
Built from source on Linux and Windows (Java 8), and tested quickstart on
both platforms.
Connect quickstart on Windows is not working as per my note on RC3:
https://www.mail-archive.com/dev@kafka.apache.org/msg86138.html
No other issues detected.
Thanks!
--Vahid
Id=console-consumer-35712] Connection to node -1 could not be
established. Broker may not be available.
(org.apache.kafka.clients.NetworkClient)
-Original Message-
From: Vahid S Hashemian [mailto:vahidhashem...@us.ibm.com]
Sent: Tuesday, March 20, 2018 1:55 PM
To: users@kafka.apache.
4
log.retention.check.interval.ms=30
zookeeper.connect=zkp02.mp.com:2181
zookeeper.connection.timeout.ms=6
-Original Message-
From: Vahid S Hashemian [mailto:vahidhashem...@us.ibm.com]
Sent: Tuesday, March 20, 2018 1:31 PM
To: users@kafka.apache.org
Subject: RE: Kafka consumer issue
EXTERNAL
EMA
ogs
num.partitions=1
num.recovery.threads.per.data.dir=1
log.retention.hours=1440
log.segment.bytes=1073741824
log.retention.check.interval.ms=30
zookeeper.connect=zkp02.mp.com:2181
zookeeper.connection.timeout.ms=6
-Original Message-
From: Vahid S Hashemian [mailto:vahidhashem.
Could you paste the server.properties content?
It wasn't attached to the original note.
Thanks.
--Vahid
From: "Anand, Uttam"
To: "users@kafka.apache.org"
Date: 03/20/2018 11:10 AM
Subject:RE: Kakfa consumer issue
Yes checked everything. No errors. Replication factor is 1 o
Hi Damian,
Thanks for running the release.
I tried building from source and running the quick start on Linux &
Windows with both Java 8 & 9.
Here's the result:
+-+-+-+
| | Linux | Windows |
+ +-+-+
|
+1 (non-binding)
Built the source and ran quickstart (including streams) successfully on
Ubuntu (with both Java 8 and Java 9).
I understand the Windows platform is not officially supported, but I ran
the same on Windows 10, and except for Step 7 (Connect) everything else
worked fine.
There ar
Kafka users and developers,
The next *Bay Area Apache Kafka Meetup* is on the *morning of Feb 20* and
is hosted by *Index Developer Conference* at Moscone West in San Francisco
.
Meetup Info: https://www.meetup.com/KafkaBayArea/events/247433783/
Registration Link: https://ibm.co/2n742Jn (required
Hi Ewen,
+1
Building from source and running the quickstart were successful on Ubuntu
and Windows 10.
Thanks for running the release.
--Vahid
From: Ewen Cheslack-Postava
To: d...@kafka.apache.org, users@kafka.apache.org,
kafka-clie...@googlegroups.com
Date: 02/05/2018 07:49 PM
Subj
Great news! Congratulations Rajini!
--Vahid
From: Gwen Shapira
To: "d...@kafka.apache.org" , Users
Date: 01/17/2018 10:49 AM
Subject:[ANNOUNCE] New Kafka PMC Member: Rajini Sivaram
Dear Kafka Developers, Users and Fans,
Rajini Sivaram became a committer in April 2017. Si
Congrats Matthias! Well deserved.
--Vahid
From: Ted Yu
To: d...@kafka.apache.org
Cc: users@kafka.apache.org
Date: 01/12/2018 03:00 PM
Subject:Re: [ANNOUNCE] New committer: Matthias J. Sax
Congratulations, Matthias.
On Fri, Jan 12, 2018 at 2:59 PM, Guozhang Wang wrote:
Hi Michael,
Java based Kafka consumers can consume messages in two ways:
- simple: by manually assigning partitions to a consumer to consume from
- consumer group: a group of consumers consume messages in a coordinated
fashion (by subscribing to topics and having partitions automatically
assigne
Congrats Onur!
--Vahid
From: Ismael Juma
To: d...@kafka.apache.org
Cc: "users@kafka.apache.org"
Date: 11/06/2017 10:13 AM
Subject:Re: [ANNOUNCE] New committer: Onur Karaman
Sent by:isma...@gmail.com
Congratulations Onur!
Ismael
On Mon, Nov 6, 2017 at 5:24 PM,
Hi Guozhang,
+1 for Ubuntu and Mac: successfully built jars and tested quickstarts with
this RC (using Java 8).
-1 for Windows: because of KAFKA-6075 and KAFKA-6100. To me these two
issues (which have simple workarounds) sound like "blockers" - unless
Kafka does not officially support Windows.
: [VOTE] 1.0.0 RC1
If you don't use the default Scala version, you have to set the
SCALA_VERSION environment variable for the bin scripts to work.
Ismael
On 17 Oct 2017 1:30 am, "Vahid S Hashemian"
wrote:
Hi Guozhang,
I'm not sure if this should be covered by "Java 9 sup
Hi Guozhang,
I'm not sure if this should be covered by "Java 9 support" in the RC note,
but when I try to build jars from source using Java 9 (./gradlew
-PscalaVersion=2.12 jar) even though the build reports as succeeded, it
doesn't seem to have been successful:
$ bin/zookeeper-server-start.sh
Hi Guozhang,
Thanks for running the release.
I tested building from source and the quickstarts on Linux, Mac, and
Windows 64 (with Java 8 and Gradle 4.2.1).
Everything worked well on Linux and Mac, but I ran into some issues on my
Windows 64 VM:
I reported one issue in KAFKA-6055, but it's an
Hi Vahid,
Do you know how to use consumer-group tool with ssl only (without sasl) ?
Gabriel.
Le 24 juil. 2017 11:15 PM, "Vahid S Hashemian"
a écrit :
Hi Meghana,
I did some experiments with SASL_PLAINTEXT and documented the results
here:
https://developer.ibm.com/opentech/2017/0
Hi,
If there is no further feedback on this KIP, I'll start the vote tomorrow.
Thanks.
--Vahid
From: Vahid S Hashemian/Silicon Valley/IBM
To: dev , "Kafka User"
Date: 07/03/2017 04:06 PM
Subject:[DISCUSS] KIP-175: Additional '--describe' views for
'd be open to doing it, but it'd require some thought about
how it would impact users and how we'd migrate them to the updated rule
(or
just agree that it is a bug and that including upgrade notes would be
sufficient).
-Ewen
On Mon, Jul 10, 2017 at 1:12 PM, Vahid S Hashemian <
va
Hi Meghana,
I did some experiments with SASL_PLAINTEXT and documented the results
here:
https://developer.ibm.com/opentech/2017/05/31/kafka-acls-in-practice/
I think it covers what you'd like to achieve. If not, please advise.
Thanks.
--Vahid
From: Meghana Narasimhan
To: users@kafka.a
Up to you, but I'd probably leave it
for future work.
-Jason
On Thu, Jul 20, 2017 at 4:21 PM, Vahid S Hashemian <
vahidhashem...@us.ibm.com> wrote:
> Hi Jason,
>
> Regarding your comment about the current limitation on the information
> returned for a consumer group, do
d the --offsets option at all, I
don't have a strong opinion, but it seems to make the command semantics a
little more consistent.
-Jason
On Tue, Jul 18, 2017 at 12:56 PM, Vahid S Hashemian <
vahidhashem...@us.ibm.com> wrote:
> Hi Jason,
>
> I updated the KIP based on your earlie
think?
-Jason
On Wed, Jul 19, 2017 at 4:39 PM, Vahid S Hashemian <
vahidhashem...@us.ibm.com> wrote:
> Hi Jason,
>
> Thanks for sharing your feedback on the updated KIP.
> Your suggestions look good to me.
> Do you see a problem with having the `--members` provide member
>
her we need the --offsets option at all, I
don't have a strong opinion, but it seems to make the command semantics a
little more consistent.
-Jason
On Tue, Jul 18, 2017 at 12:56 PM, Vahid S Hashemian <
vahidhashem...@us.ibm.com> wrote:
> Hi Jason,
>
> I updated the KIP based
that behaves exactly like `--describe`.
Thanks.
--Vahid
From: "Vahid S Hashemian"
To: d...@kafka.apache.org
Cc: Kafka Users
Date: 07/17/2017 03:24 PM
Subject:Re: [DISCUSS] KIP-175: Additional '--describe' views for
ConsumerGroupCommand
Hi Jaso
ecessary a --topics option
is.
The --partitions (or --offsets) option already shows the current
assignment. Maybe --topics could be --subscription and just list the
topics
that the members subscribed to?
Thanks,
Jason
On Mon, Jul 17, 2017 at 11:04 AM, Vahid S Hashemian <
vahidhashem...@us.ibm
ts for the group even if the partition is not currently
>> assigned. However, I don't think we need to try and fit members without
>> any
>> assigned partitions into that view.
>>
>> Thanks,
>> Jason
>>
>> On Fri, Jul 7, 2017 at 10:49 AM, Vahid S H
Hi SK,
Could you please take a look at this document (
https://developer.ibm.com/opentech/2017/05/31/kafka-acls-in-practice/) and
confirm you performed the steps in Broker Setup on all brokers?
Thanks.
--Vahid
From: Sruthi Kumar Annamneedu
To: users@kafka.apache.org
Date: 07/11/2017
I'm bumping this up again to get some feedback, especially from some of
the committers, on the KIP and on the note below.
Thanks.
--Vahid
From: "Vahid S Hashemian"
To: d...@kafka.apache.org
Cc: "Kafka User"
Date: 06/21/2017 12:49 PM
Subject:Re:
---
>
> Edoardo Comar
>
> IBM Message Hub
>
> IBM UK Ltd, Hursley Park, SO21 2JN
>
> "Vahid S Hashemian" wrote on 04/07/2017
> 17:11:43:
>
> > From: "Vahid S Hashemian"
> > To: d...@kafka.apache.org
>
at 1:18 AM, Vahid S Hashemian
wrote:
>
> James,
>
> Thanks for sharing your thoughts and experience.
> Could you please also confirm whether
> - you do any encryption for the mirrored data?
Not at the Kafka level. The data goes over a VPN.
> - you have a many-to-one mir
to tune settings.
Maybe that presentation will give more ideas about what to look at.
https://www.slideshare.net/mobile/JiangjieQin/producer-performance-tuning-for-apache-kafka-63147600
-James
Sent from my iPhone
> On Jul 6, 2017, at 1:00 AM, Vahid S Hashemian
wrote:
>
> The li
The literature suggests running the MM on the target cluster when possible
(with the exception of when encryption is required for transferred data).
I am wondering if this is still the recommended approach when mirroring
from multiple clusters to a single cluster (i.e. multiple MM instances).
Is
-
Edoardo Comar
IBM Message Hub
IBM UK Ltd, Hursley Park, SO21 2JN
From: "Vahid S Hashemian"
To: dev , "Kafka User"
Date: 04/07/2017 00:06
Subject:[DISCUSS] KIP-175: Additional '--describe' views for
Cons
Hi,
I created KIP-175 to make some improvements to the ConsumerGroupCommand
tool.
The KIP can be found here:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-175%3A+Additional+%27--describe%27+views+for+ConsumerGroupCommand
Your review and feedback is welcome!
Thanks.
--Vahid
+1.
Thank you Ismael for your hard work on this release.
--Vahid
From: Guozhang Wang
To: "d...@kafka.apache.org"
Cc: "users@kafka.apache.org" ,
annou...@apache.org, kafka-clients
Date: 06/28/2017 07:22 PM
Subject:Re: [ANNOUNCE] Apache Kafka 0.11.0.0 Released
Ismael,
anks.
--Vahid
From: Ismael Juma
To: d...@kafka.apache.org
Cc: kafka-clients , Kafka Users
Date: 06/26/2017 01:54 PM
Subject:Re: [VOTE] 0.11.0.0 RC2
Sent by:isma...@gmail.com
Hi Vahid,
Can you please check which test fails first? The errors you mentioned can
ter-tick-thread-1)
I tested on a VM and a physical machine, and both give me a lot of errors
like this.
Thanks.
--Vahid
From: Ismael Juma
To: Vahid S Hashemian
Cc: d...@kafka.apache.org, kafka-clients
, Kafka Users
Date: 06/26/2017 03:53 AM
Subject:Re: [VOTE] 0.11.0.0 R
Hi Ismael,
Not sure if my response on RC1 was lost or this issue is not a
show-stopper:
I checked again and with RC2, tests still fail in my Windown 64 bit
environment.
:clients:checkstyleMain
[ant:checkstyle] [ERROR]
C:\Users\User\Downloads\kafka-0.11.0.0-src\clients\src\main\java\org\apache
.
I was using the GetOffsetShell command to get the count, but seems that is
not necessarily the right way ..
What command should be used to get the count ?
On Thu, Jun 22, 2017 at 8:34 PM, Vahid S Hashemian <
vahidhashem...@us.ibm.com> wrote:
> Hi Karan,
>
> Just to clarify, with `--time -1
ld you please advise whether you're seeing a different behavior?
Thanks.
--Vahid
From: "Vahid S Hashemian"
To: users@kafka.apache.org
Date: 06/22/2017 06:43 PM
Subject:Re: Deleting/Purging data from Kafka topics (Kafka 0.10)
Hi Karan,
I think the issue is in verif
lhost:6095
--topic topicPurge --time -1 --partitions 0,1,2
topicPurge:0:67
topicPurge:1:67
topicPurge:2:66
Any ideas on what the issue might be ?
On Thu, Jun 22, 2017 at 1:31 PM, Vahid S Hashemian <
vahidhashem...@us.ibm.com> wrote:
> Hi Karan,
>
> The other broker config
Hi Karan,
The other broker config that plays a role here is
"log.retention.check.interval.ms".
For a low log retention time like in your example if this broker config
value is much higher, then the broker doesn't delete old logs regular
enough.
--Vahid
From: karan alang
To: users@kaf
+OffsetFetch#KIP-163:LowertheMinimumRequiredACLPermissionofOffsetFetch-AdditionalFoodforThought
I just added some more details in that section, which I hope further
clarifies the suggestion there.
Thanks.
--Vahid
From: Vahid S Hashemian/Silicon Valley/IBM
To: d...@kafka.apache.org
Cc:
Hi Ismael,
Thanks for running the release.
Running tests ('gradlew.bat test') on my Windows 64-bit VM results in
these checkstyle errors:
:clients:checkstyleMain
[ant:checkstyle] [ERROR]
C:\Users\User\Downloads\kafka-0.11.0.0-src\clients\src\main\java\org\apache\kafka\common\protocol\Errors.ja
which would intuitively
make
> > more sense to me. Perhaps any expert could shed some light on this? :)
> >
> > Viktor
> >
> > On Tue, Jun 13, 2017 at 2:38 PM, Vahid S Hashemian <
> > vahidhashem...@us.ibm.com <mailto:vahidhashem...@us.ibm.com>> wrote:
> &g
eeper - 3.4.6
Kafka - 10.2.0
Please let me know if you need any more
info. I appreciate your time.
Thanks
Arunkumar Pichaimuthu, PMP
----
On Fri, 6/16/17, Vahid S Hashemian
wrote:
Subject: Re:
UNKNOWN_TOPIC_OR_PARTITION with SASL_PLAIN
On Thu, 6/15/17, Vahid S Hashemian wrote:
Subject: Re: UNKNOWN_TOPIC_OR_PARTITION with SASL_PLAINTEXT ACL
To: users@kafka.apache.org
Date: Thursday, June 15, 2017, 6:49 PM
Hi Arunkumar,
Could you please take a look at this article:
https://developer.ibm.com/opentech/2017/05/31
run"
password="Arun123";
};
Thanks
Arunkumar Pichaimuthu, PMP
On Thu, 6/15/17, Vahid S Hashemian wrote:
Subject: Re: UNKNOWN_TOPIC_OR_PARTITION with SASL_PLAINTEXT ACL
To: users@kafka.apache.org
Date: Thursday, June 15, 2017, 6:16 PM
Hi Arunkuma
Hi Arunkumar,
Have you given your Kafka consumer/producer necessary permissions to
consume/produce messages?
--Vahid
From: Arunkumar
To:
Date: 06/15/2017 04:07 PM
Subject:UNKNOWN_TOPIC_OR_PARTITION with SASL_PLAINTEXT ACL
Hi
I am setting up ACL with SALS_PLAINTEXT. My z
s not getting earlier)
So, How do i interpret this ?
is this a caching issue ?
On Thu, Jun 15, 2017 at 1:01 PM, Vahid S Hashemian <
vahidhashem...@us.ibm.com> wrote:
> Hi Karan,
>
> The message "No topic available for consumer group provided" appears
when
> ther
Hi Karan,
The message "No topic available for consumer group provided" appears when
there is no topic under the consumer group in ZooKeeper (under
/consumers/myGroup/owners/).
Can you check whether the topic 'newBroker1' exists under this ZK path?
Also, do you still get the rows below if you run
Hi Michal,
Thanks a lot for your feedback.
Your statement about Heartbeat is fair and makes sense. I'll update the
KIP accordingly.
--Vahid
From: Michal Borowiecki
To: users@kafka.apache.org, Vahid S Hashemian
, d...@kafka.apache.org
Date: 06/13/2017 01:35 AM
Subject:
ind of weird there.
best,
Colin
On Thu, Jun 8, 2017, at 11:29, Vahid S Hashemian wrote:
> Hi all,
>
> I'm resending my earlier note hoping it would spark some conversation
> this
> time around :)
>
> Thanks.
> --Vahid
>
>
>
>
> From: "Vah
Great news.
Congrats Damian!
--Vahid
From: Guozhang Wang
To: "d...@kafka.apache.org" ,
"users@kafka.apache.org" ,
"priv...@kafka.apache.org"
Date: 06/09/2017 01:34 PM
Subject:[ANNOUNCE] New committer: Damian Guy
Hello all,
The PMC of Apache Kafka is pleased to announce
Hi all,
I'm resending my earlier note hoping it would spark some conversation this
time around :)
Thanks.
--Vahid
From: "Vahid S Hashemian"
To: dev , "Kafka User"
Date: 05/30/2017 08:33 AM
Subject:KIP-163: Lower the Minimum Required ACL Permission
+1 (non-binding)
Thanks.
--Vahid
From: Gwen Shapira
To: "d...@kafka.apache.org" , Users
Date: 06/05/2017 09:38 PM
Subject:[VOTE] KIP-162: Enable topic deletion by default
Hi,
The discussion has been quite positive, so I posted a JIRA, a PR and
updated the KIP with the lat
Hi Jerry,
The behavior you are expecting is implemented in 0.10.2 through KIP-88 (
https://cwiki.apache.org/confluence/display/KAFKA/KIP-88%3A+OffsetFetch+Protocol+Update
) and KAFKA-3853 (https://issues.apache.org/jira/browse/KAFKA-3853).
Starting from this release when you query a consumer group
Hi,
I started a new KIP to improve the minimum required ACL permissions of
some of the APIs:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-163%3A+Lower+the+Minimum+Required+ACL+Permission+of+OffsetFetch
The KIP is to address KAFKA-4585.
Feedback and suggestions are welcome!
Thanks.
--V
bypass confirmations, etc
would be an improvement. However, I've seen no complaints about the
current
behavior of the command-line and the KIP doesn't change it at all. So I'd
rather address things separately.
Gwen
On Fri, May 26, 2017 at 8:10 PM Vahid S Hashemian
wrote:
> Gw
Gwen, thanks for the KIP.
It looks good to me.
Just a minor suggestion: It would be great if the command asks for a
confirmation (y/n) before deleting the topic (similar to how removing ACLs
works).
Thanks.
--Vahid
From: Gwen Shapira
To: "d...@kafka.apache.org" , Users
Date: 05/26
On Fri, May 5, 2017 at 5:30 PM, Vahid S Hashemian
wrote:
> Hi Subhash,
>
> The broker config that affects group offset retention is
> "offsets.retention.minutes" (which defaults to 1 day).
> If the group is inactive (i.e. has no consumer consuming from it) for
t
Hi Subhash,
The broker config that affects group offset retention is
"offsets.retention.minutes" (which defaults to 1 day).
If the group is inactive (i.e. has no consumer consuming from it) for this
long its offsets will be removed from the internal topic offset and it
will not be listed in the
This might help: https://www.quora.com/How-did-Kafka-get-its-name
--Vahid
From: The Real Plato
To: users@kafka.apache.org
Date: 05/02/2017 07:20 PM
Subject:why is it called kafka?
searching google and the docs have not revealed the answer
--
-plato
Great news.
Congrats Rajini!
--Vahid
From: Gwen Shapira
To: d...@kafka.apache.org, Users ,
priv...@kafka.apache.org
Date: 04/24/2017 02:06 PM
Subject:[ANNOUNCE] New committer: Rajini Sivaram
The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we
are ple
+1 (non-binding)
Built from the source and ran the quickstart successfully on Ubuntu, Mac,
Windows (64 bit).
Thank you Gwen for running the release.
--Vahid
From: Gwen Shapira
To: d...@kafka.apache.org, Users
Cc: Alexander Ayars
Date: 04/12/2017 05:25 PM
Subject:[VOTE]
Hi Rajat,
It would be great if you could file a JIRA for this in Kafka issue
tracking site (https://issues.apache.org/jira/issues) so it can be easily
tracked and addressed.
Thanks.
--Vahid
From: "Rajat Yadav (Trainee, HO-IT)"
To: users@kafka.apache.org
Date: 03/04/2017 08:26 AM
Su
Pete,
I think this excellent post covers what you are looking for:
https://www.confluent.io/blog/tutorial-getting-started-with-the-new-apache-kafka-0-9-consumer-client/
--Vahid
From: Peter Figliozzi
To: users@kafka.apache.org
Date: 02/22/2017 07:29 PM
Subject:Simple data-driv
Thanks for this useful and the nice KIP write-up.
Just a minor suggestion. Would it make sense to avoid repeating the term
"reset" in the arguments?
We already use the argument "reset-offset", so we may not need to repeat
the term in the follow-on argument.
For example, instead of
kafka-consum
Could this be the same issue as the one reported here?
https://issues.apache.org/jira/browse/KAFKA-4547
--Vahid
From: Koert Kuipers
To: users@kafka.apache.org
Date: 01/27/2017 09:34 PM
Subject:possible bug or inconsistency in kafka-clients
hello all,
i just wanted to poi
Congrats Grant!
--Vahid
From: Sriram Subramanian
To: users@kafka.apache.org
Cc: d...@kafka.apache.org, priv...@kafka.apache.org
Date: 01/11/2017 11:58 AM
Subject:Re: [ANNOUNCE] New committer: Grant Henke
Congratulations Grant!
On Wed, Jan 11, 2017 at 11:51 AM, Gwen Shap
Hi Guozhang,
I also verified the quickstart on Ubuntu and Mac. +1 on those.
On Windows OS there are a couple of issues for which the following PRs
exist:
- https://github.com/apache/kafka/pull/2146 (already merged to trunk)
- https://github.com/apache/kafka/pull/2238 (open)
These issues are not
Any chance the consumer process that consumes from that topic is still
running while you are doing all this?
--Vahid
From: Tim Visher
To: users@kafka.apache.org
Date: 12/09/2016 08:26 AM
Subject:Re: Deleting a topic without delete.topic.enable=true?
I did all of that becaus
+1
Build and quickstart worked fine on Ubuntu, Mac, Windows 32 and 64 bit.
Thanks for running the release.
Regards,
--Vahid
From: Guozhang Wang
To: "users@kafka.apache.org" ,
"d...@kafka.apache.org" ,
kafka-clie...@googlegroups.com
Date: 12/07/2016 02:47 PM
Subject:[VOTE]
Ryan,
The correct consumer command in the latest doc (
http://kafka.apache.org/quickstart#quickstart_consume) is
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic
test --from-beginning
You used the "--zookeeper" parameter which implies using the old consumer,
in which cas
There is a JIRA open that should address this:
https://issues.apache.org/jira/browse/KAFKA-3853
Since it requires a change in the protocol, it's awaiting a KIP vote
that's happening next week (
https://cwiki.apache.org/pages/viewpage.action?pageId=66849788).
Once the vote is passed the code shoul
lease!
Confluent is on the ball.
On Wed, Nov 16, 2016 at 5:55 PM Gwen Shapira wrote:
Thank you, Vahid!
On Wed, Nov 16, 2016 at 1:53 PM, Vahid S Hashemian
wrote:
> I'll open a JIRA.
>
> Andrew, let me know if you want to take over the implementation.
> Otherwise, I'd be happ
I'll open a JIRA.
Andrew, let me know if you want to take over the implementation.
Otherwise, I'd be happy to work on it.
Thanks.
--Vahid
From: Gwen Shapira
To: Users
Date: 11/16/2016 01:23 PM
Subject:Re: --group flag for console consumer
Makes sense to me. Do you want t
Congrats Becket!
--Vahid
From: Jason Gustafson
To: Kafka Users
Cc: d...@kafka.apache.org
Date: 10/31/2016 10:56 AM
Subject:Re: [ANNOUNCE] New committer: Jiangjie (Becket) Qin
Great work, Becket!
On Mon, Oct 31, 2016 at 10:54 AM, Onur Karaman <
okara...@linkedin.com.inv
; Change
>the consumer side load balancing and distributed co-ordination to use
a
>consumer co-ordinator
>
> I thought this was already done in 2015.
>
> On Thu, Oct 6, 2016 at 4:55 PM, Vahid S Hashemian <
> vahidhashem...@us.ibm.com
> > wrote:
>
> >
Jason,
Thanks a lot for managing this release.
I ran the quick start (Steps 2-8) with this release candidate on Ubuntu,
Windows, and Mac and they mostly look great.
These are some, hopefully, minor items and gaps I noticed with respect to
the existing quick start documentation (and the updated
1 - 100 of 106 matches
Mail list logo
