- Jun 21, 2019
-
-
Anthony Simpson authored
-
- Apr 29, 2019
-
-
Giorgi Fafakerashvili authored
-
- Apr 17, 2019
-
-
Giorgi Fafakerashvili authored
-
- Mar 22, 2019
-
-
Brian Bushree authored
`kafka.list_topics(...)` should not require a topic parameter Author: Brian Bushree <bbushree@confluent.io> Reviewers: Ewen Cheslack-Postava <ewen@confluent.io> Closes #6367 from brianbushree/list-topics-no-topic
-
Bill Bejeck authored
Minor clean up ofThreadCacheTest Reviewers: Guozhang Wang <wangguoz@gmail.com>, Matthias J. Sax <mjsax@apache.org>
-
Radai Rosenblatt authored
`map` was being used to convert `Iterable[Integer]` to `Iterable[Int`]. That operation represented 11% of total CPU time measured under load for us. We also expect a positive impact on GC. Reviewers: Joel Koshy <jjkoshy@gmail.com>, Ismael Juma <ismael@juma.me.uk>
-
Matthias J. Sax authored
Reviewers: Bill Bejeck <bill@confluent.io>, Guozhang Wang <guozhang@confluent.io>
-
khairy authored
The goal of this task is to implement an integration test for the kafka stream metrics. We have to check 2 things: 1. After streams application are started, all metrics from different levels (thread, task, processor, store, cache) are correctly created and displaying recorded values. 2. When streams application are shutdown, all metrics are correctly de-registered and removed. Reviewers: John Roesler <john@confluent.io>, Guozhang Wang <wangguoz@gmail.com>
-
- Mar 21, 2019
-
-
Matthias J. Sax authored
Updates ./jenkins.sh to build stream archetype and install it in local maven cache. Afterward, archetype is used to create a new maven project and maven project is compiled for verification. Reviewers: Guozhang Wang <wangguoz@gmail.com>, John Roesler <john@confluent.io>, Bill Bejeck <bbejeck@gmail.com>
-
Stanislav Kozlovski authored
RoundTripWorker to should use a long field for maxMessages rather than an int. The consumer group used should unique as well. Reviewers: Colin P. McCabe <cmccabe@apache.org>
-
Anna Povzner authored
Reviewers: Rajini Sivaram <rajinisivaram@googlemail.com>
-
- Mar 20, 2019
-
-
huxihx authored
- The flaky failure is caused by the fact that the main thread sometimes issues DescribeConsumerGroup request before the consumer assignment takes effect. Added a latch to make sure such situation is not going to happen. Author: huxihx <huxi_2b@hotmail.com> Author: huxi <huxi_2b@hotmail.com> Author: Manikumar Reddy <manikumar.reddy@gmail.com> Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com> Closes #6441 from huxihx/KAFKA-8098
-
Florian Hussonnois authored
Sub-task required to allow to define custom processor names with KStreams DSL(KIP-307) : - add new public interface NamedOperation - deprecate methods Joined.as() and Joined.name() - update Suppredded interface to extend NamedOperation Reviewers: Matthias J. Sax <mjsax@apache.org>, John Roesler <john@confluent.io>, Bill Bejeck <bbejeck@gmail.com>
-
Matthias J. Sax authored
Reviewers: Bill Bejeck <bill@confluent.io>, Guozhang Wang <guozhang@confluent.io>
-
- Mar 19, 2019
-
-
Victoria Bialas authored
* updated names for deprecated streams constants * add DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG in place of deprecated Reviewers: Jim Galasyn <jim.galasyn@confluent.io>, Matthias J. Sax <matthias@confluent.io>
-
Victoria Bialas authored
Reviewers: Joel Mamill <joel@confluent.io>, Matthias J. Sax <mjsax@apache.org>
-
A. Sophie Blee-Goldman authored
Use concurrent data structure for the underlying cache in NamedCache, and iterate over it with subMap instead of many calls to get() Reviewers: Guozhang Wang <wangguoz@gmail.com>, Bill Bejeck <bbejeck@gmail.com>
-
Guozhang Wang authored
In a previous commit #6091, we've fixed a couple of edge cases and hence do not need to remove state listener anymore (before that we removed the state listener intentionally to avoid some race conditions, which has been gone for now). Reviewers: Matthias J. Sax <mjsax@apache.org>, Bill Bejeck <bbejeck@gmail.com>
-
Bob Barrett authored
This patch adds additional DEBUG statements in AbstractIndex.scala, OffsetIndex.scala, and TimeIndex.scala. It also changes the logging on append from DEBUG to TRACE to make DEBUG logging less disruptive, and it ensures that exceptions raised from index classes include file/offset information. Reviewers: Jason Gustafson <jason@confluent.io>
-
- Mar 18, 2019
-
-
Boyang Chen authored
Reviewers: Colin P. McCabe <cmccabe@apache.org>
-
Rajini Sivaram authored
Shutdown session expiry thread prior to closing ZooKeeper client to ensure that new clients are not created by the expiry thread and left active when returning from ZooKeeperClient.close(). Reviewers: Ismael Juma <ismael@juma.me.uk>
-
Anna Povzner authored
Reviewers: Rajini Sivaram <rajinisivaram@googlemail.com>
-
Rajini Sivaram authored
TopicDescription and ConsumerGroupDescription in org.apache.kafka.clients.admin. are part of the public API, so we should retain the existing public constructor. Changed the new constructor with authorized operations to be package-private to avoid maintaining more public constructors since we only expect admin client to use this. Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
-
Rajini Sivaram authored
We verify that ZK clients are closed in tests since these can affect subsequent tests and that makes it hard to debug test failures. But because of changes to ZooKeeper client, we were checking the wrong thread name. The thread name used now is <creatorThreadName>-EventThread where creatorThreadName varies depending on the test. Fixed ZooKeeperTestHarness to check this format and fixed tests which were leaving ZK clients behind. Also added a test to make sure we can detect changes to the thread name when we update ZK clients in future. Reviewers: Ismael Juma <ismael@juma.me.uk>, Manikumar Reddy <manikumar.reddy@gmail.com>
-
huxihx authored
https://issues.apache.org/jira/browse/KAFKA-7813 Running the JMX tool without --object-name parameter, results in a NullPointerException. *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing strategy (including rationale) for the feature or bug fix. Unit and/or integration tests are expected for any behaviour change and system tests should be considered for larger changes.* Author: huxihx <huxi_2b@hotmail.com> Reviewers: Ewen Cheslack-Postava <ewen@confluent.io> Closes #6139 from huxihx/KAFKA-7813
-
- Mar 16, 2019
-
-
Manikumar Reddy authored
KAFKA-8114: Wait for SCRAM credential propagation in DelegationTokenEndToEndAuthorizationTest (#6452) Reviewers: Rajini Sivaram <rajinisivaram@googlemail.com>
-
Rajini Sivaram authored
Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
-
Kristian Aurlien authored
Reviewers: Guozhang Wang <guozhang@confluent.io>, Matthias J. Sax <matthias@confluent.io>
-
Matthias J. Sax authored
Reviewers: Bill Bejeck <bill@confluent.io>, John Roesler <john@confluent.io>, Colin P. McCabe <cmccabe@confluent.io>
-
- Mar 15, 2019
-
-
Stanislav Kozlovski authored
Reviewers: Colin P. McCabe <cmccabe@apache.org>
-
Rajini Sivaram authored
The use of consumer.poll() made the test flaky since in some cases, it doesn't wait for coordinator connection. Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
-
Massimo Siani authored
The Java API can pass a Properties object to StreamsBuilder#build, to allow, e.g., topology optimization, while the Scala API does not yet. The latter only delegates the work to the underlying Java implementation. Reviewers: John Roesler <john@confluent.io>, Bill Bejeck <bbejeck@gmail.com>
-
huxi authored
-
Lee Dongjin authored
This is a draft cleanup for KAFKA-7502. Here is the details: * Make KTableKTableJoinNode abstract, and define its child classes ([NonMaterialized,Materialized]KTableKTableJoinNode) instead: now, all materialization-related routines are separated into the other classes. * KTableKTableJoinNodeBuilder#build now instantiates [NonMaterialized,Materialized]KTableKTableJoinNode classes instead of KTableKTableJoinNode. Reviewers: Guozhang Wang <wangguoz@gmail.com>, Bill Bejeck <bbejeck@gmail.com>
-
- Mar 14, 2019
-
-
Rajini Sivaram authored
Adds a new listener config `max.connections` to limit the number of active connections on each listener. The config may be prefixed with listener prefix. This limit may be dynamically reconfigured without restarting the broker. This is one of the PRs for KIP-402 (https://cwiki.apache.org/confluence/display/KAFKA/KIP-402%3A+Improve+fairness+in+SocketServer+processors). Note that this is currently built on top of PR #6022 Author: Rajini Sivaram <rajinisivaram@googlemail.com> Reviewers: Gwen Shapira <cshapi@gmail.com> Closes #6034 from rajinisivaram/KAFKA-7730-max-connections
-
Rajini Sivaram authored
Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
-
- Mar 13, 2019
-
-
Matthias J. Sax authored
Fix JavaDocs Warning Reviewers: uozhang Wang <wangguoz@gmail.com>, Bill Bejeck <bbejeck@gmail.com>
-
- Mar 12, 2019
-
-
José Armando García Sancio authored
Users have reported (KAFKA-7565) that when consumer poll wake up is used, it is possible to receive fetch responses that don't match the copied topic partitions collection for the session when the fetch request was created. This commit improves the error handling here by throwing an IllegalStateException instead of a NullPointerException. And by generating a message for the exception that includes a bit of more information. Reviewers: Jason Gustafson <jason@confluent.io>
-
Bill Bejeck authored
Just a minor cleanup to use Java 8 lambdas vs anonymous classes in this test. I ran all tests in the streams test suite Reviewers: Matthias J. Sax <mjsax@apache.org>, Guozhang Wang <wangguoz@gmail.com>
-
cadonna authored
Reviewers: A. Sophie Blee-Goldman <sophie@confluent.io>, Matthias J. Sax <matthias@confluent.io>
-