dev@kafka.apache.org, 2017-02

You are viewing a plain text version of this content. The canonical link for it is here.

- [jira] [Commented] (KAFKA-4686) Null Message payload is shutting down broker - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/01 00:00:54 UTC, 15 replies.
- [GitHub] kafka pull request #2473: KAFKA-4717: Use absolute paths to files in root di... - posted by asfgit <gi...@git.apache.org> on 2017/02/01 00:07:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4717) connect jars are missing LICENSE/NOTICE files - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/01 00:07:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4717) connect jars are missing LICENSE/NOTICE files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/01 00:07:51 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4320) Log compaction docs update - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2017/02/01 00:27:51 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2544) Replication tools wiki page needs to be updated - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2017/02/01 00:28:51 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3940) Log should check the return value of dir.mkdirs() - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2017/02/01 00:29:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2017/02/01 00:29:51 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3522) Consider adding version information into rocksDB storage format - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2017/02/01 00:29:51 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3543) Allow a variant of transform() which can emit multiple values - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/01 00:38:52 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3543) Allow a variant of transform() which can emit multiple values - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/01 00:44:52 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1238 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/01 00:56:11 UTC, 0 replies.
- [jira] [Created] (KAFKA-4718) Revisit DSL partitioning assumption for KStream source topics - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/01 01:16:51 UTC, 0 replies.
- Re: [VOTE] KIP-107 Add purgeDataBefore() API in AdminClient - posted by Apurva Mehta <ap...@confluent.io> on 2017/02/01 01:45:34 UTC, 3 replies.
- Re: [DISCUSS] KIP-112: Handle disk failure for JBOD - posted by Dong Lin <li...@gmail.com> on 2017/02/01 01:53:11 UTC, 64 replies.
- [jira] [Updated] (KAFKA-1332) Add functionality to the offsetsBeforeTime() API - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/01 02:16:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4495) ThreadCache.maybeEvict can become an infinite loop - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/01 02:16:52 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3262) Make KafkaStreams debugging friendly - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/01 02:16:52 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3302) Pass kerberos keytab and principal as part of client config - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/01 02:16:52 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3478) Finer Stream Flow Control - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/01 02:16:52 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4611) Support custom authentication mechanism - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/01 02:17:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3944) After the broker restart, fetchers stopped due to a delayed controlled shutdown message - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/01 02:34:51 UTC, 0 replies.
- [GitHub] kafka pull request #2429: KAFKA-4677: Avoid unnecessary task movement across... - posted by asfgit <gi...@git.apache.org> on 2017/02/01 04:17:38 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4677) Avoid unnecessary task movement across threads during rebalance - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/01 04:17:52 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4677) Avoid unnecessary task movement across threads during rebalance - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/01 04:17:52 UTC, 1 replies.
- [GitHub] kafka pull request #2476: KAFKA-4586; Add purgeDataBefore() API (KIP-107) - posted by lindong28 <gi...@git.apache.org> on 2017/02/01 05:11:40 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4586) Add purgeDataBefore() API in AdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/01 05:11:52 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1239 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/01 07:57:39 UTC, 0 replies.
- [GitHub] kafka pull request #2477: MINOR: Change rocksdb logging to error level - posted by dguy <gi...@git.apache.org> on 2017/02/01 09:37:54 UTC, 1 replies.
- Re: [DISCUSS] KIP-113: Support replicas movement between log directories - posted by Alexey Ozeritsky <ao...@yandex.ru> on 2017/02/01 10:16:20 UTC, 1 replies.
- [DISCUSS] KIP-116 - Add State Store Checkpoint Interval Configuration - posted by Damian Guy <da...@gmail.com> on 2017/02/01 10:18:27 UTC, 35 replies.
- Re: [DISCUS] consuming messages is polling - is there a reason? new KIP for poll? - posted by Alexander Binzberger <al...@wingcon.com> on 2017/02/01 10:46:24 UTC, 2 replies.
- [GitHub] kafka pull request #2478: KAFKA-4702: Parametrize streams benchmarks to run ... - posted by enothereska <gi...@git.apache.org> on 2017/02/01 12:48:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4702) Parametrize streams benchmarks to run at scale - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/01 12:48:51 UTC, 1 replies.
- Re: [DISCUSS] KIP-82 - Add Record Headers - posted by Jeroen van Disseldorp <je...@axual.io> on 2017/02/01 14:43:45 UTC, 86 replies.
- Re: [DISCUSS] KIP-98: Exactly Once Delivery and Transactional Messaging - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/01 16:03:35 UTC, 26 replies.
- [jira] [Created] (KAFKA-4719) Timed out waiting for consumption in OffsetValidationTest.test_broker_failure - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/01 16:42:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records" - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/01 16:43:51 UTC, 1 replies.
- Re: [DISCUSS] KIP-114: KTable materialization and improved semantics - posted by Eno Thereska <en...@gmail.com> on 2017/02/01 17:04:03 UTC, 0 replies.
- [GitHub] kafka pull request #2479: KAFKA-4719: Consumption timeout should take into a... - posted by hachikuji <gi...@git.apache.org> on 2017/02/01 18:10:38 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4719) Timed out waiting for consumption in OffsetValidationTest.test_broker_failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/01 18:10:51 UTC, 1 replies.
- [GitHub] kafka pull request #2480: MINOR: Update docs for version 0.10.2.0 - posted by ewencp <gi...@git.apache.org> on 2017/02/01 18:18:28 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4719) Timed out waiting for consumption in OffsetValidationTest.test_broker_failure - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/01 18:33:51 UTC, 0 replies.
- [jira] [Created] (KAFKA-4720) Add KStream.peek(ForeachAction) - posted by "Steven Schlansker (JIRA)" <ji...@apache.org> on 2017/02/01 19:00:53 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder - posted by "Roy Majumdar (JIRA)" <ji...@apache.org> on 2017/02/01 19:59:51 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2017/02/01 20:08:51 UTC, 0 replies.
- [jira] [Created] (KAFKA-4721) KafkaStreams (and possibly others) should inherit Closeable - posted by "Steven Schlansker (JIRA)" <ji...@apache.org> on 2017/02/01 20:16:51 UTC, 0 replies.
- [GitHub] kafka pull request #2481: Kafka 4706 :Unify StreamsKafkaClient instances - posted by sharad-develop <gi...@git.apache.org> on 2017/02/01 20:57:49 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2172) Round-robin partition assignment strategy too restrictive - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/02/01 21:03:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/02/01 21:43:51 UTC, 5 replies.
- [jira] [Created] (KAFKA-4722) StreamThread should allow customization of thread prefix - posted by "Steven Schlansker (JIRA)" <ji...@apache.org> on 2017/02/01 22:09:51 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1241 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/01 22:37:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4722) StreamThread should allow customization of thread prefix - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/01 22:45:51 UTC, 3 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1904 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/01 22:52:35 UTC, 0 replies.
- Re: [DISCUSS] KIP-111 : Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker. - posted by Mayuresh Gharat <gh...@gmail.com> on 2017/02/01 22:54:42 UTC, 3 replies.
- [VOTE] 0.10.2.0 RC0 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/01 23:44:50 UTC, 10 replies.
- [GitHub] kafka pull request #2482: MINOR: Update Streams docs: quickstart and concept... - posted by guozhangwang <gi...@git.apache.org> on 2017/02/02 01:08:37 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/02 03:55:51 UTC, 2 replies.
- [GitHub] kafka pull request #2177: KAFKA-3959: enforce offsets.topic.replication.fact... - posted by asfgit <gi...@git.apache.org> on 2017/02/02 03:56:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/02 03:56:51 UTC, 2 replies.
- [VOTE] KIP-98: Exactly Once Delivery and Transactional Messaging - posted by Guozhang Wang <wa...@gmail.com> on 2017/02/02 04:13:21 UTC, 41 replies.
- [GitHub] kafka pull request #2442: KAFKA-4642: Improve test coverage of ProcessorStat... - posted by asfgit <gi...@git.apache.org> on 2017/02/02 04:17:47 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4642) Improve test coverage of ProcessorStateManager - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/02 04:17:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4642) Improve test coverage of ProcessorStateManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/02 04:17:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4647) Improve test coverage of GlobalStreamThread - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/02 04:20:51 UTC, 0 replies.
- [GitHub] kafka pull request #2450: KAFKA-4647: Improve test coverage of GlobalStreamT... - posted by asfgit <gi...@git.apache.org> on 2017/02/02 04:21:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4647) Improve test coverage of GlobalStreamThread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/02 04:21:51 UTC, 0 replies.
- [GitHub] kafka pull request #2444: KAFKA-4645: Improve test coverage of ProcessorTopo... - posted by asfgit <gi...@git.apache.org> on 2017/02/02 04:30:45 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4645) Improve test coverage of ProcessorTopology - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/02 04:30:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4645) Improve test coverage of ProcessorTopology - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/02 04:30:51 UTC, 0 replies.
- [GitHub] kafka pull request #2483: MINOR: Ensure timestamp type is provided when upco... - posted by hachikuji <gi...@git.apache.org> on 2017/02/02 04:42:00 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1242 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/02 05:26:09 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1905 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/02 06:06:54 UTC, 0 replies.
- [GitHub] kafka pull request #2484: KAFKA-3959: Follow-up; move upgrade notes to 0.10.... - posted by ewencp <gi...@git.apache.org> on 2017/02/02 06:30:13 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/02 06:30:53 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1243 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/02 06:41:55 UTC, 0 replies.
- [GitHub] kafka pull request #2485: KAFKA-3896: Fix KStream-KStream leftJoin - posted by guozhangwang <gi...@git.apache.org> on 2017/02/02 06:56:32 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/02 06:56:51 UTC, 1 replies.
- [jira] [Created] (KAFKA-4723) offsets.storage=kafka - groups stuck in rebalancing with committed offsets - posted by "Jason Bew (JIRA)" <ji...@apache.org> on 2017/02/02 10:14:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4723) offsets.storage=kafka - groups stuck in rebalancing with committed offsets - posted by "Jason Bew (JIRA)" <ji...@apache.org> on 2017/02/02 10:17:51 UTC, 2 replies.
- Live-lock between consumer thread and heartbeat thread - posted by Lukavský Jan <ja...@o2.cz> on 2017/02/02 10:19:46 UTC, 8 replies.
- [jira] [Created] (KAFKA-4724) Clean up of state directories has a race condition and can possibly remove stores that are sill used - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/02 11:35:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4724) Clean up of state directories has a race condition and can possibly remove stores that are still used - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/02 12:02:51 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4724) Clean up of state directories has a race condition and can possibly remove stores that are still used - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/02 12:05:54 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4724) Clean up of state directories can possibly remove stores that are about to be used by another thread - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/02 12:59:51 UTC, 0 replies.
- [GitHub] kafka pull request #2486: KAFKA-4724: Clean up of state directories can poss... - posted by dguy <gi...@git.apache.org> on 2017/02/02 13:01:48 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4724) Clean up of state directories can possibly remove stores that are about to be used by another thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/02 13:01:51 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4723) offsets.storage=kafka - groups stuck in rebalancing with committed offsets - posted by "Jason Bew (JIRA)" <ji...@apache.org> on 2017/02/02 16:54:51 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4182) Move the change logger out of RocksDB stores - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/02 17:17:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/02 18:09:51 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-4722) Add application.id to StreamThread name - posted by "Sharad (JIRA)" <ji...@apache.org> on 2017/02/02 18:15:51 UTC, 0 replies.
- Re: [VOTE] KIP-48 Support for delegation tokens as an authentication mechanism - posted by Jun Rao <ju...@confluent.io> on 2017/02/02 18:16:39 UTC, 19 replies.
- Kafka KIP meeting Feb 7 at 11:00am PST - posted by Jun Rao <ju...@confluent.io> on 2017/02/02 18:27:39 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4722) Add application.id to StreamThread name - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/02 18:29:52 UTC, 3 replies.
- [GitHub] kafka pull request #2485: KAFKA-3896: Fix KStream-KStream leftJoin in Repart... - posted by asfgit <gi...@git.apache.org> on 2017/02/02 18:34:27 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4719) Timed out waiting for consumption in OffsetValidationTest.test_broker_failure - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/02 18:49:51 UTC, 0 replies.
- [DISCUSS] KIP-117: Add a public AdministrativeClient API for Kafka admin operations - posted by Colin McCabe <cm...@apache.org> on 2017/02/02 18:54:49 UTC, 52 replies.
- [jira] [Created] (KAFKA-4725) Kafka broker fails due to OOM when producer exceeds throttling quota for extended periods of time - posted by "Jeff Chao (JIRA)" <ji...@apache.org> on 2017/02/02 18:57:51 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1244 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/02 19:15:30 UTC, 0 replies.
- [jira] [Created] (KAFKA-4726) ValueMapper should have (read) access to key - posted by "Steven Schlansker (JIRA)" <ji...@apache.org> on 2017/02/02 20:53:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4726) ValueMapper should have (read) access to key - posted by "Steven Schlansker (JIRA)" <ji...@apache.org> on 2017/02/02 21:26:51 UTC, 0 replies.
- [GitHub] kafka pull request #2461: MINOR: added upgrade and API changes to docs - posted by mjsax <gi...@git.apache.org> on 2017/02/02 21:46:32 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/02 22:24:52 UTC, 0 replies.
- [GitHub] kafka pull request #2474: KAFKA-4039: Fix deadlock during shutdown due to lo... - posted by asfgit <gi...@git.apache.org> on 2017/02/02 22:25:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/02 22:25:53 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/02 22:28:51 UTC, 0 replies.
- [GitHub] kafka pull request #2483: MINOR: Ensure timestamp type is provided when up-c... - posted by asfgit <gi...@git.apache.org> on 2017/02/02 23:04:29 UTC, 0 replies.
- [jira] [Created] (KAFKA-4727) A Production server configuration needs to be updated - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/02 23:15:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4727) A Production server configuration needs to be updated - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/02 23:19:51 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-3924) Data loss due to halting when LEO is larger than leader's LEO - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/02 23:24:51 UTC, 0 replies.
- [GitHub] kafka pull request #2487: Kafka-4722 : Add application.id to StreamThread na... - posted by sharad-develop <gi...@git.apache.org> on 2017/02/02 23:39:47 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4423) Drop support for Java 7 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/02 23:44:51 UTC, 2 replies.
- [GitHub] kafka pull request #2488: MINOR: add architecture section and configure / ex... - posted by guozhangwang <gi...@git.apache.org> on 2017/02/03 00:37:29 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4708) Fix Transient failure in BrokerApiVersionsCommandTest.checkBrokerApiVersionCommandOutput - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/03 00:51:52 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-4727) A Production server configuration needs to be updated - posted by "huxi (JIRA)" <ji...@apache.org> on 2017/02/03 01:02:51 UTC, 0 replies.
- [GitHub] kafka pull request #2489: KAFKA-4708: Fix Transient Failure in BrokerApiVers... - posted by cmccabe <gi...@git.apache.org> on 2017/02/03 01:06:34 UTC, 1 replies.
- [GitHub] kafka pull request #2490: kafka-4727: A Production server configuration need... - posted by amethystic <gi...@git.apache.org> on 2017/02/03 01:06:44 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4708) Fix Transient failure in BrokerApiVersionsCommandTest.checkBrokerApiVersionCommandOutput - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/03 01:06:51 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4317) RocksDB checkpoint files lost on kill -9 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/03 01:26:51 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1245 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/03 02:30:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex - posted by "Yuto Kawamura (JIRA)" <ji...@apache.org> on 2017/02/03 05:34:51 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex - posted by "Yuto Kawamura (JIRA)" <ji...@apache.org> on 2017/02/03 05:37:52 UTC, 2 replies.
- Re: Trying to understand design decision about producer ack and min.insync.replicas - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/03 05:42:30 UTC, 5 replies.
- [jira] [Commented] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/03 05:43:52 UTC, 3 replies.
- [jira] [Commented] (KAFKA-4385) producer is sending too many unnecessary meta data request if the meta data for a topic is not available and "auto.create.topics.enable" =false - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/03 05:45:52 UTC, 2 replies.
- Re: [VOTE] KIP-54: Sticky Partition Assignment Strategy - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/03 06:35:54 UTC, 2 replies.
- Re: KIP-54 voting status? - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/03 06:37:10 UTC, 0 replies.
- Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/03 06:40:18 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1246 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/03 06:43:50 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2376) Add Copycat metrics - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/03 07:36:51 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4276) REST configuration not visible in connector properties config files - posted by "Akhilesh Naidu (JIRA)" <ji...@apache.org> on 2017/02/03 08:00:58 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-4276) REST configuration not visible in connector properties config files - posted by "Akhilesh Naidu (JIRA)" <ji...@apache.org> on 2017/02/03 08:04:52 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4276) REST configuration not visible in connector properties config files - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/03 08:40:51 UTC, 0 replies.
- [jira] [Created] (KAFKA-4728) KafkaConsumer#commitSync should clone its input - posted by "Jan Lukavský (JIRA)" <ji...@apache.org> on 2017/02/03 09:34:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4728) KafkaConsumer#commitSync should clone its input - posted by "Jan Lukavský (JIRA)" <ji...@apache.org> on 2017/02/03 09:36:51 UTC, 3 replies.
- [jira] [Commented] (KAFKA-4728) KafkaConsumer#commitSync should clone its input - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/03 09:46:51 UTC, 2 replies.
- [GitHub] kafka pull request #2491: [KAFKA-4728] KafkaConsumer#commitSync should clone... - posted by je-ik <gi...@git.apache.org> on 2017/02/03 09:54:22 UTC, 1 replies.
- [jira] [Created] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/03 10:00:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-4730) Streams does not have an in-memory windowed store - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/03 10:19:51 UTC, 0 replies.
- [DISCUSS] KIP-118: Drop Support for Java 7 in Kafka 0.11 - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/03 10:38:33 UTC, 7 replies.
- [jira] [Updated] (KAFKA-4422) Drop support for Scala 2.10 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/03 12:37:51 UTC, 1 replies.
- KIP-119: Drop Support for Scala 2.10 in Kafka 0.11 - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/03 14:30:44 UTC, 3 replies.
- [jira] [Updated] (KAFKA-4662) Improve test coverage TopologyBuilder - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/03 16:50:51 UTC, 0 replies.
- [GitHub] kafka pull request #2464: KAFKA-4662: adding test coverage for addSource met... - posted by asfgit <gi...@git.apache.org> on 2017/02/03 16:51:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4662) Improve test coverage TopologyBuilder - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/03 16:51:52 UTC, 0 replies.
- [GitHub] kafka-site pull request #43: [DO NOT MERGE] manual changes after copy-paste ... - posted by guozhangwang <gi...@git.apache.org> on 2017/02/03 16:59:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4725) Kafka broker fails due to OOM when producer exceeds throttling quota for extended periods of time - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/03 17:00:52 UTC, 6 replies.
- [jira] [Commented] (KAFKA-4725) Kafka broker fails due to OOM when producer exceeds throttling quota for extended periods of time - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/03 17:01:51 UTC, 6 replies.
- [GitHub] kafka pull request #2452: KAFKA-4649: Improve test coverage GlobalStateManag... - posted by asfgit <gi...@git.apache.org> on 2017/02/03 17:11:49 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4649) Improve test coverage GlobalStateManagerImpl - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/03 17:11:52 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4649) Improve test coverage GlobalStateManagerImpl - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/03 17:11:52 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4646) Improve test coverage AbstractProcessorContext - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/03 17:16:51 UTC, 0 replies.
- [GitHub] kafka pull request #2447: KAFKA-4646: Improve test coverage AbstractProcesso... - posted by asfgit <gi...@git.apache.org> on 2017/02/03 17:17:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4646) Improve test coverage AbstractProcessorContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/03 17:17:51 UTC, 0 replies.
- [jira] [Created] (KAFKA-4731) Add event-based session windows - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/03 18:01:02 UTC, 0 replies.
- [GitHub] kafka pull request #2492: HOTFIX: update incorrect docs and broken links - posted by mjsax <gi...@git.apache.org> on 2017/02/03 18:18:13 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1247 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/03 18:41:41 UTC, 0 replies.
- [GitHub] kafka pull request #2333: KAFKA-3452 Follow-up: Optimize ByteStore Scenarios - posted by asfgit <gi...@git.apache.org> on 2017/02/03 19:13:45 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3452) Support session windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/03 19:13:53 UTC, 0 replies.
- [VOTE] KIP-111 Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker. - posted by Mayuresh Gharat <gh...@gmail.com> on 2017/02/03 19:25:55 UTC, 33 replies.
- [jira] [Created] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1] - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/03 20:32:51 UTC, 0 replies.
- [GitHub] kafka pull request #2493: KAFKA-4720: add a KStream#peek(ForeachAction... - posted by stevenschlansker <gi...@git.apache.org> on 2017/02/03 20:49:24 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4720) Add KStream.peek(ForeachAction) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/03 20:49:51 UTC, 2 replies.
- [GitHub] kafka pull request #2494: HOTFIX: Verifiable producer request timeout needs ... - posted by hachikuji <gi...@git.apache.org> on 2017/02/03 21:37:51 UTC, 1 replies.
- [GitHub] kafka-site pull request #44: 0102 fixes - posted by derrickdoo <gi...@git.apache.org> on 2017/02/03 21:45:35 UTC, 0 replies.
- [GitHub] kafka-site issue #44: 0102 fixes - posted by derrickdoo <gi...@git.apache.org> on 2017/02/03 21:46:44 UTC, 2 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1248 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/03 21:49:58 UTC, 0 replies.
- [GitHub] kafka pull request #2495: Adjustments to docs to make them work with latest ... - posted by derrickdoo <gi...@git.apache.org> on 2017/02/03 21:57:44 UTC, 0 replies.
- [GitHub] kafka pull request #2496: KAFKA-4725: Stop leaking messages in produce reque... - posted by halorgium <gi...@git.apache.org> on 2017/02/03 21:57:48 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1249 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/03 22:13:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3856) Cleanup Kafka Streams builder API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/03 22:23:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3856) Move inner classes accessible only functions in TopologyBuilder out of public APIs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/03 22:23:51 UTC, 1 replies.
- [jira] [Created] (KAFKA-4733) Improve Streams Reset Tool console output - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/03 22:50:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4720) Add KStream.peek(ForeachAction) - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/03 23:08:51 UTC, 0 replies.
- [jira] [Created] (KAFKA-4734) timeindex on old segments not trimmed to actual size - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/03 23:26:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4734) timeindex on old segments not trimmed to actual size - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/03 23:26:51 UTC, 2 replies.
- [DISCUSS] KIP-120: Cleanup Kafka Streams builder API - posted by "Matthias J. Sax" <ma...@confluent.io> on 2017/02/03 23:33:20 UTC, 17 replies.
- [jira] [Assigned] (KAFKA-4733) Improve Streams Reset Tool console output - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2017/02/03 23:33:51 UTC, 0 replies.
- [GitHub] kafka pull request #2497: [MINOR] fixed some JavaDoc typos - posted by mjsax <gi...@git.apache.org> on 2017/02/03 23:45:00 UTC, 1 replies.
- [GitHub] kafka pull request #2498: MINOR: Make Kafka Connect step in quickstart more ... - posted by vahidhashemian <gi...@git.apache.org> on 2017/02/03 23:52:25 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4654) Improve test coverage MemoryLRUCache - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/04 00:35:52 UTC, 0 replies.
- [GitHub] kafka pull request #2499: KAFKA-4461 Added support to ProcessorTopologyTestD... - posted by amccague <gi...@git.apache.org> on 2017/02/04 02:17:29 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/04 02:17:52 UTC, 4 replies.
- [GitHub] kafka pull request #2500: KAFKA-4654 improve test coverage for MemoryLRUCach... - posted by bbejeck <gi...@git.apache.org> on 2017/02/04 02:44:22 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4654) Improve test coverage MemoryLRUCache - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/04 02:44:52 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4654) Improve test coverage MemoryLRUCache - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/04 02:45:51 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4734) timeindex on old segments not trimmed to actual size - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/02/04 03:21:52 UTC, 0 replies.
- [GitHub] kafka-site pull request #45: Manual edits needed for 0.10.2 release - posted by guozhangwang <gi...@git.apache.org> on 2017/02/04 03:54:39 UTC, 1 replies.
- [GitHub] kafka pull request #2501: KAFKA-4734; Trim the time index on old segments - posted by becketqin <gi...@git.apache.org> on 2017/02/04 06:39:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4734) timeindex on old segments not trimmed to actual size - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/02/04 07:59:51 UTC, 1 replies.
- [GitHub] kafka pull request #2502: Merge pull request #1 from apache/trunk - posted by PierreCoquentin <gi...@git.apache.org> on 2017/02/04 20:10:10 UTC, 1 replies.
- [GitHub] kafka pull request #2503: KAFKA-4733: Improve Streams Reset Tool console out... - posted by gwenshap <gi...@git.apache.org> on 2017/02/05 04:28:15 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4733) Improve Streams Reset Tool console output - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/05 04:28:42 UTC, 1 replies.
- [jira] [Created] (KAFKA-4735) Fix deadlock issue during MM shutdown - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/02/05 10:18:41 UTC, 0 replies.
- [GitHub] kafka pull request #2504: KAFKA-4735; Fix deadlock issue during MM shutdown - posted by lindong28 <gi...@git.apache.org> on 2017/02/05 10:20:03 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4735) Fix deadlock issue during MM shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/05 10:20:41 UTC, 1 replies.
- [GitHub] kafka pull request #2347: Initial commit of partition assignment check in co... - posted by asfgit <gi...@git.apache.org> on 2017/02/05 10:30:55 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4558) throttling_test fails if the producer starts too fast. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/05 10:34:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1250 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/05 11:15:03 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1251 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/05 14:52:09 UTC, 0 replies.
- [jira] [Created] (KAFKA-4736) producer failed too slow when meta request failed - posted by "Jun Yao (JIRA)" <ji...@apache.org> on 2017/02/05 19:03:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-4737) Streams apps hang if started when brokers are not available - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2017/02/06 00:53:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4737) Streams apps hang if started when brokers are not available - posted by "Umesh Chaudhary (JIRA)" <ji...@apache.org> on 2017/02/06 00:57:41 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-4737) Streams apps hang if started when brokers are not available - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2017/02/06 01:01:50 UTC, 0 replies.
- [GitHub] kafka pull request #2505: KAFKA-4276: Add REST configuration in connector pr... - posted by akhilesh1194 <gi...@git.apache.org> on 2017/02/06 06:04:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4276) REST configuration not visible in connector properties config files - posted by "Akhilesh Naidu (JIRA)" <ji...@apache.org> on 2017/02/06 07:50:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1101) Need better java api for embedding kafkaserver in a java container app - posted by "Enrico Olivelli (JIRA)" <ji...@apache.org> on 2017/02/06 08:12:41 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-4513) Support migration of old consumers to new consumers without downtime - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/02/06 09:27:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4715) Consumer/Producer config does not work with related enums - posted by "Mathias Kub (JIRA)" <ji...@apache.org> on 2017/02/06 13:22:42 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-4715) Consumer/Producer config does not work with related enums - posted by "Mathias Kub (JIRA)" <ji...@apache.org> on 2017/02/06 13:23:41 UTC, 0 replies.
- [GitHub] kafka pull request #2506: KAFKA-4703 Test with two SASL_SSL listeners with d... - posted by baluchicken <gi...@git.apache.org> on 2017/02/06 14:57:13 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4703) Test with two SASL_SSL listeners with different JAAS contexts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/06 14:57:41 UTC, 0 replies.
- [GitHub] kafka-site issue #45: Manual edits needed for 0.10.2 release - posted by guozhangwang <gi...@git.apache.org> on 2017/02/06 17:33:44 UTC, 5 replies.
- [jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/06 17:46:41 UTC, 4 replies.
- Request Wiki edit permission for stevenschlansker - posted by Steven Schlansker <st...@gmail.com> on 2017/02/06 18:02:08 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4264) kafka-server-stop.sh fails is Kafka launched via kafka-server-start.sh - posted by "Jeff Maxwell (JIRA)" <ji...@apache.org> on 2017/02/06 18:21:41 UTC, 0 replies.
- [GitHub] kafka pull request #2273: KAFKA-4555: Using Hamcrest for expressive intent i... - posted by rekhajoshm <gi...@git.apache.org> on 2017/02/06 18:32:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4555) Using Hamcrest for easy intent expression in tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/06 18:32:41 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4724) Clean up of state directories can possibly remove stores that are about to be used by another thread - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/06 19:04:41 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/06 19:36:41 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/06 19:38:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-4738) Remove generic type of class ClientState - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/06 19:57:41 UTC, 0 replies.
- [GitHub] kafka pull request #2325: KAFKA-4441 Monitoring incorrect during topic creat... - posted by asfgit <gi...@git.apache.org> on 2017/02/06 20:24:18 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/06 20:24:42 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/06 20:24:42 UTC, 0 replies.
- [GitHub] kafka pull request #2507: HOTFIX: Do Not use unlimited num messages - posted by guozhangwang <gi...@git.apache.org> on 2017/02/06 20:42:54 UTC, 1 replies.
- [jira] [Created] (KAFKA-4739) KafkaConsumer poll going into an infinite loop - posted by "Vipul Singh (JIRA)" <ji...@apache.org> on 2017/02/06 20:46:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4739) KafkaConsumer poll going into an infinite loop - posted by "Vipul Singh (JIRA)" <ji...@apache.org> on 2017/02/06 20:52:41 UTC, 5 replies.
- [jira] [Created] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop - posted by "Sébastien Launay (JIRA)" <ji...@apache.org> on 2017/02/06 20:58:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4739) KafkaConsumer poll going into an infinite loop - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/06 21:08:42 UTC, 11 replies.
- [jira] [Comment Edited] (KAFKA-4739) KafkaConsumer poll going into an infinite loop - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/06 21:09:41 UTC, 3 replies.
- [jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/06 21:32:42 UTC, 7 replies.
- [GitHub] kafka pull request #2508: MINOR: Fix import for streams broker compatibility... - posted by ewencp <gi...@git.apache.org> on 2017/02/06 21:38:02 UTC, 1 replies.
- Build failed in Jenkins: kafka-0.10.2-jdk7 #66 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/06 22:11:45 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4738) Remove generic type of class ClientState - posted by "Sharad (JIRA)" <ji...@apache.org> on 2017/02/06 23:14:41 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1252 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/06 23:44:11 UTC, 0 replies.
- Jenkins build is back to normal : kafka-0.10.2-jdk7 #67 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/07 00:17:42 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4735) Fix deadlock issue during MM shutdown - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/02/07 00:59:41 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4735) Fix deadlock issue during MM shutdown - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/02/07 01:01:34 UTC, 0 replies.
- Re: KIP-121 [Discuss]: Add KStream peek method - posted by "Matthias J. Sax" <ma...@confluent.io> on 2017/02/07 01:48:07 UTC, 8 replies.
- [jira] [Commented] (KAFKA-4731) Add event-based session windows - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/07 02:54:41 UTC, 1 replies.
- Re: [VOTE] KIP-109: Old Consumer Deprecation - posted by Gwen Shapira <gw...@confluent.io> on 2017/02/07 03:26:58 UTC, 3 replies.
- Streams: TTLCacheStore - posted by Elias Levy <fe...@gmail.com> on 2017/02/07 04:17:50 UTC, 3 replies.
- [jira] [Created] (KAFKA-4741) Memory leak in RecordAccumulator#append - posted by "Satish Duggana (JIRA)" <ji...@apache.org> on 2017/02/07 04:52:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4741) Memory leak in RecordAccumulator.append - posted by "Satish Duggana (JIRA)" <ji...@apache.org> on 2017/02/07 04:53:41 UTC, 0 replies.
- [GitHub] kafka pull request #2509: KAFKA-4741 Fix for buffer leaks in RecordAccumulat... - posted by satishd <gi...@git.apache.org> on 2017/02/07 04:58:49 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4741) Memory leak in RecordAccumulator.append - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/07 04:59:41 UTC, 2 replies.
- [GitHub] kafka pull request #2510: 0.9.0 - posted by rajatraj07 <gi...@git.apache.org> on 2017/02/07 05:09:55 UTC, 0 replies.
- Correct prefetching of data to KTable-like structure on application startup - posted by Jan Lukavský <je...@seznam.cz> on 2017/02/07 11:46:04 UTC, 8 replies.
- [GitHub] kafka pull request #2511: KAFKA-4567 - Connect Producer and Consumer ignore ... - posted by soenkeliebau <gi...@git.apache.org> on 2017/02/07 13:01:06 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4567) Connect Producer and Consumer ignore ssl parameters configured for worker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/07 13:01:41 UTC, 1 replies.
- [GitHub] kafka pull request #2183: Removed obsolete parameter form example config in ... - posted by soenkeliebau <gi...@git.apache.org> on 2017/02/07 14:43:07 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2122) Remove controller.message.queue.size Config - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/07 14:43:41 UTC, 2 replies.
- [GitHub] kafka pull request #2512: Removed obsolete parameter form example config in ... - posted by soenkeliebau <gi...@git.apache.org> on 2017/02/07 14:48:15 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-4686) Null Message payload is shutting down broker - posted by "Rodrigo Queiroz Saramago (JIRA)" <ji...@apache.org> on 2017/02/07 16:29:41 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-4727) A Production server configuration needs to be updated - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/07 16:41:42 UTC, 0 replies.
- [GitHub] kafka pull request #2513: WIP: Remove Struct from Request/Response classes - posted by ijuma <gi...@git.apache.org> on 2017/02/07 17:29:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4738) Remove generic type of class ClientState - posted by "Sharad (JIRA)" <ji...@apache.org> on 2017/02/07 18:57:41 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-4738) Remove generic type of class ClientState - posted by "Sharad (JIRA)" <ji...@apache.org> on 2017/02/07 18:58:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Brady Vidovic (JIRA)" <ji...@apache.org> on 2017/02/07 20:45:42 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4721) KafkaStreams (and possibly others) should inherit Closeable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/07 21:29:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-4742) ResetTool does not commit offsets correclty - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/07 22:14:42 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4697) Simplify Streams Reset Tool - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/07 22:28:41 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2017/02/07 22:51:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1255 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/07 23:12:51 UTC, 0 replies.
- [subscribe Request] - posted by Ashish Singh <as...@gmail.com> on 2017/02/08 00:15:35 UTC, 0 replies.
- Reg: Kafka Kerberos - posted by BigData dev <bi...@gmail.com> on 2017/02/08 00:25:32 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1919 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/08 00:58:54 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1256 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/08 01:47:35 UTC, 0 replies.
- [GitHub] kafka pull request #2514: MINOR: Add logging when commitSync fails in Stream... - posted by jmoney8080 <gi...@git.apache.org> on 2017/02/08 02:05:57 UTC, 1 replies.
- [jira] [Created] (KAFKA-4743) Add a tool to Reset Consumers Offsets - posted by "Jorge Quilcate (JIRA)" <ji...@apache.org> on 2017/02/08 02:32:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets - posted by "Jorge Quilcate (JIRA)" <ji...@apache.org> on 2017/02/08 02:38:41 UTC, 2 replies.
- KIP-122: Add a tool to Reset Consumer Group Offsets - posted by Jorge Esteban Quilcate Otoya <qu...@gmail.com> on 2017/02/08 02:43:16 UTC, 30 replies.
- [jira] [Assigned] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/08 05:31:41 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4733) Improve Streams Reset Tool console output - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/08 08:09:42 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1920 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/08 10:08:27 UTC, 0 replies.
- [GitHub] kafka pull request #2516: MINOR: add GlobalKTable doc to streams.html - posted by dguy <gi...@git.apache.org> on 2017/02/08 10:17:24 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1257 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/08 10:22:47 UTC, 0 replies.
- Re: [DISCUSS] KIP-84: Support SASL/SCRAM mechanisms - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/08 10:30:26 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4741) Memory leak in RecordAccumulator.append - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/08 13:38:41 UTC, 0 replies.
- FINAL REMINDER: CFP for ApacheCon closes February 11th - posted by Rich Bowen <rb...@apache.org> on 2017/02/08 14:09:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4741) Memory leak in RecordAccumulator.append - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/08 14:38:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-4744) Streams_bounce test failing occassionally - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/08 15:00:48 UTC, 0 replies.
- [GitHub] kafka pull request #2517: HOTFIX: renamed test so it is picked up by ducktap... - posted by enothereska <gi...@git.apache.org> on 2017/02/08 15:55:14 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1258 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/08 16:42:04 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/08 18:36:42 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4462) Improved Kafka Client Compatibility Policy - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/08 18:37:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4506) Refactor AbstractRequest to contain version information - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/08 18:37:41 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1921 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/08 18:38:18 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4195) support throttling on request rate - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/08 19:13:42 UTC, 1 replies.
- [jira] [Created] (KAFKA-4745) KafkaLZ4BlockOutputStream.java incorrectly finishes the last frame - posted by "Will Droste (JIRA)" <ji...@apache.org> on 2017/02/08 19:24:41 UTC, 0 replies.
- [GitHub] kafka pull request #2451: KAFKA-4648: Improve test coverage StreamTask - posted by asfgit <gi...@git.apache.org> on 2017/02/08 19:27:38 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4648) Improve test coverage StreamTask - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/08 19:27:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4648) Improve test coverage StreamTask - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/08 19:27:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4745) KafkaLZ4BlockOutputStream.java incorrectly finishes the last frame - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/08 19:30:41 UTC, 4 replies.
- [jira] [Updated] (KAFKA-4716) Fix logic for re-checking if internal topic is ready - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/08 19:34:41 UTC, 4 replies.
- [jira] [Commented] (KAFKA-4716) Fix logic for re-checking if internal topic is ready - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/08 19:34:41 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-4745) KafkaLZ4BlockOutputStream.java incorrectly finishes the last frame - posted by "Will Droste (JIRA)" <ji...@apache.org> on 2017/02/08 19:41:41 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4702) Parametrize streams benchmarks to run at scale - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/08 21:06:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-4746) Offsets can be committed for the offsets topic - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2017/02/08 21:52:41 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1922 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/08 22:12:50 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1259 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/08 22:52:17 UTC, 0 replies.
- [jira] [Created] (KAFKA-4747) add metrics for KafkaConsumer.poll - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/02/08 22:56:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4746) Offsets can be committed for the offsets topic - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/08 23:01:41 UTC, 2 replies.
- [jira] [Created] (KAFKA-4748) Need a way to shutdown all workers in a Streams application at the same time - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/02/08 23:38:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1260 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/09 00:39:06 UTC, 0 replies.
- KIP-121 [VOTE]: Add KStream peek method - posted by Steven Schlansker <ss...@opentable.com> on 2017/02/09 00:45:54 UTC, 14 replies.
- [GitHub] kafka pull request #2518: KAFKA-4747: add metrics for KafkaConsumer.poll - posted by onurkaraman <gi...@git.apache.org> on 2017/02/09 00:56:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4747) add metrics for KafkaConsumer.poll - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/09 00:56:41 UTC, 0 replies.
- [GitHub] kafka pull request #2519: MINOR: changes to the production broker configurat... - posted by alexlod <gi...@git.apache.org> on 2017/02/09 00:56:59 UTC, 1 replies.
- [jira] [Created] (KAFKA-4749) fix join-time-max and sync-time-max MeasurableStat type - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/02/09 01:08:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4749) fix join-time-max and sync-time-max MeasurableStat type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/09 01:10:41 UTC, 1 replies.
- [GitHub] kafka pull request #2520: KAFKA-4749: fix join-time-max and sync-time-max Me... - posted by onurkaraman <gi...@git.apache.org> on 2017/02/09 01:10:42 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4749) fix join-time-max and sync-time-max MeasurableStat type - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/09 02:42:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1261 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/09 02:59:31 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1262 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/09 03:58:34 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4709) Error message from Struct.validate() should include the name of the offending field. - posted by "Tegan Snyder (JIRA)" <ji...@apache.org> on 2017/02/09 04:52:41 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-4716) Fix logic for re-checking if internal topic is ready - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/09 07:43:42 UTC, 0 replies.
- [GitHub] kafka pull request #2521: KAFKA-4709：Error message from Struct.validate() ... - posted by Aegeaner <gi...@git.apache.org> on 2017/02/09 08:34:11 UTC, 1 replies.
- [GitHub] kafka pull request #2522: KAFKA-4716: Send request to controller [WiP] - posted by enothereska <gi...@git.apache.org> on 2017/02/09 10:44:24 UTC, 0 replies.
- [jira] [Work started] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/09 11:15:42 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/09 11:15:42 UTC, 0 replies.
- [GitHub] kafka pull request #2523: MINOR: fix integer overflow in simple benchmark MB... - posted by dguy <gi...@git.apache.org> on 2017/02/09 11:31:20 UTC, 1 replies.
- [jira] [Created] (KAFKA-4750) KeyValueIterator returns null values - posted by "Michal Borowiecki (JIRA)" <ji...@apache.org> on 2017/02/09 11:58:41 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4195) support throttling on request rate - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/09 12:47:41 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4195) support throttling on request rate - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/09 12:47:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-4751) kafka-clients-0.9.0.2.4.2.11-1 issue not throwing exception. - posted by "Avinash Kumar Gaur (JIRA)" <ji...@apache.org> on 2017/02/09 13:30:41 UTC, 0 replies.
- Old producer slow/no recovery on broker failure - posted by Thomas Becker <to...@Tivo.com> on 2017/02/09 14:09:54 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4751) kafka-clients-0.9.0.2.4.2.11-1 issue not throwing exception. - posted by "Manikumar Reddy (JIRA)" <ji...@apache.org> on 2017/02/09 14:13:41 UTC, 0 replies.
- [GitHub] kafka pull request #2524: HOTFIX: default params missin - posted by enothereska <gi...@git.apache.org> on 2017/02/09 14:14:28 UTC, 0 replies.
- [jira] [Created] (KAFKA-4752) Streams Simple Benchmark MB/sec calculation is not correct for Join operations - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/09 14:17:41 UTC, 0 replies.
- [GitHub] kafka pull request #2525: KAFKA-4484: Set more conservative default values o... - posted by dguy <gi...@git.apache.org> on 2017/02/09 14:37:07 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/09 14:37:41 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/09 14:42:41 UTC, 1 replies.
- [jira] [Work started] (KAFKA-4716) Fix logic for re-checking if internal topic is ready - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/09 14:42:42 UTC, 0 replies.
- [jira] [Work stopped] (KAFKA-4716) Fix logic for re-checking if internal topic is ready - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/09 14:42:42 UTC, 0 replies.
- [GitHub] kafka pull request #2526: KAFKA-4716: Fix case when controller cannot be rea... - posted by enothereska <gi...@git.apache.org> on 2017/02/09 14:48:27 UTC, 1 replies.
- [GitHub] kafka pull request #2524: HOTFIX: default params missing - posted by asfgit <gi...@git.apache.org> on 2017/02/09 15:14:23 UTC, 0 replies.
- [VOTE] KIP-118: Drop Support for Java 7 in Kafka 0.11 - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/09 15:31:53 UTC, 16 replies.
- [GitHub] kafka pull request #2527: MINOR: update README with how to run code coverage... - posted by dguy <gi...@git.apache.org> on 2017/02/09 15:48:20 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1448) Filter-plugins for messages - posted by "Mileta Cekovic (JIRA)" <ji...@apache.org> on 2017/02/09 17:02:41 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1263 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/09 17:21:26 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2507) Replace ControlledShutdown{Request,Response} with org.apache.kafka.common.requests equivalent - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2017/02/09 17:33:42 UTC, 1 replies.
- [GitHub] kafka pull request #2528: KAFKA-4745 -Optimize close to remove unnecessary f... - posted by wdroste <gi...@git.apache.org> on 2017/02/09 18:03:22 UTC, 0 replies.
- [jira] [Created] (KAFKA-4753) KafkaConsumer susceptible to FetchResponse starvation - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/02/09 21:29:41 UTC, 0 replies.
- [GitHub] kafka pull request #2522: KAFKA-4716: Send request to controller - posted by asfgit <gi...@git.apache.org> on 2017/02/09 22:02:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4753) KafkaConsumer susceptible to FetchResponse starvation - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/02/09 23:08:42 UTC, 6 replies.
- documentation feedback - posted by Brian Cornally <bc...@objectsharp.com> on 2017/02/09 23:21:36 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1264 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/09 23:21:57 UTC, 0 replies.
- [GitHub] kafka-site pull request #46: Fix routing bugs - posted by derrickdoo <gi...@git.apache.org> on 2017/02/09 23:52:19 UTC, 0 replies.
- [GitHub] kafka-site issue #46: Fix routing bugs - posted by derrickdoo <gi...@git.apache.org> on 2017/02/09 23:53:34 UTC, 2 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1265 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/10 02:02:35 UTC, 0 replies.
- [jira] [Created] (KAFKA-4754) Correctly parse '=' characters in command line overrides - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2017/02/10 02:25:41 UTC, 0 replies.
- [GitHub] kafka pull request #2382: KAFKA-4617: Generate core project with correct sou... - posted by asfgit <gi...@git.apache.org> on 2017/02/10 02:46:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/10 02:46:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/10 02:46:41 UTC, 0 replies.
- [GitHub] kafka pull request #2246: KAFKA-4525: Kafka should not require SSL trust sto... - posted by asfgit <gi...@git.apache.org> on 2017/02/10 03:02:24 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4525) Kafka should not require SSL trust store password - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/10 03:02:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4754) Correctly parse '=' characters in command line overrides - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2017/02/10 03:03:41 UTC, 5 replies.
- [GitHub] kafka pull request #2529: KAFKA-4754: Correctly parse '=' characters in comm... - posted by granthenke <gi...@git.apache.org> on 2017/02/10 03:17:37 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4754) Correctly parse '=' characters in command line overrides - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2017/02/10 03:18:41 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4731) Add event-based session windows - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/10 03:19:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2292) failed fetch request logging doesn't indicate source of request - posted by "Mathieu Filotto (JIRA)" <ji...@apache.org> on 2017/02/10 04:58:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2143) Replicas get ahead of leader and fail - posted by "Mathieu Filotto (JIRA)" <ji...@apache.org> on 2017/02/10 04:59:41 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2143) Replicas get ahead of leader and fail - posted by "Mathieu Filotto (JIRA)" <ji...@apache.org> on 2017/02/10 05:02:41 UTC, 0 replies.
- [GitHub] kafka pull request #2475: MINOR: Use an explicit `Errors` object when possib... - posted by asfgit <gi...@git.apache.org> on 2017/02/10 05:22:27 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2260) Allow specifying expected offset on produce - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/10 06:31:43 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4076) Kafka broker shuts down due to irrecoverable IO error - posted by "Manikumar Reddy (JIRA)" <ji...@apache.org> on 2017/02/10 07:49:41 UTC, 0 replies.
- [GitHub] kafka pull request #2530: MINOR: Replacing for with foreach loop in common m... - posted by PKOfficial <gi...@git.apache.org> on 2017/02/10 08:11:00 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1266 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/10 08:12:44 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "Sinóros-Szabó Péter (JIRA)" <ji...@apache.org> on 2017/02/10 09:04:42 UTC, 11 replies.
- Messages not received (C/C++ client) - posted by 飘落 <sk...@qq.com> on 2017/02/10 09:50:37 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4525) Kafka should not require SSL trust store password - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/10 10:11:41 UTC, 0 replies.
- [GitHub] kafka pull request #2531: WIP: KIP-1610: Review usages of Map#mapValues. - posted by jozi-k <gi...@git.apache.org> on 2017/02/10 10:41:54 UTC, 0 replies.
- [jira] [Created] (KAFKA-4755) SimpleBenchmark consume test fails for streams - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/10 10:45:42 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4755) SimpleBenchmark consume test fails for streams - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/10 10:46:41 UTC, 0 replies.
- [GitHub] kafka pull request #2532: MINOR: update KafkaStreams.metadataForKey(...) jav... - posted by dguy <gi...@git.apache.org> on 2017/02/10 10:47:47 UTC, 1 replies.
- [GitHub] kafka pull request #2533: Checking the Timestamp is insufficient - posted by rnpridgeon <gi...@git.apache.org> on 2017/02/10 11:22:23 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4430) Broker logging "Topic and partition to exceptions: [topic,6] -> kafka.common.MessageSizeTooLargeException" - posted by "Jozef Koval (JIRA)" <ji...@apache.org> on 2017/02/10 11:58:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1267 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/10 14:13:19 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests - posted by "Jozef Koval (JIRA)" <ji...@apache.org> on 2017/02/10 14:51:41 UTC, 0 replies.
- [GitHub] kafka pull request #2534: Update SimpleAclAuthorizer.scala - posted by cotedm <gi...@git.apache.org> on 2017/02/10 15:34:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4755) SimpleBenchmark consume test fails for streams - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/10 16:13:41 UTC, 0 replies.
- [VOTE] 0.10.2.0 RC1 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/10 16:51:20 UTC, 14 replies.
- [jira] [Created] (KAFKA-4756) The auto-generated broker id should be passed to MetricReporter.configure - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/10 17:10:41 UTC, 0 replies.
- [GitHub] kafka pull request #2535: MINOR: don't throw CommitFailedException during su... - posted by dguy <gi...@git.apache.org> on 2017/02/10 17:55:59 UTC, 1 replies.
- Is it possible to receive duplicate messages from Kafka when... - posted by "Michaud, Ben A" <be...@optum.com> on 2017/02/10 18:40:05 UTC, 1 replies.
- [GitHub] kafka pull request #2536: MINOR: Move compression stream construction into C... - posted by hachikuji <gi...@git.apache.org> on 2017/02/10 18:46:10 UTC, 1 replies.
- [jira] [Created] (KAFKA-4757) NetworkClient trace level logging regressions - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/02/10 18:57:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4714) Implement remaining KIP-66 SMTs - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/10 19:06:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.2-jdk7 #75 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/10 19:28:43 UTC, 0 replies.
- [GitHub] kafka pull request #2537: MINOR: Improve LogCleaner buffer size change loggi... - posted by cotedm <gi...@git.apache.org> on 2017/02/10 19:40:36 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4430) Broker logging "Topic and partition to exceptions: [topic,6] -> kafka.common.MessageSizeTooLargeException" - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2017/02/10 20:06:41 UTC, 0 replies.
- [GitHub] kafka pull request #2538: KAFKA-2857: Retry querying the consumer group whil... - posted by vahidhashemian <gi...@git.apache.org> on 2017/02/10 20:09:00 UTC, 0 replies.
- [GitHub] kafka pull request #2539: MINOR: Fix quickstart in docs - posted by vahidhashemian <gi...@git.apache.org> on 2017/02/10 20:20:16 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1268 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/10 20:43:42 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4144) Allow per stream/table timestamp extractor - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/10 22:08:42 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1] - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/10 22:38:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1269 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/11 00:46:50 UTC, 0 replies.
- [GitHub] kafka pull request #2540: KAFKA-4756: The auto-generated broker id should be... - posted by cmccabe <gi...@git.apache.org> on 2017/02/11 01:04:07 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4756) The auto-generated broker id should be passed to MetricReporter.configure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/11 01:04:41 UTC, 2 replies.
- Jenkins build is back to normal : kafka-0.10.2-jdk7 #76 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/11 01:20:04 UTC, 0 replies.
- Request to add to Contributor list - posted by Kamal C <ka...@gmail.com> on 2017/02/11 15:10:44 UTC, 1 replies.
- [jira] [Created] (KAFKA-4758) Connect WorkerSinkTask is missing checks for NO_TIMESTAMP - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/11 19:39:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-4759) Add support for subnet masks in SimpleACLAuthorizer - posted by "Shun Takebayashi (JIRA)" <ji...@apache.org> on 2017/02/12 01:21:42 UTC, 0 replies.
- [GitHub] kafka pull request #2541: KAFKA-4759: Add support for subnet masks in Simple... - posted by takebayashi <gi...@git.apache.org> on 2017/02/12 01:26:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4759) Add support for subnet masks in SimpleACLAuthorizer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/12 01:26:41 UTC, 0 replies.
- [GitHub] kafka pull request #2071: KAFKA-4340: Change default message.timestamp.diffe... - posted by asfgit <gi...@git.apache.org> on 2017/02/12 05:34:47 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4340) Change the default value of log.message.timestamp.difference.max.ms to the same as log.retention.ms - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/12 05:35:42 UTC, 5 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1270 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/12 06:12:24 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3531) support subnet in ACL tool - posted by "Manikumar Reddy (JIRA)" <ji...@apache.org> on 2017/02/12 06:48:42 UTC, 0 replies.
- [GitHub] kafka pull request #2542: MINOR: Stream metrics documentation - posted by enothereska <gi...@git.apache.org> on 2017/02/12 10:46:28 UTC, 1 replies.
- [GitHub] kafka pull request #2534: MINOR: Update SimpleAclAuthorizer.scala - posted by asfgit <gi...@git.apache.org> on 2017/02/12 15:11:16 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4652) Improve test coverage KStreamBuilder - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/12 17:21:42 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4652) Improve test coverage KStreamBuilder - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/12 17:22:41 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1271 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/12 17:52:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1] - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/12 18:49:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4758) Connect WorkerSinkTask is missing checks for NO_TIMESTAMP - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/13 00:07:41 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4758) Connect WorkerSinkTask is missing checks for NO_TIMESTAMP - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/13 00:07:41 UTC, 0 replies.
- [GitHub] kafka pull request #2533: KAFKA-4758: Checking the TimestampType is insuffic... - posted by asfgit <gi...@git.apache.org> on 2017/02/13 00:07:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1272 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/13 00:59:14 UTC, 0 replies.
- [GitHub] kafka pull request #2543: MINOR: Remove unused MessageWriter - posted by hachikuji <gi...@git.apache.org> on 2017/02/13 02:02:28 UTC, 0 replies.
- KafkaStream Run on 0.9.0.1 - posted by Abhinav Patil <ab...@gmail.com> on 2017/02/13 07:00:53 UTC, 1 replies.
- [GitHub] kafka pull request #2544: KFKA-4340: update the upgrade.html - posted by becketqin <gi...@git.apache.org> on 2017/02/13 10:13:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-4760) Restarting one MirrorMaker causes a global pause in mirroring. - posted by "Tomasz Gański (JIRA)" <ji...@apache.org> on 2017/02/13 12:33:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4760) Restarting one MirrorMaker causes a global pause in mirroring. - posted by "Tomasz Gański (JIRA)" <ji...@apache.org> on 2017/02/13 12:34:41 UTC, 7 replies.
- [jira] [Created] (KAFKA-4761) NullPointerException if batch.size=0 for producer config - posted by "Swen Moczarski (JIRA)" <ji...@apache.org> on 2017/02/13 17:30:41 UTC, 0 replies.
- [jira] [Work started] (KAFKA-4494) Significant startup delays in KStreams app - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/13 17:31:41 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4494) Significant startup delays in KStreams app - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/13 17:31:41 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4761) NullPointerException if batch.size=0 for producer config - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/13 17:51:43 UTC, 0 replies.
- [jira] [Work started] (KAFKA-4761) NullPointerException if batch.size=0 for producer config - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/13 18:00:45 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1379) Partition reassignment resets clock for time-based retention - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/02/13 18:10:41 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1379) Partition reassignment resets clock for time-based retention - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/02/13 18:43:41 UTC, 0 replies.
- [GitHub] kafka pull request #2545: KAFKA-4671: Fix producer regression handling small... - posted by hachikuji <gi...@git.apache.org> on 2017/02/13 19:17:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4671) Fix Streams window retention policy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/13 19:17:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4761) NullPointerException if batch.size=0 for producer config - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/13 19:20:41 UTC, 3 replies.
- Re: Need suggestion on sending XML files via kafka - posted by Prashanth Venkatesan <pr...@gmail.com> on 2017/02/13 19:36:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4762) Consumer throwing RecordTooLargeException even when messages are not that large - posted by "Vipul Singh (JIRA)" <ji...@apache.org> on 2017/02/13 19:43:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/02/13 19:59:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3264) Mark the old Scala consumer and related classes as deprecated - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/02/13 20:00:43 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4762) Consumer throwing RecordTooLargeException even when messages are not that large - posted by "Vipul Singh (JIRA)" <ji...@apache.org> on 2017/02/13 21:14:41 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-4756) The auto-generated broker id should be passed to MetricReporter.configure - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/13 21:47:42 UTC, 0 replies.
- [GitHub] kafka pull request #2545: KAFKA-4761: Fix producer regression handling small... - posted by asfgit <gi...@git.apache.org> on 2017/02/13 22:09:31 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4761) NullPointerException if batch.size=0 for producer config - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/13 22:09:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-4763) Handle disk failure for JBOD (KIP-112) - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/02/13 22:30:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4762) Consumer throwing RecordTooLargeException even when messages are not that large - posted by "huxi (JIRA)" <ji...@apache.org> on 2017/02/14 03:17:41 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-4542) Add authentication based on delegation token. - posted by "Manikumar Reddy (JIRA)" <ji...@apache.org> on 2017/02/14 07:32:41 UTC, 0 replies.
- Request for JIRA access - posted by Thomas Dutta <th...@gmail.com> on 2017/02/14 08:35:18 UTC, 0 replies.
- kafka consumer coordinator is unknown issue - posted by "Ashwini Mhatre (asmhatre)" <as...@cisco.com> on 2017/02/14 09:10:44 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "Prasanna Gautam (JIRA)" <ji...@apache.org> on 2017/02/14 09:49:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-4764) Improve diagnostics for SASL authentication failures - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/02/14 12:42:41 UTC, 0 replies.
- [GitHub] kafka pull request #2546: KAFKA-4764: Improve diagnostics for SASL auth fail... - posted by rajinisivaram <gi...@git.apache.org> on 2017/02/14 14:58:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4764) Improve diagnostics for SASL authentication failures - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/14 14:58:42 UTC, 0 replies.
- [GitHub] kafka pull request #2547: MINOR: add session windows doc to streams.html - posted by dguy <gi...@git.apache.org> on 2017/02/14 16:20:55 UTC, 1 replies.
- get function - posted by Samy CHBINOU <sa...@greenflops.com> on 2017/02/14 16:42:50 UTC, 1 replies.
- Request Wiki edit permission for mfenniak - posted by Mathieu Fenniak <ma...@replicon.com> on 2017/02/14 16:51:29 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level - posted by "Stephen Durfey (JIRA)" <ji...@apache.org> on 2017/02/14 17:00:43 UTC, 1 replies.
- [VOTE] KIP-82 Add Record Headers - posted by Michael Pearce <Mi...@ig.com> on 2017/02/14 17:42:36 UTC, 6 replies.
- [VOTE] 0.10.2.0 RC2 - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/14 18:39:59 UTC, 7 replies.
- [jira] [Commented] (KAFKA-4277) creating ephemeral node already exist - posted by "Wrikken (JIRA)" <ji...@apache.org> on 2017/02/14 19:15:41 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-4277) creating ephemeral node already exist - posted by "Wrikken (JIRA)" <ji...@apache.org> on 2017/02/14 19:16:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1938 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/14 20:58:15 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1274 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/14 21:57:39 UTC, 0 replies.
- [GitHub] kafka pull request #2549: Add subtree .gitignore files themselves to gitigno... - posted by stevenschlansker <gi...@git.apache.org> on 2017/02/14 22:06:53 UTC, 0 replies.
- [GitHub] kafka pull request #2550: KAFKA-4665: Normalize handling of non-existing top... - posted by vahidhashemian <gi...@git.apache.org> on 2017/02/14 22:32:14 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/14 22:32:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/02/14 23:55:42 UTC, 0 replies.
- [DISCUSS] KIP-123: Allow per stream/table timestamp extractor - posted by Jeyhun Karimov <je...@gmail.com> on 2017/02/15 00:31:37 UTC, 10 replies.
- [jira] [Created] (KAFKA-4765) org.apache.kafka.clients.producer.KafkaProducerTest#testConstructorFailureCloseResource and Similar Tests are Failing on some Systems (127.0.53.53 Collision Warning) - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/15 07:56:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4765) org.apache.kafka.clients.producer.KafkaProducerTest#testConstructorFailureCloseResource and Similar Tests are Failing on some Systems (127.0.53.53 Collision Warning) - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/15 07:56:41 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4765) org.apache.kafka.clients.producer.KafkaProducerTest#testConstructorFailureCloseResource and Similar Tests are Failing on some Systems (127.0.53.53 Collision Warning) - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/15 08:13:41 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-4762) Consumer throwing RecordTooLargeException even when messages are not that large - posted by "huxi (JIRA)" <ji...@apache.org> on 2017/02/15 09:18:42 UTC, 1 replies.
- [jira] [Created] (KAFKA-4766) Document lz4 and lz4hc in confluence - posted by "Daniel Pinyol (JIRA)" <ji...@apache.org> on 2017/02/15 11:40:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4767) KafkaProducer is not joining the thread properly - posted by "Buğra Gedik (JIRA)" <ji...@apache.org> on 2017/02/15 12:10:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-4767) KafkaProducer is not joining the thread properly - posted by "Buğra Gedik (JIRA)" <ji...@apache.org> on 2017/02/15 12:10:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4767) KafkaProducer is not joining its IO thread properly - posted by "Buğra Gedik (JIRA)" <ji...@apache.org> on 2017/02/15 12:11:41 UTC, 1 replies.
- [jira] [Work started] (KAFKA-4752) Streams Simple Benchmark MB/sec calculation is not correct for Join operations - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/15 13:02:41 UTC, 0 replies.
- [GitHub] kafka pull request #2551: KAFKA-4752: Fixed bandwidth calculation - posted by enothereska <gi...@git.apache.org> on 2017/02/15 13:45:32 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4752) Streams Simple Benchmark MB/sec calculation is not correct for Join operations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/15 13:45:41 UTC, 1 replies.
- [jira] [Created] (KAFKA-4768) Single-request latency for streams can be very high - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/15 14:20:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4768) Single-request latency for streams can be very high - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/15 14:36:41 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4768) Single-request latency for streams can be very high - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/15 14:37:41 UTC, 0 replies.
- Cannot start up Kafka Server within Java - posted by Stefan Kölbl <ko...@gmx.at> on 2017/02/15 15:27:49 UTC, 2 replies.
- [GitHub] kafka pull request #2552: KAFKA-4765: Fixed Intentionally Broken Hosts Resol... - posted by original-brownbear <gi...@git.apache.org> on 2017/02/15 18:12:28 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-4765) org.apache.kafka.clients.producer.KafkaProducerTest#testConstructorFailureCloseResource and Similar Tests are Failing on some Systems (127.0.53.53 Collision Warning) - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/15 18:15:42 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3893) Kafka Broker ID disappears from /brokers/ids - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/15 18:47:42 UTC, 0 replies.
- Reg: Kafka HDFS Connector with (HDFS SSL enabled) - posted by BigData dev <bi...@gmail.com> on 2017/02/15 19:03:39 UTC, 0 replies.
- [GitHub] kafka pull request #2492: HOTFIX: fixed section incompatible Steams API chan... - posted by asfgit <gi...@git.apache.org> on 2017/02/15 21:18:31 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4340) Change the default value of log.message.timestamp.difference.max.ms to the same as log.retention.ms - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/02/15 23:06:41 UTC, 0 replies.
- [GitHub] kafka pull request #2553: MINOR: fix indention in

 tags - posted by mjsax <gi...@git.apache.org> on 2017/02/16 00:51:51 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly - posted by "huxi (JIRA)" <ji...@apache.org> on 2017/02/16 01:29:41 UTC, 7 replies.

- Re: [kafka-clients] [VOTE] 0.10.2.0 RC2 - posted by Jun Rao <ju...@confluent.io> on 2017/02/16 02:04:12 UTC, 2 replies.

- Jenkins build is back to normal : kafka-trunk-jdk7 #1940 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/16 02:05:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4766) Document lz4 and lz4hc in confluence - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2017/02/16 03:42:41 UTC, 2 replies.

- [jira] [Resolved] (KAFKA-4720) Add KStream.peek(ForeachAction) - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/16 05:20:41 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4720) Add KStream.peek(ForeachAction) - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/16 05:23:42 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-4767) KafkaProducer is not joining its IO thread properly - posted by "Buğra Gedik (JIRA)" <ji...@apache.org> on 2017/02/16 05:26:41 UTC, 7 replies.

- [jira] [Created] (KAFKA-4769) Add Float serializer, deserializer, serde - posted by "Michael Noll (JIRA)" <ji...@apache.org> on 2017/02/16 05:33:41 UTC, 0 replies.

- [GitHub] kafka pull request #2554: KAFKA-4769: Add Float serializer, deserializer, se... - posted by miguno <gi...@git.apache.org> on 2017/02/16 05:54:34 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4769) Add Float serializer, deserializer, serde - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/16 05:54:41 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4769) Add Float serializer, deserializer, serde - posted by "Michael Noll (JIRA)" <ji...@apache.org> on 2017/02/16 05:55:41 UTC, 0 replies.

- Kafka  exception - posted by 揣立武 <ch...@meituan.com> on 2017/02/16 06:29:25 UTC, 1 replies.

- Jenkins build is back to normal : kafka-trunk-jdk8 #1277 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/16 08:55:35 UTC, 0 replies.

- [jira] [Created] (KAFKA-4770) KStreamAggregationDedupIntegrationTest fails occasionally - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/16 11:29:41 UTC, 0 replies.

- [GitHub] kafka pull request #2555: Javadoc typo - posted by astubbs <gi...@git.apache.org> on 2017/02/16 12:00:53 UTC, 0 replies.

- [jira] [Created] (KAFKA-4771) NPEs in KerberosLogin due to autoboxing - posted by "Colm O hEigeartaigh (JIRA)" <ji...@apache.org> on 2017/02/16 15:48:41 UTC, 0 replies.

- Apache Kafka Docker official image - posted by Gianluca Privitera <gi...@yahoo.com.INVALID> on 2017/02/16 16:04:21 UTC, 2 replies.

- [GitHub] kafka pull request #2556: KAFKA-4771 - NPEs in KerberosLogin due to autoboxi... - posted by coheigea <gi...@git.apache.org> on 2017/02/16 16:39:49 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4771) NPEs in KerberosLogin due to autoboxing - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/16 16:40:41 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level - posted by "Stephen Durfey (JIRA)" <ji...@apache.org> on 2017/02/16 17:01:41 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level - posted by "Stephen Durfey (JIRA)" <ji...@apache.org> on 2017/02/16 17:01:41 UTC, 0 replies.

- [jira] [Created] (KAFKA-4772) Exploit #peek to implement #print() and other methods - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/16 17:38:41 UTC, 0 replies.

- [jira] [Created] (KAFKA-4773) The Kafka build should run findbugs - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/16 19:48:41 UTC, 0 replies.

- [GitHub] kafka pull request #2557: KAFKA-4773: The Kafka build should run findbugs - posted by cmccabe <gi...@git.apache.org> on 2017/02/16 19:50:52 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4773) The Kafka build should run findbugs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/16 19:51:41 UTC, 1 replies.

- [jira] [Work started] (KAFKA-4773) The Kafka build should run findbugs - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/16 19:51:41 UTC, 0 replies.

- [jira] [Created] (KAFKA-4774) Inner classes which don't need a reference to the outer class should be static - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/16 21:09:50 UTC, 0 replies.

- [GitHub] kafka pull request #2558: KAFKA-4774. Inner classes which don't need a refer... - posted by cmccabe <gi...@git.apache.org> on 2017/02/16 21:10:50 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4774) Inner classes which don't need a reference to the outer class should be static - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/16 21:11:41 UTC, 1 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1278 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/16 21:13:40 UTC, 0 replies.

- [jira] [Created] (KAFKA-4775) Fix findbugs warnings in kafka-tools - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/16 21:44:41 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4709) Error message from Struct.validate() should include the name of the offending field. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/16 21:44:41 UTC, 0 replies.

- [GitHub] kafka pull request #2559: KAFKA-4775. Fix findbugs warnings in kafka-tools - posted by cmccabe <gi...@git.apache.org> on 2017/02/16 21:45:48 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4775) Fix findbugs warnings in kafka-tools - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/16 21:46:41 UTC, 1 replies.

- [jira] [Created] (KAFKA-4776) Implement graceful handling for improperly formed compressed message sets - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/16 23:16:41 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1279 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/16 23:47:34 UTC, 0 replies.

- [GitHub] kafka pull request #2560: KAFKA-4494: Reduce startup and rebalance time - posted by dguy <gi...@git.apache.org> on 2017/02/17 00:04:20 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4494) Significant startup delays in KStreams app - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/17 00:04:41 UTC, 1 replies.

- Should InvalidTopicException be called IllegalTopicException - posted by Cosmin Lehene <cl...@adobe.com> on 2017/02/17 00:29:14 UTC, 2 replies.

- [GitHub] kafka pull request #2561: MINOR: Fix possible NPE in NodeApiVersions.toStrin... - posted by hachikuji <gi...@git.apache.org> on 2017/02/17 00:38:07 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1280 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/17 01:01:02 UTC, 0 replies.

- Would kafka support delay queue in the future - posted by "Steven,Zhang(vip.com)" <st...@vipshop.com> on 2017/02/17 03:20:00 UTC, 0 replies.

- [GitHub] kafka pull request #2562: MINOR: Update docstring for "offsets.retention.min... - posted by omkreddy <gi...@git.apache.org> on 2017/02/17 06:05:37 UTC, 0 replies.

- Request to add to contributor list - posted by Shun Takebayashi <sh...@takebayashi.asia> on 2017/02/17 07:01:31 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-4775) Fix findbugs warnings in kafka-tools - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/17 09:53:42 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4676) Kafka consumers gets stuck for some partitions - posted by "Narendra Kumar (JIRA)" <ji...@apache.org> on 2017/02/17 10:32:41 UTC, 2 replies.

- [GitHub] kafka pull request #2544: KFKA-4340: follow up patch for KAFAK-4340 - posted by asfgit <gi...@git.apache.org> on 2017/02/17 10:41:57 UTC, 0 replies.

- Kafka Connect / Access to OffsetStorageReader from SourceConnector - posted by Florian Hussonnois <fh...@gmail.com> on 2017/02/17 12:45:53 UTC, 4 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1281 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/17 12:52:22 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk7 #1947 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/17 13:25:00 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1282 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/17 13:41:12 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-4754) Correctly parse '=' characters in command line overrides - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/17 17:02:41 UTC, 1 replies.

- [DISCUSS] KIP-124: Request rate quotas - posted by Rajini Sivaram <ra...@gmail.com> on 2017/02/17 17:05:33 UTC, 37 replies.

- [jira] [Updated] (KAFKA-4757) NetworkClient should log request details at trace level when a request is cancelled because of disconnection - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/17 17:38:41 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4757) NetworkClient should log request details at trace level when a request is cancelled because of disconnection - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/17 17:39:41 UTC, 3 replies.

- [jira] [Assigned] (KAFKA-4757) NetworkClient should log request details at trace level when a request is cancelled because of disconnection - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/17 17:39:41 UTC, 0 replies.

- Request Wiki edit permission for cshannon - posted by Christopher Shannon <ch...@gmail.com> on 2017/02/17 18:20:08 UTC, 2 replies.

- [jira] [Created] (KAFKA-4777) Kafka client Heartbeat thread use all the cpu. - posted by "Allen Xiang (JIRA)" <ji...@apache.org> on 2017/02/17 18:32:41 UTC, 0 replies.

- [GitHub] kafka pull request #2563: Kafka 4757: NetworkClient should log request detai... - posted by cmccabe <gi...@git.apache.org> on 2017/02/17 19:38:36 UTC, 1 replies.

- [jira] [Updated] (KAFKA-4757) Improve NetworkClient trace logging of request details - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/17 19:43:41 UTC, 2 replies.

- [jira] [Commented] (KAFKA-4757) Improve NetworkClient trace logging of request details - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/17 19:48:42 UTC, 3 replies.

- [GitHub] kafka pull request #2564: KAFKA-4777 fix client heartbeat non-stop retry iss... - posted by allenxiang <gi...@git.apache.org> on 2017/02/17 20:05:49 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4777) Kafka client Heartbeat thread use all the cpu. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/17 20:06:41 UTC, 1 replies.

- [jira] [Updated] (KAFKA-4759) Add support for subnet masks in SimpleACLAuthorizer - posted by "Shun Takebayashi (JIRA)" <ji...@apache.org> on 2017/02/17 21:58:45 UTC, 0 replies.

- [GitHub] kafka pull request #2565: MINOR: Use scale of 3 in streams benchmark by defa... - posted by guozhangwang <gi...@git.apache.org> on 2017/02/17 22:18:12 UTC, 0 replies.

- [GitHub] kafka pull request #2513: MINOR: Remove Struct from Request/Response classes - posted by asfgit <gi...@git.apache.org> on 2017/02/17 22:34:45 UTC, 0 replies.

- [GitHub] kafka pull request #2471: KAFKA-4317: Regularly checkpoint StateStore change... - posted by asfgit <gi...@git.apache.org> on 2017/02/17 22:42:20 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4317) RocksDB checkpoint files lost on kill -9 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/17 22:42:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4778) OOM on kafka-streams instances with high numbers of unreaped Record classes - posted by "Dave Thomas (JIRA)" <ji...@apache.org> on 2017/02/17 23:03:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4778) OOM on kafka-streams instances with high numbers of unreaped Record classes - posted by "Dave Thomas (JIRA)" <ji...@apache.org> on 2017/02/17 23:05:44 UTC, 2 replies.

- [GitHub] kafka pull request #2566: HOTFIX: ClassCastException in requrest logging - posted by hachikuji <gi...@git.apache.org> on 2017/02/18 00:06:32 UTC, 0 replies.

- [GitHub] kafka pull request #2566: HOTFIX: ClassCastException in request logging - posted by asfgit <gi...@git.apache.org> on 2017/02/18 00:33:13 UTC, 0 replies.

- Jenkins build is back to normal : kafka-trunk-jdk7 #1949 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/18 01:29:33 UTC, 0 replies.

- [GitHub] kafka pull request #2567: MINOR: Increase consumer init timeout in throttlin... - posted by apurvam <gi...@git.apache.org> on 2017/02/18 01:33:15 UTC, 1 replies.

- [jira] [Created] (KAFKA-4779) Failure in kafka/tests/kafkatest/tests/core/security_rolling_upgrade_test.py - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/02/18 01:38:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4779) Failure in kafka/tests/kafkatest/tests/core/security_rolling_upgrade_test.py - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/02/18 01:39:44 UTC, 9 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1284 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/18 02:32:17 UTC, 0 replies.

- [jira] [Commented] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started - posted by "Michał Woś (JIRA)" <ji...@apache.org> on 2017/02/18 03:38:44 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started - posted by "Michał Woś (JIRA)" <ji...@apache.org> on 2017/02/18 03:41:44 UTC, 3 replies.

- [GitHub] kafka pull request #2568: Kafka 4198: Fix Race Condition in KafkaServer Shut... - posted by original-brownbear <gi...@git.apache.org> on 2017/02/18 12:08:31 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4198) Transient test failure: ConsumerBounceTest.testConsumptionWithBrokerFailures - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/18 12:08:44 UTC, 1 replies.

- [GitHub] kafka pull request #2569: MINOR: Add build_eclipse to .gitignore - posted by cshannon <gi...@git.apache.org> on 2017/02/18 14:30:16 UTC, 1 replies.

- [GitHub] kafka pull request #2570: KAFKA-4196: Improved Test Stability by Disabling Z... - posted by original-brownbear <gi...@git.apache.org> on 2017/02/18 16:39:19 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4196) Transient test failure: DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/18 16:39:44 UTC, 1 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1285 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/18 16:53:10 UTC, 0 replies.

- [GitHub] kafka pull request #2571: HOTFIX: ClassCastException in Request logging - posted by original-brownbear <gi...@git.apache.org> on 2017/02/18 17:26:18 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-4777) Kafka client Heartbeat thread use all the cpu. - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/18 17:43:44 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk7 #1951 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/18 18:38:16 UTC, 0 replies.

- Jenkins build is back to normal : kafka-trunk-jdk7 #1952 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/18 21:01:09 UTC, 0 replies.

- [GitHub] kafka pull request #2572: KAFKA-4776: Implement graceful handling for improp... - posted by hachikuji <gi...@git.apache.org> on 2017/02/18 22:46:15 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4776) Implement graceful handling for improperly formed compressed message sets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/18 22:46:44 UTC, 1 replies.

- [jira] [Commented] (KAFKA-2296) Not able to delete topic on latest kafka - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/19 06:43:44 UTC, 0 replies.

- [GitHub] kafka pull request #2573: MINOR: Cleanup org.apache.kafka.streams.kstream.in... - posted by original-brownbear <gi...@git.apache.org> on 2017/02/19 07:36:17 UTC, 0 replies.

- [GitHub] kafka pull request #2574: MINOR: Fixed 3 inner classes without instance refe... - posted by original-brownbear <gi...@git.apache.org> on 2017/02/19 09:26:33 UTC, 1 replies.

- [jira] [Created] (KAFKA-4780) ReplicaFetcherThread.fetch could not get any reponse - posted by "mashudong (JIRA)" <ji...@apache.org> on 2017/02/19 11:06:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4780) ReplicaFetcherThread.fetch could not get any reponse - posted by "mashudong (JIRA)" <ji...@apache.org> on 2017/02/19 11:11:44 UTC, 2 replies.

- [jira] [Commented] (KAFKA-1524) Implement transactional producer - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/02/19 18:14:44 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-1524) Implement transactional producer - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/02/19 18:16:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-1935) Consumer should use a separate socket for Coordinator connection - posted by "Dipen Patel (JIRA)" <ji...@apache.org> on 2017/02/19 21:17:44 UTC, 5 replies.

- [jira] [Resolved] (KAFKA-4774) Inner classes which don't need a reference to the outer class should be static - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/20 00:36:44 UTC, 0 replies.

- [GitHub] kafka pull request #2575: MINOR: update AWS test setup guide - posted by mjsax <gi...@git.apache.org> on 2017/02/20 01:34:17 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4780) ReplicaFetcherThread.fetch could not get any reponse - posted by "huxi (JIRA)" <ji...@apache.org> on 2017/02/20 01:49:44 UTC, 1 replies.

- [GitHub] kafka pull request #2576: kafka-4767: KafkaProducer is not joining its IO th... - posted by amethystic <gi...@git.apache.org> on 2017/02/20 02:29:29 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4767) KafkaProducer is not joining its IO thread properly - posted by "huxi (JIRA)" <ji...@apache.org> on 2017/02/20 02:30:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4781) Kafka should return its advertised host name before any protocol verification is done - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2017/02/20 02:53:44 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4776) Implement graceful handling for improperly formed compressed message sets - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/20 05:16:44 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1288 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/20 07:45:30 UTC, 0 replies.

- [jira] [Created] (KAFKA-4782) change chroot for a kafka instance - posted by "polarbear (JIRA)" <ji...@apache.org> on 2017/02/20 08:03:44 UTC, 0 replies.

- [GitHub] kafka pull request #2577: MINOR: add 2 failure test methods - posted by enothereska <gi...@git.apache.org> on 2017/02/20 14:27:27 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4782) change chroot for a kafka instance - posted by "Jayesh Thakrar (JIRA)" <ji...@apache.org> on 2017/02/20 14:58:44 UTC, 1 replies.

- [jira] [Work started] (KAFKA-4703) Test with two SASL_SSL listeners with different JAAS contexts - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2017/02/20 15:35:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-2096) Enable keepalive socket option for broker to prevent socket leak - posted by "Faisal (JIRA)" <ji...@apache.org> on 2017/02/20 17:29:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-1895) Investigate moving deserialization and decompression out of KafkaConsumer - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/20 18:09:44 UTC, 9 replies.

- [jira] [Commented] (KAFKA-2045) Memory Management on the consumer - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/20 18:11:44 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-2045) Memory Management on the consumer - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/20 18:11:44 UTC, 0 replies.

- [DISCUSS] KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback - posted by Onur Karaman <on...@gmail.com> on 2017/02/20 20:04:59 UTC, 4 replies.

- [GitHub] kafka pull request #2578: MINOR: Variable name corrected - posted by Kamal15 <gi...@git.apache.org> on 2017/02/21 11:01:52 UTC, 0 replies.

- [GitHub] kafka pull request #2579: MINOR: Make it impossible to invoke `Request.body`... - posted by ijuma <gi...@git.apache.org> on 2017/02/21 13:43:13 UTC, 1 replies.

- [GitHub] kafka pull request #2561: MINOR: Fix NPE handling unknown APIs in NodeApiVer... - posted by asfgit <gi...@git.apache.org> on 2017/02/21 13:53:14 UTC, 0 replies.

- [GitHub] kafka pull request #2543: MINOR: Remove unused MessageWriter and Compression... - posted by asfgit <gi...@git.apache.org> on 2017/02/21 14:03:08 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1289 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/21 14:29:37 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3308) Use ProtocolVersion during rolling upgrades to decide on a mutually agreed protocol version between brokers, eliminating the need of inter.broker.protocol.version. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/21 16:16:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-3308) Use ProtocolVersion during rolling upgrades to decide on a mutually agreed protocol version between brokers, eliminating the need of inter.broker.protocol.version. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/21 16:17:44 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4752) Streams Simple Benchmark MB/sec calculation is not correct for Join operations - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/21 17:25:44 UTC, 0 replies.

- [GitHub] kafka pull request #2580: MINOR: Move ProtoUtils methods to ApiKeys - posted by ijuma <gi...@git.apache.org> on 2017/02/21 17:39:50 UTC, 1 replies.

- [jira] [Updated] (KAFKA-4340) Change the default value of log.message.timestamp.difference.max.ms to the same as log.retention.ms - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/02/21 18:13:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect - posted by "Antony Stubbs (JIRA)" <ji...@apache.org> on 2017/02/21 18:56:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect - posted by "Antony Stubbs (JIRA)" <ji...@apache.org> on 2017/02/21 18:58:44 UTC, 2 replies.

- [GitHub] kafka pull request #2180: KAFKA-4439: NetworkClient: create a builder class ... - posted by cmccabe <gi...@git.apache.org> on 2017/02/21 19:10:26 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4439) Add a builder to NetworkClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/21 19:10:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4784) Pluggable JAAS LoginModule configuration for SSL (KIP-127) - posted by "Christopher L. Shannon (JIRA)" <ji...@apache.org> on 2017/02/21 19:12:44 UTC, 0 replies.

- [DISCUSS] KIP-127: Pluggable JAAS LoginModule configuration for SSL - posted by Christopher Shannon <ch...@gmail.com> on 2017/02/21 19:23:25 UTC, 11 replies.

- [jira] [Updated] (KAFKA-4784) Pluggable JAAS LoginModule configuration for SSL (KIP-127) - posted by "Christopher L. Shannon (JIRA)" <ji...@apache.org> on 2017/02/21 19:26:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4778) OOM on kafka-streams instances with high numbers of unreaped Record classes - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/21 19:53:44 UTC, 2 replies.

- [DISCUSS] KIP-126 - Allow KafkaProducer to batch based on uncompressed size - posted by Becket Qin <be...@gmail.com> on 2017/02/21 20:30:03 UTC, 14 replies.

- [GitHub] kafka pull request #2581: HOTFIX: Fix version in __init__.py - posted by ijuma <gi...@git.apache.org> on 2017/02/21 22:22:51 UTC, 1 replies.

- [jira] [Updated] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/02/22 00:17:44 UTC, 1 replies.

- [jira] [Updated] (KAFKA-2273) Kip-54: Add rebalance with a minimal number of reassignments to server-defined strategy list - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/02/22 00:20:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-2273) KIP-54: Add rebalance with a minimal number of reassignments to server-defined strategy list - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/02/22 00:21:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3534) Deserialize on demand when default time extractor used - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 00:53:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3535) Add metrics ability for streams serde components - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 00:57:46 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3537) Provide access to low-level Metrics in ProcessorContext - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 00:57:46 UTC, 1 replies.

- [jira] [Updated] (KAFKA-3395) prefix job id to internal topic names - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 00:58:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3060) Refactor MeteredXXStore - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 00:59:44 UTC, 2 replies.

- [jira] [Updated] (KAFKA-3278) clientId is not unique in producer/consumer registration leads to mbean warning - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 00:59:44 UTC, 2 replies.

- [jira] [Updated] (KAFKA-3016) Add KStream-KStream window joins - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:01:47 UTC, 2 replies.

- [jira] [Updated] (KAFKA-2763) Reduce stream task migrations and initialization costs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:01:50 UTC, 1 replies.

- [jira] [Updated] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:01:50 UTC, 3 replies.

- [jira] [Updated] (KAFKA-2727) initialize only the part of the topology relevant to the task - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:01:50 UTC, 1 replies.

- [jira] [Updated] (KAFKA-2706) Make state stores first class citizens in the processor DAG - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:01:50 UTC, 1 replies.

- [jira] [Updated] (KAFKA-2984) KTable should send old values along with new values to downstreams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:01:50 UTC, 2 replies.

- [jira] [Updated] (KAFKA-3862) Kafka streams documentation: partition<->thread<->task assignment unclear - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:02:44 UTC, 1 replies.

- [jira] [Updated] (KAFKA-3619) State lock file handle leaks - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:02:44 UTC, 1 replies.

- [jira] [Updated] (KAFKA-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:02:44 UTC, 1 replies.

- [jira] [Updated] (KAFKA-3612) Add initial set of integration tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:03:44 UTC, 1 replies.

- [jira] [Updated] (KAFKA-3607) Close state stores explicitly in unit tests upon completing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:04:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3521) Better handling NPEs in Streams DSL implementation - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:04:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3523) Capture org.apache.kafka.clients.consumer.CommitFailedException in UncaughtExceptionHandler - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:04:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3639) Configure default serdes passed via StreamsConfig - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:04:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3599) Move WindowStoreUtils to package "internals" - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:04:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3598) Improve JavaDoc of public API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:04:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3658) Incorrect validation check on maintenance period with join window size - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:04:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3504) Changelog partition configured to enable log compaction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:05:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3499) byte[] should not be used as Map key nor Set member - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:05:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3519) Refactor Transformer templates to return the same strong-typed value. - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:05:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3512) Add a foreach() operator in Kafka Streams DSL - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:05:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3505) Set curRecord in punctuate() functions - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:05:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3440) Add Javadoc for KTable (changelog stream) and KStream (record stream) - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:05:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3477) Add customizable StreamPartition into #to functions of Streams DSL - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:05:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:06:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3337) Extract selector as a separate groupBy operator for KTable aggregations - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:06:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:06:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:06:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3439) Document possible exception thrown in public APIs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:06:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-3153) Serializer/Deserializer Registration and Type inference - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:07:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-2811) Add standby tasks - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:07:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-2856) add KTable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:07:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of  getBaseConsumerConfigs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:07:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-2593) KeyValueStores should not require use of the context's default serializers and deserializers - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:08:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-2594) Add a key-value store that is a fixed-capacity in-memory LRU cache - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:08:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-2649) Add support for custom partitioner in sink nodes - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:08:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-2694) Make a task id be a composite id of a topic group id and a partition id - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 01:08:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4785) Records from internal repartitioning topics should always use RecordMetadataTimestampExtractor - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 02:02:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4785) Records from internal repartitioning topics should always use RecordMetadataTimestampExtractor - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 02:04:44 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-4757) Improve NetworkClient trace logging of request details - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/02/22 04:49:44 UTC, 0 replies.

- [GitHub] kafka pull request #2582: MINOR: Fixed Non-Final Close Method + its Duplicat... - posted by original-brownbear <gi...@git.apache.org> on 2017/02/22 05:52:08 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/22 06:49:44 UTC, 3 replies.

- Build failed in Jenkins: kafka-trunk-jdk7 #1957 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/22 06:55:50 UTC, 0 replies.

- Jenkins build is back to normal : kafka-trunk-jdk8 #1291 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/22 07:53:28 UTC, 0 replies.

- [ANNOUNCE] Apache Kafka 0.10.2.0 Released - posted by Ewen Cheslack-Postava <ew...@apache.org> on 2017/02/22 08:33:02 UTC, 14 replies.

- [jira] [Resolved] (KAFKA-4780) ReplicaFetcherThread.fetch could not get any reponse - posted by "mashudong (JIRA)" <ji...@apache.org> on 2017/02/22 09:30:44 UTC, 0 replies.

- [GitHub] kafka pull request #2583: MINOR: Reduce metrics overheads - posted by enothereska <gi...@git.apache.org> on 2017/02/22 10:41:37 UTC, 1 replies.

- [jira] [Created] (KAFKA-4786) Transient test failure: ConsumerCoordinatorTest.testHeartbeatThreadClose - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/22 10:56:44 UTC, 0 replies.

- Build failed in Jenkins: kafka-0.10.2-jdk7 #85 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/22 11:12:54 UTC, 0 replies.

- [GitHub] kafka pull request #2584: MINOR: Fix transient failure of testCannotSendToIn... - posted by ijuma <gi...@git.apache.org> on 2017/02/22 11:52:39 UTC, 1 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1292 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/22 12:02:51 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4703) Test with two SASL_SSL listeners with different JAAS contexts - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2017/02/22 12:39:44 UTC, 0 replies.

- Jenkins build is back to normal : kafka-trunk-jdk7 #1958 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/22 13:03:08 UTC, 0 replies.

- [jira] [Commented] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/02/22 13:06:44 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/02/22 13:07:44 UTC, 0 replies.

- [GitHub] kafka pull request #2585: MINOR: Fix potential integer overflow and String.f... - posted by ijuma <gi...@git.apache.org> on 2017/02/22 13:29:48 UTC, 1 replies.

- [GitHub] kafka pull request #2586: KAFKA-4786: Wait for heartbeat thread to terminate... - posted by rajinisivaram <gi...@git.apache.org> on 2017/02/22 16:15:09 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4786) Transient test failure: ConsumerCoordinatorTest.testHeartbeatThreadClose - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/22 16:15:44 UTC, 1 replies.

- [GitHub] kafka-site pull request #47: More edits on 0.10.2 web docs after the release - posted by guozhangwang <gi...@git.apache.org> on 2017/02/22 19:01:35 UTC, 1 replies.

- [jira] [Created] (KAFKA-4787) KafkaStreams close() is not reentrant - posted by "Steven Schlansker (JIRA)" <ji...@apache.org> on 2017/02/22 19:11:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4787) KafkaStreams close() is not reentrant - posted by "Steven Schlansker (JIRA)" <ji...@apache.org> on 2017/02/22 19:22:44 UTC, 3 replies.

- [jira] [Comment Edited] (KAFKA-1895) Investigate moving deserialization and decompression out of KafkaConsumer - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/22 19:27:44 UTC, 4 replies.

- Current offset for partition  out of range; reset offset - posted by "Ghosh, Achintya (Contractor)" <Ac...@comcast.com> on 2017/02/22 19:33:52 UTC, 0 replies.

- [jira] [Commented] (KAFKA-3798) Kafka Consumer 0.10.0.0 killed after rebalancing exception - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2017/02/22 19:37:44 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4786) Transient test failure: ConsumerCoordinatorTest.testHeartbeatThreadClose - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/22 20:43:44 UTC, 0 replies.

- Jenkins build is back to normal : kafka-0.10.2-jdk7 #86 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/22 22:20:11 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-4787) KafkaStreams close() is not reentrant - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/22 22:55:44 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1293 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/23 00:06:14 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers - posted by "mjuarez (JIRA)" <ji...@apache.org> on 2017/02/23 00:22:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers - posted by "mjuarez (JIRA)" <ji...@apache.org> on 2017/02/23 00:24:44 UTC, 0 replies.

- [GitHub] kafka-site issue #47: More edits on 0.10.2 web docs after the release - posted by derrickdoo <gi...@git.apache.org> on 2017/02/23 01:16:44 UTC, 1 replies.

- Fwd: Producer acks=1, clean broker shutdown and data loss - posted by Nick Travers <n....@gmail.com> on 2017/02/23 05:10:42 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4570) How to transfer extended fields in producing or consuming requests. - posted by "dongeforever (JIRA)" <ji...@apache.org> on 2017/02/23 06:52:48 UTC, 0 replies.

- [jira] [Created] (KAFKA-4788) Broker level configuration 'log.segment.bytes' not used when 'segment.bytes' not configured per topic. - posted by "Ciprian Pascu (JIRA)" <ji...@apache.org> on 2017/02/23 07:59:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4788) Broker level configuration 'log.segment.bytes' not used when 'segment.bytes' not configured per topic. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/23 09:48:44 UTC, 8 replies.

- [jira] [Created] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics - posted by "Hamidreza Afzali (JIRA)" <ji...@apache.org> on 2017/02/23 10:37:45 UTC, 0 replies.

- [GitHub] kafka pull request #2587: KAFKA-4461: Added support to ProcessorTopologyTest... - posted by hrafzali <gi...@git.apache.org> on 2017/02/23 11:37:22 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4788) Broker level configuration 'log.segment.bytes' not used when 'segment.bytes' not configured per topic. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/23 11:45:53 UTC, 1 replies.

- [jira] [Created] (KAFKA-4790) Kafka can't not recover after a disk full - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2017/02/23 12:58:44 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-4788) Broker level configuration 'log.segment.bytes' not used when 'segment.bytes' not configured per topic. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/02/23 13:03:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4790) Kafka can't not recover after a disk full - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/23 13:12:44 UTC, 0 replies.

- [jira] [Reopened] (KAFKA-4092) retention.bytes should not be allowed to be less than segment.bytes - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/23 13:16:44 UTC, 0 replies.

- [GitHub] kafka pull request #2588: KAFKA-4788: Revert "KAFKA-4092: retention.bytes sh... - posted by ijuma <gi...@git.apache.org> on 2017/02/23 13:23:34 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-4779) Failure in kafka/tests/kafkatest/tests/core/security_rolling_upgrade_test.py - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/02/23 13:27:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4790) Kafka can't not recover after a disk full - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2017/02/23 14:44:44 UTC, 0 replies.

- [GitHub] kafka pull request #2587: KAFKA-4789: Added support to ProcessorTopologyTest... - posted by hrafzali <gi...@git.apache.org> on 2017/02/23 15:24:54 UTC, 0 replies.

- [GitHub] kafka pull request #2589: KAFKA-4779: Fix security upgrade system test to be... - posted by rajinisivaram <gi...@git.apache.org> on 2017/02/23 15:25:43 UTC, 1 replies.

- [GitHub] kafka pull request #2590: KAFKA-4789: Added support to ProcessorTopologyTest... - posted by hrafzali <gi...@git.apache.org> on 2017/02/23 15:25:43 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/23 15:25:44 UTC, 4 replies.

- [jira] [Created] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source - posted by "Bart Vercammen (JIRA)" <ji...@apache.org> on 2017/02/23 16:01:44 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/23 16:27:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/23 16:28:44 UTC, 6 replies.

- [jira] [Resolved] (KAFKA-4788) Broker level configuration 'log.segment.bytes' not used when 'segment.bytes' not configured per topic. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/23 16:36:44 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/23 18:56:44 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL - posted by "Michal Borowiecki (JIRA)" <ji...@apache.org> on 2017/02/23 19:03:44 UTC, 1 replies.

- [GitHub] kafka pull request #2591: HOTFIX: use explicit version in upgrade.html - posted by guozhangwang <gi...@git.apache.org> on 2017/02/23 19:07:45 UTC, 1 replies.

- [jira] [Created] (KAFKA-4792) Kafka Connect: Add ByteArray Converter - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2017/02/23 19:18:44 UTC, 0 replies.

- [GitHub] kafka pull request #2592: MINOR: fixed javadoc typo in KafkaProducer::partit... - posted by jpdaigle <gi...@git.apache.org> on 2017/02/23 19:51:33 UTC, 1 replies.

- [jira] [Created] (KAFKA-4793) Kafka Connect: POST /connectors/(string: name)/restart doesn't start failed tasks - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2017/02/23 21:08:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector - posted by "Florian Hussonnois (JIRA)" <ji...@apache.org> on 2017/02/23 21:58:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector - posted by "Florian Hussonnois (JIRA)" <ji...@apache.org> on 2017/02/23 21:59:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4795) Confusion around topic deletion - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/02/23 23:57:44 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1296 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/24 00:13:41 UTC, 0 replies.

- [VOTE] KIP-122: Add Reset Consumer Group Offsets tooling - posted by Jorge Esteban Quilcate Otoya <qu...@gmail.com> on 2017/02/24 00:46:29 UTC, 1 replies.

- [jira] [Created] (KAFKA-4796) Fix some findbugs warnings in Kafka Java client - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/24 00:57:44 UTC, 0 replies.

- [GitHub] kafka pull request #2593: KAFKA-4796: Fix some findbugs warnings in Kafka Ja... - posted by cmccabe <gi...@git.apache.org> on 2017/02/24 01:00:23 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4796) Fix some findbugs warnings in Kafka Java client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/24 01:01:57 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4766) Document lz4 and lz4hc in confluence - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2017/02/24 03:35:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4797) Add lag in seconds JMX metrics for fether threads - posted by "Jun Ma (JIRA)" <ji...@apache.org> on 2017/02/24 05:09:44 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4797) Add lag in time JMX metrics for fether threads - posted by "Jun Ma (JIRA)" <ji...@apache.org> on 2017/02/24 05:09:44 UTC, 2 replies.

- Consumption on a explicitly (dynamically) created topic has a 5 minute delay - posted by Jaikiran Pai <ja...@gmail.com> on 2017/02/24 06:03:34 UTC, 5 replies.

- [jira] [Created] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/24 06:33:44 UTC, 0 replies.

- Broaden the utilization of Kafka by being more user friendly - posted by Werner Daehn <we...@gmail.com> on 2017/02/24 10:28:48 UTC, 0 replies.

- KIPs to broaden the utilization of Kafka by making it more user friendly - posted by Werner Daehn <we...@gmail.com> on 2017/02/24 10:52:14 UTC, 0 replies.

- [jira] [Created] (KAFKA-4799) session timeout during event processing shuts down stream - posted by "Jacob Gur (JIRA)" <ji...@apache.org> on 2017/02/24 11:37:44 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4198) Transient test failure: ConsumerBounceTest.testConsumptionWithBrokerFailures - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/24 12:22:44 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4198) Transient test failure: ConsumerBounceTest.testConsumptionWithBrokerFailures - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/24 12:22:44 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1298 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/24 12:22:49 UTC, 0 replies.

- [GitHub] kafka pull request #2578: MINOR: ConfigKey variable renamed - posted by asfgit <gi...@git.apache.org> on 2017/02/24 13:45:09 UTC, 0 replies.

- [jira] [Created] (KAFKA-4800) Streams State transition ASCII diagrams need fixing and polishing - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/02/24 13:51:44 UTC, 0 replies.

- add contributor - posted by Eno Thereska <en...@gmail.com> on 2017/02/24 14:10:31 UTC, 1 replies.

- [GitHub] kafka pull request #2594: MINOR: add code quality checks to checkstyle.xml. ... - posted by dguy <gi...@git.apache.org> on 2017/02/24 15:48:08 UTC, 1 replies.

- [jira] [Created] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/02/24 16:34:44 UTC, 0 replies.

- [GitHub] kafka pull request #2595: MINOR: Fix typos in javadoc and code comments - posted by vahidhashemian <gi...@git.apache.org> on 2017/02/24 16:57:55 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4779) Failure in kafka/tests/kafkatest/tests/core/security_rolling_upgrade_test.py - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/24 17:24:44 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4800) Streams State transition ASCII diagrams need fixing and polishing - posted by "Clemens Valiente (JIRA)" <ji...@apache.org> on 2017/02/24 18:08:44 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4494) Significant startup delays in KStreams app - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/24 18:34:44 UTC, 0 replies.

- Jenkins build is back to normal : kafka-trunk-jdk8 #1300 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/24 19:44:10 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/24 20:00:47 UTC, 9 replies.

- [jira] [Resolved] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/24 20:00:47 UTC, 1 replies.

- [jira] [Closed] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/24 20:00:47 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/24 20:03:44 UTC, 2 replies.

- [jira] [Updated] (KAFKA-3995) Add a new configuration "enable.compression.ratio.estimation" to the producer config - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/02/24 22:24:44 UTC, 0 replies.

- [GitHub] kafka pull request #2596: MINOR: Ensure consumer calls poll() if requests ar... - posted by hachikuji <gi...@git.apache.org> on 2017/02/24 22:45:36 UTC, 1 replies.

- New subscriber - posted by Huimin He <hu...@gmail.com> on 2017/02/25 00:39:04 UTC, 1 replies.

- Jenkins build is back to normal : kafka-trunk-jdk8 #1302 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/25 01:47:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-1120) Controller could miss a broker state change - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/25 06:58:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-3436) Speed up controlled shutdown. - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/25 07:02:44 UTC, 3 replies.

- [jira] [Commented] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/02/25 07:10:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4802) Support direct ByteBuffer serializers/deserializers in clients - posted by "Matt Sicker (JIRA)" <ji...@apache.org> on 2017/02/25 07:16:44 UTC, 0 replies.

- [GitHub] kafka pull request #2570: KAFKA-4196: Improved Test Stability - posted by original-brownbear <gi...@git.apache.org> on 2017/02/25 10:21:49 UTC, 0 replies.

- [GitHub] kafka pull request #2597: KAFKA-4652: Added tests for KStreamBuilder - posted by bbejeck <gi...@git.apache.org> on 2017/02/25 18:04:23 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4793) Kafka Connect: POST /connectors/(string: name)/restart doesn't start failed tasks - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/25 20:51:44 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/25 21:39:44 UTC, 0 replies.

- [GitHub] kafka pull request #2598: KAFKA-4784: Add ByteArrayConverter (KIP-128) - posted by ewencp <gi...@git.apache.org> on 2017/02/25 22:19:10 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4784) Pluggable JAAS LoginModule configuration for SSL (KIP-127) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/25 22:19:44 UTC, 1 replies.

- [GitHub] kafka pull request #2599: KAFKA-4783: Add ByteArrayConverter (KIP-128) - posted by ewencp <gi...@git.apache.org> on 2017/02/25 22:21:15 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/25 22:21:45 UTC, 0 replies.

- [jira] [Work started] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/25 22:21:45 UTC, 0 replies.

- [jira] [Work stopped] (KAFKA-4783) Blackbox or pass through converter or ByteArrayConverter for connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/25 22:21:45 UTC, 0 replies.

- [DISCUSS] KIP-128: Add ByteArrayConverter for Kafka Connect - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2017/02/25 22:25:15 UTC, 3 replies.

- [GitHub] kafka pull request #2467: MINOR: Use API hyperlinks in 'Kafka Protocol Guide... - posted by asfgit <gi...@git.apache.org> on 2017/02/26 02:45:54 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1304 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/26 04:02:12 UTC, 0 replies.

- [jira] [Commented] (KAFKA-3900) High CPU util on broker - posted by "songxin (JIRA)" <ji...@apache.org> on 2017/02/26 04:09:44 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-3900) High CPU util on broker - posted by "songxin (JIRA)" <ji...@apache.org> on 2017/02/26 04:10:44 UTC, 2 replies.

- [jira] [Created] (KAFKA-4803) OT6Y1 - posted by "Vamsi Jakkula (JIRA)" <ji...@apache.org> on 2017/02/26 08:07:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4804) TdOZY - posted by "Vamsi Jakkula (JIRA)" <ji...@apache.org> on 2017/02/26 08:09:44 UTC, 0 replies.

- [jira] [Created] (KAFKA-4805) e9qgi - posted by "Vamsi Jakkula (JIRA)" <ji...@apache.org> on 2017/02/26 08:22:44 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4805) e9qgi - posted by "Vamsi Jakkula (JIRA)" <ji...@apache.org> on 2017/02/26 08:24:44 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4784) Pluggable JAAS LoginModule configuration for SSL (KIP-127) - posted by "Christopher L. Shannon (JIRA)" <ji...@apache.org> on 2017/02/26 15:03:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4434) KafkaProducer configuration is logged twice - posted by "Marco Ebert (JIRA)" <ji...@apache.org> on 2017/02/26 19:03:45 UTC, 0 replies.

- [jira] [Created] (KAFKA-4806) KafkaConsumer: ConsumerConfig gets logged twice. - posted by "Marco Ebert (JIRA)" <ji...@apache.org> on 2017/02/26 19:07:45 UTC, 0 replies.

- [GitHub] kafka pull request #2600: KAFKA-4806: Prevent double logging of ConsumerConf... - posted by Gacko <gi...@git.apache.org> on 2017/02/26 19:16:01 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4806) KafkaConsumer: ConsumerConfig gets logged twice. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/26 19:16:45 UTC, 1 replies.

- [jira] [Updated] (KAFKA-4806) KafkaConsumer: ConsumerConfig gets logged twice. - posted by "Marco Ebert (JIRA)" <ji...@apache.org> on 2017/02/26 19:21:46 UTC, 3 replies.

- [GitHub] kafka pull request #2601: KAFKA-4744: Increased timeout for bounce test - posted by enothereska <gi...@git.apache.org> on 2017/02/26 19:32:27 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4744) Streams_bounce test failing occassionally - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/26 19:32:45 UTC, 1 replies.

- [jira] [Work started] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/02/26 21:58:45 UTC, 0 replies.

- [jira] [Created] (KAFKA-4807) Kafka broker fail over bug in zookeeper - posted by "Mingzhou Zhuang (JIRA)" <ji...@apache.org> on 2017/02/27 05:51:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4807) Kafka broker fail over bug in zookeeper - posted by "Mingzhou Zhuang (JIRA)" <ji...@apache.org> on 2017/02/27 05:52:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/27 11:26:45 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/27 11:28:45 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-4806) KafkaConsumer: ConsumerConfig gets logged twice. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/27 11:50:48 UTC, 0 replies.

- [jira] [Reopened] (KAFKA-4779) Failure in kafka/tests/kafkatest/tests/core/security_rolling_upgrade_test.py - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/27 12:54:45 UTC, 0 replies.

- [jira] [Created] (KAFKA-4808) send of null key to a compacted topic should throw error back to user - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/27 13:08:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4808) send of null key to a compacted topic should throw error back to user - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/27 13:08:45 UTC, 3 replies.

- Re: [VOTE] KIP-81: Bound Fetch memory usage in the consumer - posted by Mickael Maison <mi...@gmail.com> on 2017/02/27 17:09:30 UTC, 2 replies.

- [jira] [Assigned] (KAFKA-4808) send of null key to a compacted topic should throw error back to user - posted by "Mayuresh Gharat (JIRA)" <ji...@apache.org> on 2017/02/27 18:44:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4744) Streams_bounce test failing occassionally - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/27 19:19:45 UTC, 0 replies.

- Kafka MirrorMaker issues - posted by Le Cyberian <le...@gmail.com> on 2017/02/27 19:21:20 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4809) sanity_checks/test_verifiable_producer.py should test 0.10.x and not 0.8 - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/27 20:01:45 UTC, 1 replies.

- [jira] [Created] (KAFKA-4809) sanity_checks/test_verifiable_producer.py should test 0.10.1 and 0.10.2 and not 0.8 - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/27 20:01:45 UTC, 0 replies.

- [GitHub] kafka pull request #2602: KAFKA-4809: sanity_checks/test_verifiable_producer... - posted by cmccabe <gi...@git.apache.org> on 2017/02/27 20:02:56 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4809) sanity_checks/test_verifiable_producer.py should test 0.10.x and not 0.8 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/27 20:03:45 UTC, 1 replies.

- [GitHub] kafka pull request #2603: MINOR: Minor reduce unnecessary calls to time.mill... - posted by enothereska <gi...@git.apache.org> on 2017/02/27 20:13:41 UTC, 0 replies.

- [jira] [Commented] (KAFKA-3990) Kafka New Producer may raise an OutOfMemoryError - posted by "Adrian McCague (JIRA)" <ji...@apache.org> on 2017/02/27 20:19:45 UTC, 1 replies.

- [jira] [Commented] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/27 22:40:45 UTC, 0 replies.

- [GitHub] kafka pull request #2604: KAFKA-4794: Add access to OffsetStorageReader from... - posted by fhussonnois <gi...@git.apache.org> on 2017/02/27 22:40:53 UTC, 0 replies.

- Jenkins build is back to normal : kafka-trunk-jdk8 #1306 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/27 22:47:56 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4809) docker/run_tests.sh should be able to run sanity_checks/test_verifiable_producer.py against version 0.8.2.2 - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/27 23:01:45 UTC, 2 replies.

- [jira] [Commented] (KAFKA-4809) docker/run_tests.sh should be able to run sanity_checks/test_verifiable_producer.py against version 0.8.2.2 - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/27 23:05:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4809) docker/run_tests.sh should set up /opt/kafka-dev to be the source directory - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/27 23:08:45 UTC, 1 replies.

- [jira] [Updated] (KAFKA-4809) docker/run_tests.sh should set up /opt/kafka-dev the same way Vagrant does - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/02/27 23:08:45 UTC, 0 replies.

- [GitHub] kafka-site pull request #48: Filled in og meta tags - posted by derrickdoo <gi...@git.apache.org> on 2017/02/27 23:31:29 UTC, 0 replies.

- [jira] [Created] (KAFKA-4810) SchemaBuilder should be more lax about checking that fields are unset if they are being set to the same value - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/27 23:52:45 UTC, 0 replies.

- [GitHub] kafka pull request #2605: Kafka 4738:Remove generic type of class ClientStat... - posted by sharad-develop <gi...@git.apache.org> on 2017/02/27 23:55:21 UTC, 0 replies.

- [jira] [Created] (KAFKA-4811) ReplicaFetchThread may fail to create due to existing metric - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/28 02:36:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4811) ReplicaFetchThread may fail to create due to existing metric - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/02/28 02:46:45 UTC, 2 replies.

- [jira] [Updated] (KAFKA-4811) ReplicaFetchThread may fail to create due to existing metric - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/28 02:50:45 UTC, 1 replies.

- [jira] [Updated] (KAFKA-4586) Add purgeDataBefore() API in AdminClient - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/28 03:04:45 UTC, 1 replies.

- [DISCUSS] 0.10.3.0/0.11.0.0 release planning - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/28 03:47:05 UTC, 15 replies.

- Re: [VOTE] KIP-107: Add purgeDataBefore() API in AdminClient - posted by Dong Lin <li...@gmail.com> on 2017/02/28 04:26:45 UTC, 2 replies.

- [jira] [Commented] (KAFKA-4623) Change Default unclean.leader.election.enabled from True to False - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/28 05:29:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4706) Unify StreamsKafkaClient instances - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/28 05:30:45 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4811) ReplicaFetchThread may fail to create due to existing metric - posted by "huxi (JIRA)" <ji...@apache.org> on 2017/02/28 05:35:46 UTC, 0 replies.

- [GitHub] kafka pull request #2606: kafka4811: ReplicaFetchThread may fail to create d... - posted by amethystic <gi...@git.apache.org> on 2017/02/28 05:36:46 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1523) Implement transaction manager module - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:44:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1525) DumpLogSegments should print transaction IDs - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:45:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1524) Implement transactional producer - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:45:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1526) Producer performance tool should have an option to enable transactions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:46:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1527) SimpleConsumer should be transaction-aware - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:46:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:47:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1541)  Add transactional request definitions to clients package - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:47:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1604) System Test for Transaction Management - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:48:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-1569) Tool for performance and correctness of transactions end-to-end - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 05:48:45 UTC, 0 replies.

- Like to contribute - posted by Sunitha Prabhu <su...@gmail.com> on 2017/02/28 06:29:23 UTC, 1 replies.

- [VOTE] KIP-123: Allow per stream/table timestamp extractor - posted by Jeyhun Karimov <je...@gmail.com> on 2017/02/28 08:59:18 UTC, 4 replies.

- [jira] [Created] (KAFKA-4812) We are facing the same issue as SAMZA-590 - posted by "Manjeer Srujan. Y (JIRA)" <ji...@apache.org> on 2017/02/28 10:38:45 UTC, 0 replies.

- [VOTE] KIP-119: Drop Support for Scala 2.10 in Kafka 0.11 - posted by Ismael Juma <is...@juma.me.uk> on 2017/02/28 10:40:58 UTC, 4 replies.

- [jira] [Updated] (KAFKA-4812) We are facing the same issue as SAMZA-590 for kafka - posted by "Manjeer Srujan. Y (JIRA)" <ji...@apache.org> on 2017/02/28 10:41:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4812) We are facing the same issue as SAMZA-590 for kafka - posted by "Manjeer Srujan. Y (JIRA)" <ji...@apache.org> on 2017/02/28 10:47:45 UTC, 0 replies.

- [GitHub] kafka pull request #2607: MINOR: Fix typo in javadoc of `flatMapValues` - posted by miguno <gi...@git.apache.org> on 2017/02/28 11:49:01 UTC, 1 replies.

- [GitHub] kafka pull request #2608: KAFKA-4779: Request metadata in consumer if partit... - posted by rajinisivaram <gi...@git.apache.org> on 2017/02/28 13:15:18 UTC, 0 replies.

- [jira] [Created] (KAFKA-4813) 2h6R1 - posted by "Vamsi Jakkula (JIRA)" <ji...@apache.org> on 2017/02/28 13:37:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception - posted by "Federico Giraud (JIRA)" <ji...@apache.org> on 2017/02/28 14:43:46 UTC, 0 replies.

- [GitHub] kafka pull request #2609: KAFKA-4677: [Follow Up] add optimization to Sticky... - posted by dguy <gi...@git.apache.org> on 2017/02/28 15:01:42 UTC, 0 replies.

- [jira] [Created] (KAFKA-4814) ZookeeperLeaderElector not respecting zookeeper.set.acl - posted by "Stevo Slavic (JIRA)" <ji...@apache.org> on 2017/02/28 16:59:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4814) ZookeeperLeaderElector not respecting zookeeper.set.acl - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/28 17:05:45 UTC, 2 replies.

- [GitHub] kafka pull request #2610: MINOR: Make asJsonSchema() and asConnectSchema() m... - posted by C0urante <gi...@git.apache.org> on 2017/02/28 18:00:48 UTC, 1 replies.

- [GitHub] kafka pull request #2611: MINOR: improve MinTimestampTrackerTest and fix NPE... - posted by dguy <gi...@git.apache.org> on 2017/02/28 18:49:40 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1307 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/28 20:15:55 UTC, 0 replies.

- [GitHub] kafka pull request #2602: KAFKA-4809: docker/run_tests.sh should set up /opt... - posted by asfgit <gi...@git.apache.org> on 2017/02/28 20:22:44 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4809) docker/run_tests.sh should set up /opt/kafka-dev to be the source directory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/28 20:22:45 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4809) docker/run_tests.sh should set up /opt/kafka-dev to be the source directory - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/02/28 20:24:46 UTC, 0 replies.

- [jira] [Created] (KAFKA-4815) Idempotent/transactional Producer Checklist (KIP-98) - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 20:54:45 UTC, 0 replies.

- Re: Improve License Header Check - posted by "Matthias J. Sax" <ma...@confluent.io> on 2017/02/28 20:54:55 UTC, 0 replies.

- [jira] [Created] (KAFKA-4816) Message format changes for idempotent/transactional producer - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 20:56:45 UTC, 0 replies.

- [jira] [Created] (KAFKA-4817) Basic idempotent producer implementation - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 20:59:45 UTC, 0 replies.

- [jira] [Created] (KAFKA-4818) Implement transactional producer - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 21:07:45 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4817) Implement idempotent producer - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/02/28 21:08:45 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4815) Idempotent/transactional Producer Checklist (KIP-98) - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/28 21:10:45 UTC, 2 replies.

- [jira] [Updated] (KAFKA-4815) Idempotent/transactional Producer Checklist (KIP-98) - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/28 21:10:45 UTC, 0 replies.

- Build failed in Jenkins: kafka-trunk-jdk8 #1308 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/28 21:20:42 UTC, 0 replies.

- [jira] [Created] (KAFKA-4819) Expose states of active tasks to public API - posted by "Florian Hussonnois (JIRA)" <ji...@apache.org> on 2017/02/28 21:26:45 UTC, 0 replies.

- [GitHub] kafka pull request #2303: MINOR: improve license header check by providing h... - posted by asfgit <gi...@git.apache.org> on 2017/02/28 21:30:55 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/28 21:32:45 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/02/28 21:33:45 UTC, 0 replies.

- [GitHub] kafka pull request #2612: KAFKA-4819: Expose states for active tasks to publ... - posted by fhussonnois <gi...@git.apache.org> on 2017/02/28 21:46:02 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4819) Expose states of active tasks to public API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/28 21:46:45 UTC, 1 replies.

- [DISCUSS] KIP-129: Kafka Streams Exactly-Once Semantics - posted by Guozhang Wang <wa...@gmail.com> on 2017/02/28 21:54:43 UTC, 0 replies.

- [GitHub] kafka pull request #2613: MINOR. Fix tests/docker/Dockerfile - posted by cmccabe <gi...@git.apache.org> on 2017/02/28 22:30:52 UTC, 0 replies.

- [jira] [Updated] (KAFKA-4819) Expose states of active tasks to public API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/28 22:42:45 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-4819) Expose states of active tasks to public API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/02/28 22:53:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2017/02/28 23:21:45 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-4773) The Kafka build should run findbugs - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/02/28 23:21:45 UTC, 0 replies.

- [GitHub] kafka pull request #2614: KAFKA-4816: Message format changes for idempotent/... - posted by hachikuji <gi...@git.apache.org> on 2017/02/28 23:45:15 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4816) Message format changes for idempotent/transactional producer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/02/28 23:45:45 UTC, 0 replies.

- [jira] [Commented] (KAFKA-1712) Excessive storage usage on newly added node - posted by "Alan Braithwaite (JIRA)" <ji...@apache.org> on 2017/02/28 23:52:46 UTC, 0 replies.

- [GitHub] kafka pull request #2615: Add a consumer offset migration tool - posted by jeffwidman <gi...@git.apache.org> on 2017/02/28 23:54:06 UTC, 0 replies.