dev@kafka.apache.org, 2016-11

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

- [GitHub] kafka pull request #2081: MINOR: Extend mirror maker test to include interce... - posted by kkonstantine <gi...@git.apache.org> on 2016/11/01 00:05:59 UTC, 1 replies.
- [jira] [Created] (KAFKA-4362) Offset commits fail after a partition reassignment - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2016/11/01 00:10:58 UTC, 0 replies.
- [GitHub] kafka pull request #2082: KAFKA-4352: instable ResetTool integration test - posted by mjsax <gi...@git.apache.org> on 2016/11/01 00:51:17 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4352) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 00:51:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4348) On Mac OS, KafkaConsumer.poll returns 0 when there are still messages on Kafka server - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/01 01:21:58 UTC, 4 replies.
- [jira] [Commented] (KAFKA-4360) Controller may deadLock when autoLeaderRebalance encounter zk expired - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/01 02:54:58 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-4360) Controller may deadLock when autoLeaderRebalance encounter zk expired - posted by "Json Tu (JIRA)" <ji...@apache.org> on 2016/11/01 03:04:58 UTC, 6 replies.
- [jira] [Updated] (KAFKA-4360) Controller may deadLock when autoLeaderRebalance encounter zk expired - posted by "Json Tu (JIRA)" <ji...@apache.org> on 2016/11/01 03:16:59 UTC, 3 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4360) Controller may deadLock when autoLeaderRebalance encounter zk expired - posted by "Json Tu (JIRA)" <ji...@apache.org> on 2016/11/01 03:17:58 UTC, 0 replies.
- KAFKA-4360 issue - posted by Json Tu <ka...@126.com> on 2016/11/01 03:20:03 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4362) Offset commits fail after a partition reassignment - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/01 05:36:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4362) Offset commits fail after a partition reassignment - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/01 05:46:58 UTC, 0 replies.
- Re: [ANNOUNCE] New committer: Jiangjie (Becket) Qin - posted by Harsha Chintalapani <ka...@harsha.io> on 2016/11/01 05:57:57 UTC, 5 replies.
- [jira] [Commented] (KAFKA-4362) Offset commits fail after a partition reassignment - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2016/11/01 06:24:58 UTC, 0 replies.
- [GitHub] kafka pull request #2083: KAFKA-4318 Migrate ProducerSendTest to the new con... - posted by baluchicken <gi...@git.apache.org> on 2016/11/01 09:40:36 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4318) Migrate ProducerSendTest to the new consumer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 09:40:58 UTC, 0 replies.
- [GitHub] kafka pull request #2084: KAFKA-4361: Streams does not respect user configs ... - posted by dguy <gi...@git.apache.org> on 2016/11/01 10:20:24 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4361) Streams does not respect user configs for "default" params - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 10:20:58 UTC, 1 replies.
- [GitHub] kafka pull request #2085: KAFKA-4360：Controller may deadLock when autoLead... - posted by xiguantiaozhan <gi...@git.apache.org> on 2016/11/01 12:35:57 UTC, 1 replies.
- [GitHub] kafka pull request #2086: KAFKA-3751: SASL/SCRAM implementation - posted by rajinisivaram <gi...@git.apache.org> on 2016/11/01 13:28:35 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3751) Add support for SASL mechanism SCRAM-SHA-256 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 13:28:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3751) Add support for SASL mechanism SCRAM-SHA-256 - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/01 13:32:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3751) Add support for SASL/SCRAM mechanisms - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/01 13:33:58 UTC, 0 replies.
- [GitHub] kafka pull request #2087: MINOR: Fix NPE when Connect offset contains non-pr... - posted by mfenniak <gi...@git.apache.org> on 2016/11/01 13:38:23 UTC, 1 replies.
- Re: [VOTE] KIP-85: Dynamic JAAS configuration for Kafka clients - posted by Rajini Sivaram <ra...@googlemail.com> on 2016/11/01 13:42:30 UTC, 5 replies.
- [jira] [Created] (KAFKA-4363) Add document for dynamic JAAS configuration property sasl.jaas.config - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/01 13:51:58 UTC, 0 replies.
- Re: [DISCUSS] KIP-84: Support SASL/SCRAM mechanisms - posted by Rajini Sivaram <ra...@googlemail.com> on 2016/11/01 14:41:26 UTC, 18 replies.
- [GitHub] kafka pull request #2073: MINOR: Fix issue in `AsyncProducerTest` where it e... - posted by asfgit <gi...@git.apache.org> on 2016/11/01 15:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4361) Streams does not respect user configs for "default" params - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/01 17:08:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1663 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/01 17:18:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1012 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/01 17:31:38 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4352) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/01 17:31:58 UTC, 0 replies.
- [DISCUSS] KAFKA-4345: Run decktape test for each pull request - posted by Raghav Kumar Gautam <ra...@apache.org> on 2016/11/01 18:47:53 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-4320) Log compaction docs update - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/11/01 18:55:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4307) Inconsistent parameters between console producer and consumer - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/11/01 18:55:58 UTC, 4 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1664 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/01 18:59:06 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2544) Replication tools wiki page needs to be updated - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/11/01 19:01:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4357) Consumer group describe exception when there is no active member (old consumer) - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/01 19:31:58 UTC, 0 replies.
- [GitHub] kafka pull request #2075: KAFKA-4357: Fix consumer group describe output whe... - posted by asfgit <gi...@git.apache.org> on 2016/11/01 19:32:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4357) Consumer group describe exception when there is no active member (old consumer) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 19:32:58 UTC, 0 replies.
- Re: [DISCUSS] KIP-87 - Add Compaction Tombstone Flag - posted by Becket Qin <be...@gmail.com> on 2016/11/01 20:15:32 UTC, 49 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1013 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/01 20:23:15 UTC, 0 replies.
- [jira] [Created] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2016/11/01 20:29:58 UTC, 0 replies.
- [GitHub] kafka pull request #2080: KAFKA-4302: Simplify KTableSource - posted by mjsax <gi...@git.apache.org> on 2016/11/01 21:26:40 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4302) Simplify KTableSource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 21:26:58 UTC, 0 replies.
- [GitHub] kafka pull request #2079: HOTFIX: improve error message on invalid input rec... - posted by mjsax <gi...@git.apache.org> on 2016/11/01 21:27:04 UTC, 0 replies.
- [GitHub] kafka pull request #2062: Expose name of processor on KStream - posted by thijsc <gi...@git.apache.org> on 2016/11/01 21:40:55 UTC, 0 replies.
- [GitHub] kafka pull request #2088: Cross compile to Scala 2.12.0-RC2 - posted by leachbj <gi...@git.apache.org> on 2016/11/01 22:08:14 UTC, 1 replies.
- [GitHub] kafka pull request #2089: Fix documentation of compaction - posted by apurvam <gi...@git.apache.org> on 2016/11/01 22:28:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4362) Consumer can fail after reassignment of the offsets topic partition - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2016/11/01 22:42:59 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool. - posted by "David (JIRA)" <ji...@apache.org> on 2016/11/01 23:08:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1665 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/01 23:15:15 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4113) Allow KTable bootstrap - posted by "Greg Fodor (JIRA)" <ji...@apache.org> on 2016/11/01 23:50:58 UTC, 0 replies.
- [GitHub] kafka pull request #2090: KAFKA-4269: Follow up for 0.10.1 branch -update to... - posted by bbejeck <gi...@git.apache.org> on 2016/11/02 00:16:44 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 00:16:58 UTC, 0 replies.
- [GitHub] kafka pull request #2089: MINOR: Fix documentation of compaction - posted by asfgit <gi...@git.apache.org> on 2016/11/02 01:18:31 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1666 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/02 04:33:57 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1015 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/02 04:54:32 UTC, 0 replies.
- [GitHub] kafka pull request #2050: Replaced unnecessary isDefined and get on option v... - posted by asfgit <gi...@git.apache.org> on 2016/11/02 05:38:48 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4362) Consumer can fail after reassignment of the offsets topic partition - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/02 05:41:58 UTC, 8 replies.
- [jira] [Commented] (KAFKA-3986) completedReceives can contain closed channels - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/02 06:16:58 UTC, 0 replies.
- ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message - posted by "Jun H." <ju...@gmail.com> on 2016/11/02 08:38:29 UTC, 5 replies.
- Re: [DISCUSS] KIP-82 - Add Record Headers - posted by Michael Pearce <Mi...@ig.com> on 2016/11/02 09:33:00 UTC, 49 replies.
- Kafka Connect key.converter and value.converter properties for Avro encoding - posted by da...@bt.com on 2016/11/02 09:48:49 UTC, 7 replies.
- [jira] [Created] (KAFKA-4365) In case async producer closes the TCP connection to Kafka broker, last sent messages might be lost. - posted by "Ciprian Pascu (JIRA)" <ji...@apache.org> on 2016/11/02 09:56:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Michal Borowiecki (JIRA)" <ji...@apache.org> on 2016/11/02 10:02:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted - posted by "Michal Borowiecki (JIRA)" <ji...@apache.org> on 2016/11/02 10:03:58 UTC, 5 replies.
- [GitHub] kafka pull request #2091: MINOR: Bug fixed - posted by himani1 <gi...@git.apache.org> on 2016/11/02 10:15:31 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/02 10:42:58 UTC, 0 replies.
- [jira] [Work started] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/02 10:43:58 UTC, 0 replies.
- [GitHub] kafka pull request #2092: MINOR: remove commented out code and System.out.pr... - posted by dguy <gi...@git.apache.org> on 2016/11/02 10:51:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4367) MirrorMaker shuts down gracefully without being stopped - posted by "Alex (JIRA)" <ji...@apache.org> on 2016/11/02 11:03:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4367) MirrorMaker shuts down gracefully without being stopped - posted by "Alex (JIRA)" <ji...@apache.org> on 2016/11/02 11:11:59 UTC, 2 replies.
- [jira] [Created] (KAFKA-4368) Unclean shutdown breaks Kafka cluster - posted by "Anukool Rattana (JIRA)" <ji...@apache.org> on 2016/11/02 11:14:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3703) Handle close gracefully for consumers and producers with acks=0 - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/02 11:37:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4365) In case async producer closes the TCP connection to Kafka broker, last sent messages might be lost. - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/02 11:42:58 UTC, 0 replies.
- 0.10.1.0 - KafkaConsumer.poll() blocks background heartbeat thread causing consumer to be considered dead? - posted by Jaikiran Pai <ja...@gmail.com> on 2016/11/02 14:14:56 UTC, 3 replies.
- [GitHub] kafka-site pull request #28: Add Becket to the committers page - posted by becketqin <gi...@git.apache.org> on 2016/11/02 17:01:56 UTC, 1 replies.
- [jira] [Created] (KAFKA-4369) ZkClient is not closed upon streams shutdown - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2016/11/02 17:05:59 UTC, 0 replies.
- [GitHub] kafka-site issue #28: Add Becket to the committers page - posted by becketqin <gi...@git.apache.org> on 2016/11/02 17:18:07 UTC, 0 replies.
- [GitHub] kafka pull request #2093: MINOR: Add description of how consumer wakeup acts... - posted by srdo <gi...@git.apache.org> on 2016/11/02 17:23:07 UTC, 1 replies.
- Re: [DISCUSS] KIP-81: Max in-flight fetches - posted by radai <ra...@gmail.com> on 2016/11/02 17:34:32 UTC, 6 replies.
- [jira] [Created] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send - posted by "Lars Pfannenschmidt (JIRA)" <ji...@apache.org> on 2016/11/02 18:21:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send - posted by "Lars Pfannenschmidt (JIRA)" <ji...@apache.org> on 2016/11/02 18:22:59 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/02 20:13:58 UTC, 2 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1668 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/02 20:52:42 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4369) ZkClient is not closed upon streams shutdown - posted by "Andy Chambers (JIRA)" <ji...@apache.org> on 2016/11/02 21:25:58 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1017 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/02 21:39:49 UTC, 0 replies.
- why cant SslTransportLayer be muted before handshake completion? - posted by radai <ra...@gmail.com> on 2016/11/02 23:24:20 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-4348) On Mac OS, KafkaConsumer.poll returns 0 when there are still messages on Kafka server - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/03 01:13:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4367) MirrorMaker shuts down gracefully without being stopped - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/03 01:55:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4368) Unclean shutdown breaks Kafka cluster - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/03 02:18:59 UTC, 2 replies.
- [GitHub] kafka pull request #2094: KAFKA-4360：Controller may deadLock when autoLead... - posted by xiguantiaozhan <gi...@git.apache.org> on 2016/11/03 03:58:10 UTC, 1 replies.
- [jira] [Commented] (KAFKA-955) After a leader change, messages sent with ack=0 are lost - posted by "Bill Zhang (JIRA)" <ji...@apache.org> on 2016/11/03 07:12:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4367) MirrorMaker shuts down gracefully without actually being stopped - posted by "Alex (JIRA)" <ji...@apache.org> on 2016/11/03 08:30:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4367) MirrorMaker shuts down gracefully without actually being stopped - posted by "Alex (JIRA)" <ji...@apache.org> on 2016/11/03 08:39:58 UTC, 2 replies.
- [jira] [Created] (KAFKA-4371) Sporadic ConnectException shuts down the whole connect process - posted by "Sagar Rao (JIRA)" <ji...@apache.org> on 2016/11/03 10:02:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2247) Merge kafka.utils.Time and kafka.common.utils.Time - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/03 10:18:59 UTC, 0 replies.
- [GitHub] kafka pull request #2095: KAFKA-2247: Merge kafka.utils.Time and kafka.commo... - posted by ijuma <gi...@git.apache.org> on 2016/11/03 10:55:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2247) Merge kafka.utils.Time and kafka.common.utils.Time - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 10:55:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-2247) Merge kafka.utils.Time and kafka.common.utils.Time - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/03 11:01:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1018 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/03 11:20:08 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4371) Sporadic ConnectException shuts down the whole connect process - posted by "Tianji Li (JIRA)" <ji...@apache.org> on 2016/11/03 11:47:58 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-4371) Sporadic ConnectException shuts down the whole connect process - posted by "Tianji Li (JIRA)" <ji...@apache.org> on 2016/11/03 11:50:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4372) Kafka Connect REST API does not handle DELETE of connector with slashes in their names - posted by "Olivier Girardot (JIRA)" <ji...@apache.org> on 2016/11/03 13:53:58 UTC, 0 replies.
- [GitHub] kafka pull request #2096: KAFKA-4372: Kafka Connect REST API does not handle... - posted by ogirardot <gi...@git.apache.org> on 2016/11/03 13:59:02 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4372) Kafka Connect REST API does not handle DELETE of connector with slashes in their names - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 13:59:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4373) Kafka Consumer API jumping offsets - posted by "Srinivasan Venkatraman (JIRA)" <ji...@apache.org> on 2016/11/03 14:53:59 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1669 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/03 14:56:23 UTC, 0 replies.
- [jira] [Created] (KAFKA-4374) Improve Response Errors Logging - posted by "Jesse Anderson (JIRA)" <ji...@apache.org> on 2016/11/03 16:37:58 UTC, 0 replies.
- [DISCUSS] KIP 88: DescribeGroups Protocol Update - posted by Vahid S Hashemian <va...@us.ibm.com> on 2016/11/03 18:09:46 UTC, 3 replies.
- [GitHub] kafka pull request #2097: KAFKA-4366: KafkaStreams.close() blocks indefinite... - posted by dguy <gi...@git.apache.org> on 2016/11/03 18:51:19 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 18:51:59 UTC, 1 replies.
- [jira] [Created] (KAFKA-4375) Kafka consumer may swallow some interrupts meant for the calling thread - posted by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2016/11/03 19:24:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4375) Kafka consumer may swallow some interrupts meant for the calling thread - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/11/03 19:58:58 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-4356) o.a.k.common.utils.SystemTime.sleep() swallows InterruptedException - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/11/03 20:07:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4376) Add scala 2.12 support - posted by "Bernard Leach (JIRA)" <ji...@apache.org> on 2016/11/03 21:35:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4377) Address 2.12 deprecations - posted by "Bernard Leach (JIRA)" <ji...@apache.org> on 2016/11/03 21:37:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4378) Address 2.12 eta-expansion warnings - posted by "Bernard Leach (JIRA)" <ji...@apache.org> on 2016/11/03 21:38:58 UTC, 0 replies.
- [GitHub] kafka pull request #2098: KAFA-4378: resolve eta-expansion of zero-argument ... - posted by leachbj <gi...@git.apache.org> on 2016/11/03 21:45:51 UTC, 0 replies.
- [GitHub] kafka pull request #2099: MINOR: Fix re-raise of python error in system test... - posted by ewencp <gi...@git.apache.org> on 2016/11/03 21:54:57 UTC, 1 replies.
- [GitHub] kafka pull request #2100: KAFKA-4375: Reset thread interrupted state in a fe... - posted by srdo <gi...@git.apache.org> on 2016/11/03 22:05:39 UTC, 0 replies.
- [GitHub] kafka pull request #2101: KAFKA-4377: remove deprecated scala.collection.Jav... - posted by leachbj <gi...@git.apache.org> on 2016/11/03 22:06:21 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4377) Address 2.12 deprecations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 22:06:59 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4375) Kafka consumer may swallow some interrupts meant for the calling thread - posted by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2016/11/03 22:06:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4376) Add scala 2.12 support - posted by "Bernard Leach (JIRA)" <ji...@apache.org> on 2016/11/03 22:07:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4375) Kafka consumer may swallow some interrupts meant for the calling thread - posted by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2016/11/03 22:11:58 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4375) Kafka consumer may swallow some interrupts meant for the calling thread - posted by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2016/11/03 22:12:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4373) Kafka Consumer API jumping offsets - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/04 00:22:58 UTC, 3 replies.
- [GitHub] kafka pull request #2102: KAFKA-2284: corrects value type in beforeReleasing... - posted by leachbj <gi...@git.apache.org> on 2016/11/04 01:10:32 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2284) ConsumerRebalanceListener receives wrong type in partitionOwnership values - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 01:10:58 UTC, 2 replies.
- [GitHub] kafka pull request #1707: KAFKA-4024: Fix metadata update to not apply backo... - posted by asfgit <gi...@git.apache.org> on 2016/11/04 06:20:43 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4024) First metadata update always take retry.backoff.ms milliseconds to complete - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/04 06:20:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4024) First metadata update always take retry.backoff.ms milliseconds to complete - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 06:20:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1020 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/04 09:22:26 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1670 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/04 09:38:39 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4371) Sporadic ConnectException shuts down the whole connect process - posted by "Sagar Rao (JIRA)" <ji...@apache.org> on 2016/11/04 11:30:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4379) Remove caching of dirty and removed keys from StoreChangeLogger - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/04 11:48:59 UTC, 0 replies.
- [jira] [Work started] (KAFKA-4379) Remove caching of dirty and removed keys from StoreChangeLogger - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/04 12:40:58 UTC, 0 replies.
- [GitHub] kafka pull request #2103: KAFKA-4379: Remove caching of dirty and removed ke... - posted by dguy <gi...@git.apache.org> on 2016/11/04 12:49:33 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4379) Remove caching of dirty and removed keys from StoreChangeLogger - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 12:49:59 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3151) kafka-consumer-groups.sh fail with sasl enabled - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2016/11/04 12:49:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/04 12:50:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4379) Remove caching of dirty and removed keys from StoreChangeLogger - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/04 12:50:58 UTC, 2 replies.
- Re: [DISCUSS] KIP-80: Kafka REST Server - posted by Manikumar <ma...@gmail.com> on 2016/11/04 15:57:32 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4372) Kafka Connect REST API does not handle DELETE of connector with slashes in their names - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/04 17:46:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3994) Deadlock between consumer heartbeat expiration and offset commit. - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/04 19:02:00 UTC, 2 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1021 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/04 20:00:17 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1671 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/04 20:02:39 UTC, 0 replies.
- [GitHub] kafka pull request #1969: MINOR: missing fullstop in doc for `max.partition.... - posted by asfgit <gi...@git.apache.org> on 2016/11/04 20:30:14 UTC, 0 replies.
- [jira] [Created] (KAFKA-4380) Remove CleanShutdownFile as 0.8.2 has been released - posted by "holdenk (JIRA)" <ji...@apache.org> on 2016/11/04 20:54:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4380) Remove CleanShutdownFile as 0.8.2 has been released - posted by "holdenk (JIRA)" <ji...@apache.org> on 2016/11/04 20:58:58 UTC, 1 replies.
- [GitHub] kafka pull request #2104: [KAFKA-4380] Remove cleanshutdownfile - posted by holdenk <gi...@git.apache.org> on 2016/11/04 20:59:06 UTC, 0 replies.
- [GitHub] kafka pull request #2105: KAFKA-4322 StateRestoreCallback begin and end indi... - posted by markcshelton <gi...@git.apache.org> on 2016/11/04 21:01:29 UTC, 10 replies.
- [jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 21:01:59 UTC, 17 replies.
- [GitHub] kafka pull request #1968: MINOR: missing whitespace in doc for `ssl.cipher.s... - posted by shikhar <gi...@git.apache.org> on 2016/11/04 21:02:22 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4322) StateRestoreCallback begin and end indication - posted by "Mark Shelton (JIRA)" <ji...@apache.org> on 2016/11/04 21:06:58 UTC, 3 replies.
- [DISCUSS] KIP-89: Allow sink connectors to decouple flush and offset commit - posted by Shikhar Bhushan <sh...@confluent.io> on 2016/11/04 21:16:24 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4161) Decouple flush and offset commits - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/11/04 21:18:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4381) Add per partition lag metric to KafkaConsumer. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/04 21:20:58 UTC, 0 replies.
- [jira] [Work started] (KAFKA-4381) Add per partition lag metric to KafkaConsumer. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/04 21:21:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1672 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/04 21:22:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-4382) Fix broken fragments in site docs - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2016/11/04 21:34:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4383) Update API design subsection to reflect the current implementation of Producer/Consumer - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2016/11/04 21:40:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1022 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/04 22:45:54 UTC, 0 replies.
- Re: [DISCUSS] KIP-72 Allow Sizing Incoming Request Queue in Bytes - posted by radai <ra...@gmail.com> on 2016/11/05 00:04:25 UTC, 0 replies.
- [GitHub] kafka-site pull request #29: Update the website repo link in code.html to po... - posted by becketqin <gi...@git.apache.org> on 2016/11/05 00:23:58 UTC, 1 replies.
- [GitHub] kafka-site issue #29: Update the website repo link in code.html to point to ... - posted by ijuma <gi...@git.apache.org> on 2016/11/05 00:25:13 UTC, 6 replies.
- [jira] [Commented] (KAFKA-4381) Add per partition lag metric to KafkaConsumer. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/05 00:30:58 UTC, 7 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1023 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/05 00:49:22 UTC, 0 replies.
- Use Android App as a “Producing client” for Kafka? - posted by li...@web.de on 2016/11/05 06:40:29 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3469) kafka-topics lock down znodes with user principal when zk security is enabled. - posted by "Mohammed amine GARMES (JIRA)" <ji...@apache.org> on 2016/11/05 14:43:59 UTC, 0 replies.
- [GitHub] kafka pull request #2106: Added unit tests for DefaultDecoder and StringDeco... - posted by ntrphanikumar <gi...@git.apache.org> on 2016/11/05 16:01:37 UTC, 0 replies.
- [jira] [Created] (KAFKA-4384) ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message - posted by "Jun He (JIRA)" <ji...@apache.org> on 2016/11/05 19:01:58 UTC, 0 replies.
- [jira] [Updated] (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 "Jun Yao (JIRA)" <ji...@apache.org> on 2016/11/06 04:34:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4385) producer is sending too many unnecessary meta data request if the meta data for a topic is not available - posted by "Jun Yao (JIRA)" <ji...@apache.org> on 2016/11/06 04:34:58 UTC, 0 replies.
- [GitHub] kafka pull request #2107: KAFKA-4385-avoid-unnecessary-meta-request-overhead - posted by yaojuncn <gi...@git.apache.org> on 2016/11/06 05:15:25 UTC, 0 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 "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/06 05:15:58 UTC, 6 replies.
- [jira] [Commented] (KAFKA-4384) ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/06 09:56:58 UTC, 8 replies.
- 回复： [DISCUSS] KIP-68 Add a consumed log retention before log retention - posted by 东方甲乙 <25...@qq.com> on 2016/11/06 14:10:40 UTC, 0 replies.
- Re: [DISCUSS] KIP-68 Add a consumed log retention before log retention - posted by Becket Qin <be...@gmail.com> on 2016/11/06 15:39:45 UTC, 1 replies.
- [jira] [Comment Edited] (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 "Jun Yao (JIRA)" <ji...@apache.org> on 2016/11/06 16:19:59 UTC, 0 replies.
- [GitHub] kafka pull request #2108: MINOR: Fix regex on connector path param in Connec... - posted by ewencp <gi...@git.apache.org> on 2016/11/07 01:05:43 UTC, 1 replies.
- [jira] [Created] (KAFKA-4386) Producer Metrics Explanation - posted by "Pratik kumar (JIRA)" <ji...@apache.org> on 2016/11/07 11:52:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4386) Producer Metrics Explanation - posted by "Pratik kumar (JIRA)" <ji...@apache.org> on 2016/11/07 11:53:59 UTC, 0 replies.
- [GitHub] kafka-site issue #26: add trademark symbol on all pages plus longer footer m... - posted by ijuma <gi...@git.apache.org> on 2016/11/07 14:31:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4384) ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/07 14:46:58 UTC, 4 replies.
- [GitHub] kafka pull request #2109: MINOR: fix incorrect logging in StreamThread - posted by dguy <gi...@git.apache.org> on 2016/11/07 15:18:49 UTC, 1 replies.
- replica fetch error and shuabing - posted by Json Tu <ka...@126.com> on 2016/11/07 15:35:53 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4382) Fix broken fragments in site docs - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/07 17:06:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4383) Update API design subsection to reflect the current implementation of Producer/Consumer - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/07 17:06:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4387) KafkaConsumer will enter an infinite loop if the polling thread is interrupted, and either commitSync or committed is called - posted by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2016/11/07 17:54:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4387) KafkaConsumer will enter an infinite loop if the polling thread is interrupted, and either commitSync or committed is called - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/07 18:11:59 UTC, 3 replies.
- [jira] [Created] (KAFKA-4388) Connect key and value converters are listed without default values - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/07 18:29:58 UTC, 0 replies.
- [GitHub] kafka pull request #2110: KAFKA-4387: Fix KafkaConsumer not responding corre... - posted by srdo <gi...@git.apache.org> on 2016/11/07 19:14:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4387) KafkaConsumer will enter an infinite loop if the polling thread is interrupted, and either commitSync or committed is called - posted by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2016/11/07 19:15:59 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1675 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/07 19:54:56 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1025 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/07 20:17:25 UTC, 0 replies.
- [VOTE] KIP-72 - Allow putting a bound on memory consumed by Incoming requests - posted by radai <ra...@gmail.com> on 2016/11/07 21:08:44 UTC, 25 replies.
- [jira] [Assigned] (KAFKA-3910) Cyclic schema support in ConnectSchema and SchemaBuilder - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/11/07 22:20:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4353) Add semantic types to Kafka Connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/07 23:45:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4386) Producer Metrics Explanation - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/08 01:29:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4389) kafka-server.stop.sh not work - posted by "JianwenSun (JIRA)" <ji...@apache.org> on 2016/11/08 02:47:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4389) kafka-server.stop.sh not work - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/08 03:16:00 UTC, 0 replies.
- [GitHub] kafka pull request #2111: throw exception when the connection is error. - posted by huyanping <gi...@git.apache.org> on 2016/11/08 04:23:52 UTC, 0 replies.
- [jira] [Created] (KAFKA-4390) Replace MessageSet usage with client-side equivalents - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/08 16:52:58 UTC, 0 replies.
- [GitHub] kafka pull request #2000: KAFKA-4284: Make Partitioner a Closeable and close... - posted by asfgit <gi...@git.apache.org> on 2016/11/08 17:54:28 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4284) Partitioner never closed by producer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/08 17:54:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4284) Partitioner never closed by producer - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/08 17:54:58 UTC, 0 replies.
- [GitHub] kafka pull request #2112: MINOR: fix typos and incorrect docs - posted by xvrl <gi...@git.apache.org> on 2016/11/08 19:14:19 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1026 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/08 19:48:39 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1676 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/08 20:55:28 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1027 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/08 20:55:33 UTC, 0 replies.
- [jira] [Created] (KAFKA-4391) On Windows, Kafka server stops with uncaught exception after coming back from sleep - posted by "Yiquan Zhou (JIRA)" <ji...@apache.org> on 2016/11/08 20:58:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4391) On Windows, Kafka server stops with uncaught exception after coming back from sleep - posted by "Yiquan Zhou (JIRA)" <ji...@apache.org> on 2016/11/08 21:02:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1677 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/08 22:13:56 UTC, 0 replies.
- [GitHub] kafka pull request #2113: KAFKA-4376: Cross compile to Scala 2.12.0 - posted by leachbj <gi...@git.apache.org> on 2016/11/08 22:37:11 UTC, 1 replies.
- [jira] [Created] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception - posted by "Ara Ebrahimi (JIRA)" <ji...@apache.org> on 2016/11/08 22:41:59 UTC, 0 replies.
- [GitHub] kafka pull request #2114: MINOR: add upgrade guide for Kafka Streams API - posted by mjsax <gi...@git.apache.org> on 2016/11/08 22:46:55 UTC, 1 replies.
- [GitHub] kafka pull request #1882: MINOR: some trace logging for streams debugging - posted by asfgit <gi...@git.apache.org> on 2016/11/08 22:50:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2016/11/08 22:55:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4391) On Windows, Kafka server stops with uncaught exception after coming back from sleep - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/08 23:28:59 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-4391) On Windows, Kafka server stops with uncaught exception after coming back from sleep - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/08 23:31:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4393) Improve invalid/negative TS handling - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/11/08 23:37:58 UTC, 0 replies.
- [GitHub] kafka pull request #2115: KAFKA-4364: Remove secrets from DEBUG logging - posted by rnpridgeon <gi...@git.apache.org> on 2016/11/08 23:39:37 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2016/11/08 23:39:59 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2016/11/08 23:40:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1028 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/08 23:55:39 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3901) KStreamTransformValues$KStreamTransformValuesProcessor#process() forwards null values - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/11/09 00:07:58 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-3901) KStreamTransformValues$KStreamTransformValuesProcessor#process() forwards null values - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/11/09 00:08:59 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1678 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/09 00:54:35 UTC, 0 replies.
- [GitHub] kafka pull request #2116: KAFKA-4362 : Consumer can fail after reassignment ... - posted by MayureshGharat <gi...@git.apache.org> on 2016/11/09 01:46:08 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4393) Improve invalid/negative TS handling - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/11/09 02:16:58 UTC, 2 replies.
- [GitHub] kafka pull request #2117: KAFKA-4393: Improve invalid/negative TS handling - posted by mjsax <gi...@git.apache.org> on 2016/11/09 02:38:46 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4393) Improve invalid/negative TS handling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/09 02:38:58 UTC, 0 replies.
- [GitHub] kafka pull request #2118: MINOR: improve exception message for incompatible ... - posted by mjsax <gi...@git.apache.org> on 2016/11/09 03:05:32 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled - posted by "hangzhao (JIRA)" <ji...@apache.org> on 2016/11/09 07:15:59 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled - posted by "hangzhao (JIRA)" <ji...@apache.org> on 2016/11/09 07:15:59 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4386) Producer Metrics Explanation - posted by "Pratik kumar (JIRA)" <ji...@apache.org> on 2016/11/09 09:20:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4367) MirrorMaker shuts down gracefully without actually being stopped - posted by "Alex (JIRA)" <ji...@apache.org> on 2016/11/09 10:50:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled - posted by "Catalina-Alina Dobrica (JIRA)" <ji...@apache.org> on 2016/11/09 12:20:58 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled - posted by "Catalina-Alina Dobrica (JIRA)" <ji...@apache.org> on 2016/11/09 12:33:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer - posted by "Catalina-Alina Dobrica (JIRA)" <ji...@apache.org> on 2016/11/09 12:34:58 UTC, 2 replies.
- [jira] [Created] (KAFKA-4394) Processor API does not receive timestamp and/or ConsumerRecord - posted by "Mark Shelton (JIRA)" <ji...@apache.org> on 2016/11/09 14:37:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4394) Processor API does not receive timestamp and/or ConsumerRecord - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/09 15:28:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4395) KafkaConfig and LogConfig should not have static initialization order dependencies - posted by "Sumant Tambe (JIRA)" <ji...@apache.org> on 2016/11/09 18:18:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4395) KafkaConfig and LogConfig should not have static initialization order dependencies - posted by "Sumant Tambe (JIRA)" <ji...@apache.org> on 2016/11/09 18:18:58 UTC, 0 replies.
- [GitHub] kafka pull request #2120: KAFKA-4395: Break static initialization order depe... - posted by sutambe <gi...@git.apache.org> on 2016/11/09 18:29:05 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4395) KafkaConfig and LogConfig should not have static initialization order dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/09 18:29:58 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4360) Controller may deadLock when autoLeaderRebalance encounter zk expired - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/09 18:38:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4311) Multi layer cache eviction causes forwarding to incorrect ProcessorNode - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/09 18:43:59 UTC, 1 replies.
- [GitHub] kafka pull request #2051: KAFKA-4311: Multi layer cache eviction causes forw... - posted by asfgit <gi...@git.apache.org> on 2016/11/09 18:44:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4311) Multi layer cache eviction causes forwarding to incorrect ProcessorNode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/09 18:44:58 UTC, 0 replies.
- Re: [DISCUSS] KIP 88: OffsetFetch Protocol Update - posted by Vahid S Hashemian <va...@us.ibm.com> on 2016/11/09 19:11:53 UTC, 2 replies.
- [GitHub] kafka pull request #2119: MINOR: remove unused fields from KTableImpl - posted by asfgit <gi...@git.apache.org> on 2016/11/09 19:18:22 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1029 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/09 19:56:11 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1030 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/09 20:55:31 UTC, 0 replies.
- [VOTE] KIP-89: Allow sink connectors to decouple flush and offset commit - posted by Shikhar Bhushan <sh...@confluent.io> on 2016/11/09 22:16:48 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/09 22:59:58 UTC, 0 replies.
- [GitHub] kafka-site pull request #30: New meetup links and kafka summit to events pag... - posted by derrickdoo <gi...@git.apache.org> on 2016/11/09 23:37:34 UTC, 1 replies.
- [jira] [Created] (KAFKA-4396) Seeing offsets not resetting even when reset policy is configured explicitly - posted by "Justin Miller (JIRA)" <ji...@apache.org> on 2016/11/09 23:49:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4396) Seeing offsets not resetting even when reset policy is configured explicitly - posted by "Justin Miller (JIRA)" <ji...@apache.org> on 2016/11/09 23:49:58 UTC, 2 replies.
- [jira] [Work started] (KAFKA-4161) Decouple flush and offset commits - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/11/10 00:28:58 UTC, 0 replies.
- Upgrading from kafka-0.8.1.1 to kafka-0.9.0.1 - posted by Divyajothi Baskaran <db...@expedia.com> on 2016/11/10 00:31:44 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1031 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/10 00:48:47 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1681 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/10 00:50:19 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.1-jdk7 #84 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/10 01:10:23 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4396) Seeing offsets not resetting even when reset policy is configured explicitly - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/10 01:15:58 UTC, 2 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1032 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/10 02:17:39 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4328) The parameters for creating the ZkUtils object is reverse - posted by "Matt Wang (JIRA)" <ji...@apache.org> on 2016/11/10 04:27:58 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4384) ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message - posted by "Jun He (JIRA)" <ji...@apache.org> on 2016/11/10 06:57:58 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1894) Avoid long or infinite blocking in the consumer - posted by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2016/11/10 14:31:59 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1682 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/10 16:55:00 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1033 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/10 17:48:58 UTC, 0 replies.
- any plans to switch to java 8? - posted by radai <ra...@gmail.com> on 2016/11/10 18:23:46 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-4394) Processor API does not receive timestamp and/or ConsumerRecord - posted by "Mark Shelton (JIRA)" <ji...@apache.org> on 2016/11/10 19:37:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/10 19:43:58 UTC, 9 replies.
- [jira] [Comment Edited] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/10 21:35:58 UTC, 0 replies.
- [GitHub] kafka pull request #2121: KAFKA-4392: race condition in directory cleanup - posted by guozhangwang <gi...@git.apache.org> on 2016/11/10 21:40:14 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1034 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 01:55:56 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1683 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 02:56:36 UTC, 0 replies.
- [GitHub] kafka pull request #2122: failing to close this iterator causes leaks in roc... - posted by norwood <gi...@git.apache.org> on 2016/11/11 04:21:16 UTC, 1 replies.
- [jira] [Created] (KAFKA-4397) Refactor Connect backing stores for thread-safety - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2016/11/11 06:43:59 UTC, 0 replies.
- [GitHub] kafka pull request #2123: KAFKA-4397: Refactor Connect backing stores for th... - posted by kkonstantine <gi...@git.apache.org> on 2016/11/11 07:40:35 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4397) Refactor Connect backing stores for thread-safety - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/11 07:40:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4346) Add foreachValue method to KStream - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 11:04:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4217) KStream.transform equivalent of flatMap - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:10:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4369) ZkClient is not closed upon streams shutdown - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:28:58 UTC, 0 replies.
- [GitHub] kafka pull request #2124: KAFKA-4359: Removed commit interval - posted by enothereska <gi...@git.apache.org> on 2016/11/11 12:52:21 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4359) Streams integration tests should not use commit interval of 1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/11 12:52:58 UTC, 1 replies.
- [jira] [Work started] (KAFKA-4359) Streams integration tests should not use commit interval of 1 - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:52:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4317) RocksDB checkpoint files lost on kill -9 - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:55:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4281) Should be able to forward aggregation values immediately - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:56:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:56:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:57:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4240) Remove disableLogging from API - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:57:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4219) Permit setting of event time in stream processor - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:57:58 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:57:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4218) Enable access to key in {{ValueTransformer}} - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 12:58:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 13:01:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4182) Move the change logger our of RocksDB stores - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 13:01:58 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4181) Processors punctuate() methods call multiple times - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 13:04:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4144) Allow per stream/table timestamp extractor - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 13:04:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3739) Add no-arg constructor for library provided serdes - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:47:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3705) Support non-key joining in KTable - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3262) Make KafkaStreams debugging friendly - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:50:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3262) Make KafkaStreams debugging friendly - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:51:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4199) When a window store segment is dropped we should also clear any corresponding cached entries - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:52:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:53:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3625) Move kafka-streams test fixtures into a published package - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3534) Deserialize on demand when default time extractor used - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 14:55:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4398) offsetsForTimes returns false starting offset when timestamp of messages are not monotonically increasing - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/11 15:31:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4398) offsetsForTimes returns false starting offset when timestamp of messages are not monotonically increasing - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/11 15:35:58 UTC, 4 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1035 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 15:56:06 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1684 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 16:09:01 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.1-jdk7 #85 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 16:09:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect - posted by "Chris Riccomini (JIRA)" <ji...@apache.org> on 2016/11/11 17:16:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3994) Deadlock between consumer heartbeat expiration and offset commit. - posted by "mjuarez (JIRA)" <ji...@apache.org> on 2016/11/11 18:23:59 UTC, 5 replies.
- Subscribe to Kafka - posted by Husayn Campbell <h_...@sbcglobal.net> on 2016/11/11 18:37:55 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4081) Consumer API consumer new interface commitSyn does not verify the validity of offset - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/11 18:37:59 UTC, 0 replies.
- [GitHub] kafka pull request #1827: KAFKA-4081: Consumer API consumer new interface co... - posted by asfgit <gi...@git.apache.org> on 2016/11/11 18:38:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4081) Consumer API consumer new interface commitSyn does not verify the validity of offset - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/11 18:38:58 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1036 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 18:51:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/11 18:56:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1685 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 18:58:27 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions. - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2016/11/11 19:01:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/11 19:01:00 UTC, 0 replies.
- [GitHub] kafka pull request #1972: KAFKA-3224: New log deletion policy based on times... - posted by bill-warshaw <gi...@git.apache.org> on 2016/11/11 19:23:26 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3224) Add timestamp-based log deletion policy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/11 19:23:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/11 19:42:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4399) Deadlock between cleanupGroupMetadata and offset commit - posted by "Alexey Ozeritskiy (JIRA)" <ji...@apache.org> on 2016/11/11 19:48:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4399) Deadlock between cleanupGroupMetadata and offset commit - posted by "Alexey Ozeritskiy (JIRA)" <ji...@apache.org> on 2016/11/11 19:49:58 UTC, 3 replies.
- [GitHub] kafka pull request #2125: KAFKA-4399; deadlock cleanupGroupMetadata and offs... - posted by resetius <gi...@git.apache.org> on 2016/11/11 19:59:47 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4399) Deadlock between cleanupGroupMetadata and offset commit - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/11 19:59:58 UTC, 4 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1686 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 20:15:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1037 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/11 20:46:37 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4281) Should be able to forward aggregation values immediately - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/11 20:56:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4270) ClassCast for Agregation - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/11 21:04:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3522) Consider adding version information into rocksDB storage format - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/11 21:05:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4212) Add a key-value store that is a TTL persistent cache - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/11 21:07:59 UTC, 1 replies.
- [GitHub] kafka pull request #2126: MINOR: Fix export command for additional env vars ... - posted by kkonstantine <gi...@git.apache.org> on 2016/11/11 21:41:49 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4120) byte[] keys in RocksDB state stores do not work as expected - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/11 22:09:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4120) byte[] keys in RocksDB state stores do not work as expected - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/11 22:10:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4400) Prefix for sink task consumer groups should be configurable - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/11 23:21:59 UTC, 0 replies.
- [Subscribe] - posted by Ashish Singh <as...@gmail.com> on 2016/11/12 00:20:56 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1038 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/12 00:50:27 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions. - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2016/11/12 02:21:58 UTC, 1 replies.
- [GitHub] kafka pull request #2127: KAFKA-4384: ReplicaFetcherThread stopped after Rep... - posted by jun-he <gi...@git.apache.org> on 2016/11/12 06:58:22 UTC, 1 replies.
- [jira] [Created] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/12 19:31:58 UTC, 0 replies.
- [GitHub] kafka pull request #1911: KAFKA-3829: Ensure valid configuration prior to cr... - posted by asfgit <gi...@git.apache.org> on 2016/11/13 00:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3829) Warn that kafka-connect group.id must not conflict with connector names - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/13 00:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3829) Warn that kafka-connect group.id must not conflict with connector names - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/13 00:14:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1039 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/13 01:42:37 UTC, 0 replies.
- [DISCUSS] KIP-92 - Add per partition lag metrics to KafkaConsumer - posted by Becket Qin <be...@gmail.com> on 2016/11/13 04:13:01 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-4398) offsetsForTimes returns false starting offset when timestamp of messages are not monotonically increasing - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/13 10:29:58 UTC, 0 replies.
- Re： [DISCUSS] KIP-68 Add a consumed log retention before log retention - posted by 东方甲乙 <25...@qq.com> on 2016/11/13 14:16:47 UTC, 1 replies.
- [jira] [Created] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fashion" - posted by "Jun Yao (JIRA)" <ji...@apache.org> on 2016/11/13 21:40:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class. - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/13 21:41:59 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fashion" - posted by "Jun Yao (JIRA)" <ji...@apache.org> on 2016/11/13 21:45:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4402) Kafka Producer's DefaultPartitioner is actually not round robin as said in the code comments "If no partition or key is present choose a partition in a round-robin fashion" - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/13 21:45:58 UTC, 6 replies.
- [GitHub] kafka pull request #2128: KAFKA-4402: make the KafkaProducer true round robi... - posted by yaojuncn <gi...@git.apache.org> on 2016/11/13 21:47:32 UTC, 2 replies.
- [jira] [Created] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/13 21:51:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4021) system tests need to enable trace level logging for controller and state-change log - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/14 00:18:59 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3967) Excessive Network IO between Kafka brokers - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/14 00:48:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4404) Add knowledge of sign to numeric schema types - posted by "Andy Bryant (JIRA)" <ji...@apache.org> on 2016/11/14 03:35:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/14 04:36:58 UTC, 7 replies.
- [jira] [Created] (KAFKA-4405) Kafka consumer improperly send prefetch request - posted by "ysysberserk (JIRA)" <ji...@apache.org> on 2016/11/14 08:38:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4268) huge server.logs during the error frequently happen "Message format version for partition 200 not found" - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/14 10:22:58 UTC, 0 replies.
- [VOTE] KIP-84: Support SASL SCRAM mechanisms - posted by Rajini Sivaram <ra...@googlemail.com> on 2016/11/14 13:57:16 UTC, 10 replies.
- [jira] [Created] (KAFKA-4406) Add support for custom Java Security Providers in configuration - posted by "Magnus Reftel (JIRA)" <ji...@apache.org> on 2016/11/14 13:57:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4407) Java consumer does not always send LEAVE_GROUP request during shut down - posted by "Igor (JIRA)" <ji...@apache.org> on 2016/11/14 15:40:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4408) KTable doesn't work with ProcessorTopologyTestDriver in Kafka 0.10.1.0 - posted by "Byron Nikolaidis (JIRA)" <ji...@apache.org> on 2016/11/14 15:48:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4404) Add knowledge of sign to numeric schema types - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/14 17:14:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4409) ZK consumer shutdown/topic event deadlock - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2016/11/14 17:42:58 UTC, 0 replies.
- [GitHub] kafka pull request #2129: KAFKA-4409; Fix deadlock between topic event handl... - posted by jjkoshy <gi...@git.apache.org> on 2016/11/14 17:50:57 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4409) ZK consumer shutdown/topic event deadlock - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/14 17:50:58 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4409) ZK consumer shutdown/topic event deadlock - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/14 18:08:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4409) ZK consumer shutdown/topic event deadlock - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/14 18:09:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1040 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/14 18:56:12 UTC, 0 replies.
- [jira] [Work started] (KAFKA-4393) Improve invalid/negative TS handling - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/11/14 19:29:59 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3008) Connect should parallelize task start/stop - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2016/11/14 19:53:59 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4306) Connect workers won't shut down if brokers are not available - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2016/11/14 19:54:59 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4154) Kafka Connect fails to shutdown if it has not completed startup - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2016/11/14 19:55:00 UTC, 0 replies.
- [GitHub] kafka pull request #1714: KAFKA-4011 - fix issues and beef up tests around B... - posted by radai-rosenblatt <gi...@git.apache.org> on 2016/11/14 21:49:06 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4011) allow sizing RequestQueue in bytes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/14 21:49:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4011) allow sizing RequestQueue in bytes - posted by "radai rosenblatt (JIRA)" <ji...@apache.org> on 2016/11/14 21:50:58 UTC, 0 replies.
- [GitHub] kafka pull request #2130: MINOR: Extract SCALA_BINARY_VERSION from SCALA_VER... - posted by kkonstantine <gi...@git.apache.org> on 2016/11/14 22:11:33 UTC, 1 replies.
- Kafka 0.10 Monitoring tool - posted by "Ghosh, Achintya (Contractor)" <Ac...@comcast.com> on 2016/11/14 22:16:19 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3462) Allow SinkTasks to disable consumer offset commit - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/11/15 00:24:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2066) Replace FetchRequest / FetchResponse with their org.apache.kafka.common.requests equivalents - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/15 00:46:58 UTC, 0 replies.
- [GitHub] kafka pull request #2069: KAFKA-2066: Use client-side FetchRequest/FetchResp... - posted by asfgit <gi...@git.apache.org> on 2016/11/15 00:47:14 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2066) Replace FetchRequest / FetchResponse with their org.apache.kafka.common.requests equivalents - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 00:47:58 UTC, 0 replies.
- [GitHub] kafka pull request #2131: Remove failing ConnectDistributedTest.test_bad_con... - posted by shikhar <gi...@git.apache.org> on 2016/11/15 00:59:40 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-4404) Add knowledge of sign to numeric schema types - posted by "Andy Bryant (JIRA)" <ji...@apache.org> on 2016/11/15 02:40:59 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1041 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/15 02:53:25 UTC, 0 replies.
- [GitHub] kafka pull request #2132: add a space to separate two words - posted by ZhengQian1 <gi...@git.apache.org> on 2016/11/15 06:13:08 UTC, 1 replies.
- [jira] [Created] (KAFKA-4410) KafkaController sends double the expected number of StopReplicaRequests during controlled shutdown - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/15 08:43:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4410) KafkaController sends double the expected number of StopReplicaRequests during controlled shutdown - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/15 08:51:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4410) KafkaController sends double the expected number of StopReplicaRequests during controlled shutdown - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/15 08:59:58 UTC, 0 replies.
- [GitHub] kafka pull request #2133: KAFKA-4355: Skip topics that have no partitions - posted by enothereska <gi...@git.apache.org> on 2016/11/15 10:04:06 UTC, 3 replies.
- [jira] [Updated] (KAFKA-3637) Add method that checks if streams are initialised - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/15 10:53:59 UTC, 1 replies.
- [GitHub] kafka pull request #2134: config: add ssl.provider.classes config option - posted by reftel <gi...@git.apache.org> on 2016/11/15 11:25:24 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4406) Add support for custom Java Security Providers in configuration - posted by "Magnus Reftel (JIRA)" <ji...@apache.org> on 2016/11/15 11:29:58 UTC, 9 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4406) Add support for custom Java Security Providers in configuration - posted by "Magnus Reftel (JIRA)" <ji...@apache.org> on 2016/11/15 11:30:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4406) Add support for custom Java Security Providers in configuration - posted by "Magnus Reftel (JIRA)" <ji...@apache.org> on 2016/11/15 11:31:59 UTC, 0 replies.
- [GitHub] kafka pull request #2135: KAFKA-3637: Added initial states - posted by enothereska <gi...@git.apache.org> on 2016/11/15 11:43:22 UTC, 4 replies.
- [jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 11:43:58 UTC, 4 replies.
- [GitHub] kafka pull request #2136: MINOR: Remove unused code - posted by ijuma <gi...@git.apache.org> on 2016/11/15 11:54:41 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1548) Refactor the "replica_id" in requests - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2016/11/15 13:33:58 UTC, 0 replies.
- [GitHub] kafka pull request #2137: KAFKA-1548 Refactor the "replica_id" in requests - posted by baluchicken <gi...@git.apache.org> on 2016/11/15 13:34:17 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1548) Refactor the "replica_id" in requests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 13:34:59 UTC, 0 replies.
- [jira] [Work started] (KAFKA-1548) Refactor the "replica_id" in requests - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2016/11/15 13:35:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4407) Java consumer does not always send LEAVE_GROUP request during shut down - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/15 13:46:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4407) Java consumer does not always send LEAVE_GROUP request during shut down - posted by "Igor (JIRA)" <ji...@apache.org> on 2016/11/15 13:53:58 UTC, 0 replies.
- [GitHub] kafka pull request #2041: MINOR: Clarify how to fix conversion issues when p... - posted by asfgit <gi...@git.apache.org> on 2016/11/15 14:24:33 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3469) kafka-topics lock down znodes with user principal when zk security is enabled. - posted by "Mohammed amine GARMES (JIRA)" <ji...@apache.org> on 2016/11/15 15:22:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4411) broker don't have access to kafka zookeeper nodes - posted by "Mohammed amine GARMES (JIRA)" <ji...@apache.org> on 2016/11/15 15:36:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1933) Fine-grained locking in log append - posted by "Maxim Ivanov (JIRA)" <ji...@apache.org> on 2016/11/15 16:05:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-559) Garbage collect old consumer metadata entries - posted by "tony mancill (JIRA)" <ji...@apache.org> on 2016/11/15 16:18:58 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-559) Garbage collect old consumer metadata entries - posted by "tony mancill (JIRA)" <ji...@apache.org> on 2016/11/15 17:20:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4412) Replication fetch stuck in loop on offset null - posted by "Xavier Lange (JIRA)" <ji...@apache.org> on 2016/11/15 18:27:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4413) Kakfa should support default SSLContext - posted by "Wenjie Zhang (JIRA)" <ji...@apache.org> on 2016/11/15 22:36:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4413) Kakfa should support default SSLContext - posted by "Wenjie Zhang (JIRA)" <ji...@apache.org> on 2016/11/15 22:43:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4414) Unexpected "Halting because log truncation is not allowed" - posted by "Meyer Kizner (JIRA)" <ji...@apache.org> on 2016/11/15 23:21:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4414) Unexpected "Halting because log truncation is not allowed" - posted by "Meyer Kizner (JIRA)" <ji...@apache.org> on 2016/11/15 23:24:58 UTC, 0 replies.
- [GitHub] kafka pull request #2138: KAFKA-4331: Kafka Streams resetter is slow because... - posted by mjsax <gi...@git.apache.org> on 2016/11/16 00:42:59 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4331) Kafka Streams resetter is slow because it joins the same group for each topic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 00:43:59 UTC, 1 replies.
- [GitHub] kafka pull request #2139: KAFKA-4161: KIP-89: Allow sink connectors to decou... - posted by shikhar <gi...@git.apache.org> on 2016/11/16 01:00:22 UTC, 0 replies.
- [GitHub] kafka pull request #2140: KAFKA-4390: Replace MessageSet usage with client-s... - posted by hachikuji <gi...@git.apache.org> on 2016/11/16 04:24:09 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4390) Replace MessageSet usage with client-side equivalents - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 04:24:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/16 04:47:58 UTC, 0 replies.
- [GitHub] kafka pull request #2141: KAFKA-4415; Reduce time to create and send Metadat... - posted by lindong28 <gi...@git.apache.org> on 2016/11/16 05:32:46 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 05:32:58 UTC, 4 replies.
- [jira] [Commented] (KAFKA-4414) Unexpected "Halting because log truncation is not allowed" - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/16 05:38:58 UTC, 2 replies.
- [GitHub] kafka pull request #2142: Merge pull request #1 from apache/trunk - posted by husthang <gi...@git.apache.org> on 2016/11/16 09:27:57 UTC, 1 replies.
- [GitHub] kafka pull request #2136: MINOR: Remove unused `ByteBoundedBlockingQueue` cl... - posted by asfgit <gi...@git.apache.org> on 2016/11/16 17:52:19 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1043 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/16 19:22:01 UTC, 0 replies.
- [GitHub] kafka pull request #1791: KAFKA-4089: KafkaProducer expires batch when metad... - posted by sutambe <gi...@git.apache.org> on 2016/11/16 19:23:25 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4089) KafkaProducer raises Batch Expired exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 19:23:58 UTC, 0 replies.
- [GitHub] kafka pull request #2143: KAFKA-4400: Enabling configurable prefix for sink ... - posted by skyahead <gi...@git.apache.org> on 2016/11/16 19:53:37 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4400) Prefix for sink task consumer groups should be configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 19:53:59 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1693 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/16 20:29:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4359) Streams integration tests should not use commit interval of 1 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/16 20:46:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1044 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/16 21:53:13 UTC, 0 replies.
- [jira] [Created] (KAFKA-4416) Add a '--group' option to the console consumer - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/16 21:57:58 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1694 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/16 22:57:25 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1045 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/16 23:31:48 UTC, 0 replies.
- [GitHub] kafka pull request #2060: KAFKA-4211: Update system tests to use the new con... - posted by asfgit <gi...@git.apache.org> on 2016/11/17 00:31:37 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4211) Change system tests to use the new consumer by default - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/17 00:31:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4376) Add scala 2.12 support - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/17 03:45:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4376) Add scala 2.12 support - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/17 03:45:58 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/17 03:49:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1047 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/17 04:37:01 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1048 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/17 05:18:54 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1696 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/17 06:38:42 UTC, 0 replies.
- Kafka high cpu usage - posted by Andrey Dyachkov <an...@gmail.com> on 2016/11/17 07:34:59 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1697 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/17 09:25:57 UTC, 0 replies.
- Kafka gives very few number of messages - posted by Hoang Bao Thien <hb...@gmail.com> on 2016/11/17 09:45:10 UTC, 0 replies.
- Kafka 0.7 - problem with link to config - posted by Arik Sher <ar...@ebsbrokertec.com> on 2016/11/17 09:57:21 UTC, 1 replies.
- [jira] [Created] (KAFKA-4417) Update build dependencies for 0.10.2 cycle - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/17 10:30:58 UTC, 0 replies.
- [GitHub] kafka pull request #2144: KAFKA-4417: Update build dependencies for 0.10.2 c... - posted by ijuma <gi...@git.apache.org> on 2016/11/17 10:50:46 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4417) Update build dependencies for 0.10.2 cycle - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/17 10:50:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3209) Support single message transforms in Kafka Connect - posted by "Juan Jesus Chorro (JIRA)" <ji...@apache.org> on 2016/11/17 11:51:58 UTC, 1 replies.
- Re: [DISCUSS] Deprecating the old consumers in trunk - posted by Ismael Juma <is...@juma.me.uk> on 2016/11/17 15:37:16 UTC, 7 replies.
- [jira] [Created] (KAFKA-4418) Broker Leadership Election Fails If Missing ZK Path Raises Exception - posted by "Michael Pedersen (JIRA)" <ji...@apache.org> on 2016/11/17 15:41:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4418) Broker Leadership Election Fails If Missing ZK Path Raises Exception - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/17 15:43:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4419) Unable to GetOffset when the ACL of topic is defined - posted by "Mohammed amine GARMES (JIRA)" <ji...@apache.org> on 2016/11/17 16:04:58 UTC, 0 replies.
- [GitHub] kafka pull request #2145: MINOR: Remove unused code in `LeaderAndIsr`, `ApiU... - posted by ijuma <gi...@git.apache.org> on 2016/11/17 16:36:51 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4211) Change system tests to use the new consumer by default - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/17 18:09:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1941) Timeout connections in the clients - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2016/11/17 20:08:58 UTC, 0 replies.
- [GitHub] kafka pull request #1588: KAFKA-3825: Allow users to specify different types... - posted by asfgit <gi...@git.apache.org> on 2016/11/17 20:53:36 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3825) Allow users to specify different types of state stores in Streams DSL - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/17 20:53:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3825) Allow users to specify different types of state stores in Streams DSL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/17 20:53:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4413) Kakfa should support default SSLContext - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/17 20:56:59 UTC, 0 replies.
- [GitHub] kafka-site pull request #26: add trademark symbol on all pages plus longer f... - posted by derrickdoo <gi...@git.apache.org> on 2016/11/17 20:57:29 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1941) Timeout connections in the clients - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2016/11/17 20:57:58 UTC, 0 replies.
- [GitHub] kafka-site pull request #31: Documentation nav updates for older versions of... - posted by derrickdoo <gi...@git.apache.org> on 2016/11/17 21:05:57 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4419) Unable to GetOffset when the ACL of topic is defined - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/17 21:10:58 UTC, 2 replies.
- [GitHub] kafka pull request #2146: KAFKA-4272: Add missing 'connect' Windows batch sc... - posted by vahidhashemian <gi...@git.apache.org> on 2016/11/17 22:02:47 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4272) Kafka Connect batch scripts are missing under `bin/windows/` - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/17 22:02:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4272) Kafka Connect batch scripts are missing under `bin/windows/` - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/17 22:02:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1698 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/17 22:13:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1049 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/17 22:36:42 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4417) Update build dependencies for 0.10.2 cycle - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/17 22:43:58 UTC, 0 replies.
- [GitHub] kafka pull request #2147: revert corrupted commit 10cfc1628df024f7596d3af5c1... - posted by mjsax <gi...@git.apache.org> on 2016/11/17 23:09:00 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1050 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/18 00:50:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-4420) Group StopReplicaRequests for partitions on the same broker into one StopReplicaRequest - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/18 00:53:59 UTC, 0 replies.
- [GitHub] kafka pull request #2148: KAFKA-4420; Group StopReplicaRequests for partitio... - posted by lindong28 <gi...@git.apache.org> on 2016/11/18 00:55:15 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4420) Group StopReplicaRequests for partitions on the same broker into one StopReplicaRequest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 00:55:58 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1699 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/18 00:56:09 UTC, 0 replies.
- Jenkins build is back to normal : kafka-0.10.1-jdk7 #86 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/18 03:17:07 UTC, 0 replies.
- [GitHub] kafka pull request #2072: Kafka-4351: Topic regex behavioral change with Mir... - posted by amethystic <gi...@git.apache.org> on 2016/11/18 05:18:52 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4377) Remove deprecated scala.collection.JavaConversions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/18 14:11:58 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-4377) Remove deprecated scala.collection.JavaConversions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/18 14:11:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/18 14:15:59 UTC, 0 replies.
- [GitHub] kafka pull request #2149: HOTFIX: Hotfix streams smoke test - posted by enothereska <gi...@git.apache.org> on 2016/11/18 14:17:45 UTC, 1 replies.
- [jira] [Created] (KAFKA-4422) Drop support for Scala 2.10 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/18 14:36:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4423) Drop support for Java 7 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/18 15:01:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4422) Drop support for Scala 2.10 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/18 15:01:09 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4373) Kafka Consumer API jumping offsets - posted by "Conor Hughes (JIRA)" <ji...@apache.org> on 2016/11/18 16:42:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1051 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/18 17:12:40 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3701) Expose KafkaStreams metrics in public API - posted by "Mitch Seymour (JIRA)" <ji...@apache.org> on 2016/11/18 18:46:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4270) ClassCast for Agregation - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/18 19:56:58 UTC, 0 replies.
- [GitHub] kafka pull request #2150: KAFKA-4416: Add a `--group` option to console cons... - posted by vahidhashemian <gi...@git.apache.org> on 2016/11/18 20:20:40 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4416) Add a '--group' option to the console consumer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 20:20:58 UTC, 0 replies.
- [DISCUSS] KIP-93: Improve invalid timestamp handling in Kafka Streams - posted by "Matthias J. Sax" <ma...@confluent.io> on 2016/11/18 20:27:02 UTC, 7 replies.
- [jira] [Updated] (KAFKA-4416) Add a '--group' option to the console consumer - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/18 22:20:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4270) ClassCast for Agregation - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/18 22:40:59 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-4270) ClassCast for Agregation - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/18 22:41:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4420) Group StopReplicaRequests for partitions on the same broker into one StopReplicaRequest - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/19 01:28:58 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4420) Group StopReplicaRequests for partitions on the same broker into one StopReplicaRequest - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/19 01:28:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/19 01:48:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1701 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/19 02:55:03 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1052 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/19 03:52:07 UTC, 0 replies.
- [GitHub] kafka pull request #1836: KAFKA-3703: Graceful close for consumers and produ... - posted by asfgit <gi...@git.apache.org> on 2016/11/19 09:35:26 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3703) Handle close gracefully for consumers and producers with acks=0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/19 09:35:58 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1702 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/19 10:56:21 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1053 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/19 11:47:00 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1703 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/19 12:13:11 UTC, 0 replies.
- [GitHub] kafka pull request #2151: Feature/authorizer name reference - posted by reftel <gi...@git.apache.org> on 2016/11/19 13:48:17 UTC, 0 replies.
- Resources about Apache Kafka - posted by Irosha Alahakoon <al...@gmail.com> on 2016/11/20 12:30:39 UTC, 1 replies.
- [GitHub] kafka pull request #2152: MINOR: make serializer classes final - posted by MatthiasBechtold <gi...@git.apache.org> on 2016/11/20 12:49:25 UTC, 0 replies.
- [jira] [Created] (KAFKA-4424) Make serializer classes final - posted by "Matthias Bechtold (JIRA)" <ji...@apache.org> on 2016/11/20 13:48:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4424) Make serializer classes final - posted by "Michael Andre Pearce (IG) (JIRA)" <ji...@apache.org> on 2016/11/20 16:48:58 UTC, 6 replies.
- [jira] [Created] (KAFKA-4425) Topic created with CreateTopic command not listed in Metadata - posted by "Mark de Jong (JIRA)" <ji...@apache.org> on 2016/11/20 17:56:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4425) Topic created with CreateTopic command not listed in Metadata - posted by "Mark de Jong (JIRA)" <ji...@apache.org> on 2016/11/20 17:56:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4425) Topic created with CreateTopic command, does not list partitions in metadata - posted by "Mark de Jong (JIRA)" <ji...@apache.org> on 2016/11/20 17:58:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4378) Address 2.12 eta-expansion warnings - posted by "Bernard Leach (JIRA)" <ji...@apache.org> on 2016/11/20 22:04:58 UTC, 0 replies.
- scala 2.12 artifacts - posted by Bernard Leach <le...@bouncycastle.org> on 2016/11/20 22:28:34 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4425) Topic created with CreateTopic command, does not list partitions in metadata - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/21 01:50:58 UTC, 9 replies.
- [GitHub] kafka pull request #2153: MINOR: Update JavaDoc of KStream interface - posted by mjsax <gi...@git.apache.org> on 2016/11/21 05:52:16 UTC, 0 replies.
- [jira] [Created] (KAFKA-4426) Add consumer.close(timeout, unit) for graceful close with timeout - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/21 09:40:58 UTC, 0 replies.
- [GitHub] kafka pull request #2154: HOTFIX: Increased wait time - posted by enothereska <gi...@git.apache.org> on 2016/11/21 09:47:02 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3514) Stream timestamp computation needs some further thoughts - posted by "Michal Borowiecki (JIRA)" <ji...@apache.org> on 2016/11/21 09:55:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3038) Speeding up partition reassignment after broker failure - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/21 09:59:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4427) Skip topicGroups with no tasks - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/21 10:03:59 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4425) Topic created with CreateTopic command, does not list partitions in metadata - posted by "Mark de Jong (JIRA)" <ji...@apache.org> on 2016/11/21 10:29:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3701) Expose KafkaStreams metrics in public API - posted by "Mitch Seymour (JIRA)" <ji...@apache.org> on 2016/11/21 13:01:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4428) Kafka does not exit when it receives "Address already in use" error during startup - posted by "Zeynep Arikoglu (JIRA)" <ji...@apache.org> on 2016/11/21 13:29:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4428) Kafka does not exit when it receives "Address already in use" error during startup - posted by "Zeynep Arikoglu (JIRA)" <ji...@apache.org> on 2016/11/21 13:32:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4271) The console consumer fails on Windows with new consumer is used - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/21 19:21:00 UTC, 5 replies.
- should HeartbeatThread be a daemon thread? - posted by David Judd <dj...@stripe.com.INVALID> on 2016/11/21 22:03:06 UTC, 2 replies.
- [jira] [Created] (KAFKA-4429) records-lag should be zero if FetchResponse is empty - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/22 00:23:58 UTC, 0 replies.
- [GitHub] kafka pull request #2155: KAFKA-4429; records-lag should be zero if FetchRes... - posted by lindong28 <gi...@git.apache.org> on 2016/11/22 00:39:40 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4429) records-lag should be zero if FetchResponse is empty - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/22 00:39:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4428) Kafka does not exit when it receives "Address already in use" error during startup - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/22 02:16:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4430) Broker logging Topic and partition to exceptions: [topic,6] -> kafka.common.MessageSizeTooLargeException - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2016/11/22 02:19:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4430) Broker logging Topic and partition to exceptions: [topic,6] -> kafka.common.MessageSizeTooLargeException - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2016/11/22 02:20:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4430) Broker logging "Topic and partition to exceptions: [topic,6] -> kafka.common.MessageSizeTooLargeException" - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2016/11/22 02:21:59 UTC, 8 replies.
- [jira] [Commented] (KAFKA-4428) Kafka does not exit when it receives "Address already in use" error during startup - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/22 03:31:59 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4428) Kafka does not exit when it receives "Address already in use" error during startup - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/22 03:32:59 UTC, 1 replies.
- [GitHub] kafka pull request #2156: kafka-4428: Kafka does not exit when it receives "... - posted by amethystic <gi...@git.apache.org> on 2016/11/22 03:42:11 UTC, 0 replies.
- KafkaProducer - posted by 揣立武 <ch...@meituan.com> on 2016/11/22 03:57:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-4431) HeartbeatThread should be a daemon thread - posted by "David Judd (JIRA)" <ji...@apache.org> on 2016/11/22 05:16:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4430) Broker logging "Topic and partition to exceptions: [topic,6] -> kafka.common.MessageSizeTooLargeException" - posted by "huxi (JIRA)" <ji...@apache.org> on 2016/11/22 06:29:58 UTC, 11 replies.
- [jira] [Created] (KAFKA-4432) ProducerPerformance.java : Add support to supply custom message payloads. - posted by "Sandesh Karkera (JIRA)" <ji...@apache.org> on 2016/11/22 09:46:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4432) ProducerPerformance.java : Add support to supply custom message payloads. - posted by "Sandesh Karkera (JIRA)" <ji...@apache.org> on 2016/11/22 09:49:58 UTC, 3 replies.
- [GitHub] kafka pull request #2157: Typo in Javadoc - posted by astubbs <gi...@git.apache.org> on 2016/11/22 10:10:36 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3175) topic not accessible after deletion even when delete.topic.enable is disabled - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/22 12:09:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3175) topic not accessible after deletion even when delete.topic.enable is disabled - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/22 12:10:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4432) ProducerPerformance.java : Add support to supply custom message payloads. - posted by "Sandesh Karkera (JIRA)" <ji...@apache.org> on 2016/11/22 13:05:58 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1704 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/22 13:08:42 UTC, 0 replies.
- [GitHub] kafka pull request #2158: KAFKA-4432: Added support to supply custom message... - posted by SandeshKarkera <gi...@git.apache.org> on 2016/11/22 15:58:37 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/22 17:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4322) StateRestoreCallback begin and end indication - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/22 18:09:58 UTC, 0 replies.
- Kafka consumers are not equally distributed - posted by "Ghosh, Achintya (Contractor)" <Ac...@comcast.com> on 2016/11/22 19:03:06 UTC, 2 replies.
- Restrict consumers from connecting to Kafka cluster - posted by ravi singh <rr...@gmail.com> on 2016/11/22 19:13:07 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1055 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/22 19:38:28 UTC, 0 replies.
- [GitHub] kafka-site pull request #32: Added section for Kafka Summit on the Events pa... - posted by derrickdoo <gi...@git.apache.org> on 2016/11/22 19:39:40 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1705 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/22 19:55:44 UTC, 0 replies.
- [GitHub] kafka pull request #2159: KAFKA 4273 - Add TTL support for RocksDB - posted by dpoldrugo <gi...@git.apache.org> on 2016/11/22 21:52:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/22 21:52:58 UTC, 0 replies.
- [GitHub] kafka pull request #2160: KAFKA-4095: Remove topic offsets and owners from Z... - posted by vahidhashemian <gi...@git.apache.org> on 2016/11/22 23:29:37 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 "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/22 23:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1120) Controller could miss a broker state change - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/11/22 23:31:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/22 23:32:58 UTC, 0 replies.
- [GitHub] kafka-site issue #32: Added section for Kafka Summit on the Events page - posted by guozhangwang <gi...@git.apache.org> on 2016/11/22 23:48:23 UTC, 0 replies.
- [GitHub] kafka pull request #2121: KAFKA-4392: Fix race condition in directory cleanu... - posted by guozhangwang <gi...@git.apache.org> on 2016/11/22 23:48:54 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 2016/11/23 00:18:58 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4271) The console consumer fails on Windows with new consumer is used - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/23 00:21:59 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-1120) Controller could miss a broker state change - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/11/23 01:03:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4433) Kafka Controller Does not send a LeaderAndIsr to old leader of a topicPartition during reassignment, if the old leader is not a part of the new assigned replicas - posted by "Mayuresh Gharat (JIRA)" <ji...@apache.org> on 2016/11/23 02:25:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1706 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/23 05:57:10 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1056 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/23 06:50:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4362) Consumer can fail after reassignment of the offsets topic partition - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/23 08:27:58 UTC, 0 replies.
- [GitHub] kafka pull request #2161: KAFKA-4307 Inconsistent parameters between console... - posted by baluchicken <gi...@git.apache.org> on 2016/11/23 08:48:46 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4307) Inconsistent parameters between console producer and consumer - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2016/11/23 08:48:58 UTC, 0 replies.
- [GitHub] kafka pull request #2162: Fixed kafka stop error - posted by muliliao <gi...@git.apache.org> on 2016/11/23 09:43:55 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4425) Topic created with CreateTopic command, does not list partitions in metadata - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/23 09:48:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4395) KafkaConfig and LogConfig should not have static initialization order dependencies - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/23 11:07:58 UTC, 0 replies.
- [GitHub] kafka pull request #2163: fix issue: stop kafka or zookeeper failed when ful... - posted by muliliao <gi...@git.apache.org> on 2016/11/23 11:30:32 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1057 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/23 12:46:53 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1707 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/23 12:56:50 UTC, 0 replies.
- [jira] [Created] (KAFKA-4434) KafkaProducer configuration is logged twice - posted by "Ruben de Gooijer (JIRA)" <ji...@apache.org> on 2016/11/23 13:55:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4434) KafkaProducer configuration is logged twice - posted by "Ruben de Gooijer (JIRA)" <ji...@apache.org> on 2016/11/23 13:59:59 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4434) KafkaProducer configuration is logged twice - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/23 14:11:58 UTC, 3 replies.
- [jira] [Updated] (KAFKA-4302) Simplify KTableSource - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 14:57:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4352) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 14:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 14:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4275) Check of State-Store-assignment to Processor-Nodes is not enabled - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 15:01:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4331) Kafka Streams resetter is slow because it joins the same group for each topic - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 15:01:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4361) Streams does not respect user configs for "default" params - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 15:02:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 15:05:58 UTC, 0 replies.
- A strange controller log in Kafka 0.9.0.1 - posted by Json Tu <ka...@126.com> on 2016/11/23 15:28:42 UTC, 4 replies.
- [jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "derek (JIRA)" <ji...@apache.org> on 2016/11/23 15:32:00 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "derek (JIRA)" <ji...@apache.org> on 2016/11/23 15:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1429) Yet another deadlock in controller shutdown - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/11/23 16:40:58 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4424) Make serializer classes final - posted by "Matthias Bechtold (JIRA)" <ji...@apache.org> on 2016/11/23 16:50:58 UTC, 14 replies.
- [jira] [Updated] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:15:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:16:59 UTC, 0 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 "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:16:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4184) Test failure in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:16:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4178) Replication Throttling: Consolidate Rate Classes - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:17:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:18:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:18:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3986) completedReceives can contain closed channels - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:18:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1573) Transient test failures on LogTest.testCorruptLog - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:19:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2363) ProducerSendTest.testCloseWithZeroTimeoutFromCallerThread Transient Failure - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:19:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3689) Exception when attempting to decrease connection count for address with no connections - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:19:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1377) transient unit test failure in LogOffsetTest - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:20:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4178) Replication Throttling: Consolidate Rate Classes - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/23 19:23:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1377) transient unit test failure in LogOffsetTest - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/23 19:24:59 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-1377) transient unit test failure in LogOffsetTest - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/23 19:25:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 19:31:59 UTC, 3 replies.
- [jira] [Created] (KAFKA-4435) Improve storage overhead of group metadata - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/23 19:37:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4435) Improve storage overhead of group metadata - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/23 19:37:59 UTC, 0 replies.
- [DISCUSS] 0.10.1.1 Plan - posted by Guozhang Wang <wa...@gmail.com> on 2016/11/23 19:58:50 UTC, 26 replies.
- FOSDEM 2017 HPC, Bigdata and Data Science DevRoom CFP is closing soon - posted by Roman Shaposhnik <ro...@shaposhnik.org> on 2016/11/23 21:11:19 UTC, 0 replies.
- [jira] [Created] (KAFKA-4436) Provide builder pattern for StreamsConfig - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/11/23 22:32:58 UTC, 0 replies.
- Data (re)processing with Kafka (new wiki page) - posted by "Matthias J. Sax" <ma...@confluent.io> on 2016/11/23 22:41:03 UTC, 3 replies.
- [jira] [Created] (KAFKA-4437) Incremental Batch Processing for Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/11/23 23:33:59 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4424) Make serializer classes final - posted by "Michael Andre Pearce (IG) (JIRA)" <ji...@apache.org> on 2016/11/24 00:23:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4424) Make serializer classes final - posted by "Michael Andre Pearce (IG) (JIRA)" <ji...@apache.org> on 2016/11/24 00:29:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4438) BACKPORT - Add scala 2.12 support - posted by "Bernard Leach (JIRA)" <ji...@apache.org> on 2016/11/24 00:31:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4438) BACKPORT - Add scala 2.12 support - posted by "Bernard Leach (JIRA)" <ji...@apache.org> on 2016/11/24 00:32:58 UTC, 1 replies.
- [GitHub] kafka pull request #2164: KAFKA-4438; Cross compile to Scala 2.12.0 - posted by leachbj <gi...@git.apache.org> on 2016/11/24 00:34:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4438) BACKPORT - Add scala 2.12 support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/24 00:34:58 UTC, 0 replies.
- [GitHub] kafka pull request #1603: KAFKA-1429: Yet another deadlock in controller shu... - posted by pengwei-li <gi...@git.apache.org> on 2016/11/24 00:45:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1429) Yet another deadlock in controller shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/24 00:45:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4439) Add a builder to NetworkClient - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2016/11/24 01:39:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4424) Make serializer classes final - posted by "Matthias Bechtold (JIRA)" <ji...@apache.org> on 2016/11/24 01:45:58 UTC, 0 replies.
- [GitHub] kafka pull request #2152: KAFKA-4424: make serializer classes final - posted by MatthiasBechtold <gi...@git.apache.org> on 2016/11/24 01:48:37 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1058 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/24 03:49:24 UTC, 0 replies.
- [GitHub] kafka pull request #2064: KAFKA-4345: Run decktape test for each pull reques... - posted by asfgit <gi...@git.apache.org> on 2016/11/24 04:49:42 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4345) Run decktape test for each pull request - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2016/11/24 04:49:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4345) Run decktape test for each pull request - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/24 04:49:58 UTC, 2 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1059 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/24 06:51:01 UTC, 0 replies.
- Is kafka mesos framework still supported? Is there any official kafka docker images? - posted by Yu Wei <yu...@hotmail.com> on 2016/11/24 08:45:53 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1709 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/24 09:38:22 UTC, 0 replies.
- [jira] [Created] (KAFKA-4440) Make producer RecordMetadata non-final - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/24 09:51:58 UTC, 0 replies.
- [GitHub] kafka pull request #2165: KAFKA-4440: Make producer RecordMetadata non-final - posted by rajinisivaram <gi...@git.apache.org> on 2016/11/24 10:15:36 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4440) Make producer RecordMetadata non-final - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/24 10:15:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4405) Kafka consumer improperly send prefetch request - posted by "ysysberserk (JIRA)" <ji...@apache.org> on 2016/11/24 10:29:58 UTC, 0 replies.
- [DISCUSS] KIP-94: Session Windows - posted by Damian Guy <da...@gmail.com> on 2016/11/24 15:59:03 UTC, 2 replies.
- [jira] [Created] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion - posted by "Tom Crayford (JIRA)" <ji...@apache.org> on 2016/11/24 16:11:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1060 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/24 16:38:30 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3452) Support session windows besides time interval windows - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/24 16:45:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3452) Support session windows besides time interval windows - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/24 16:45:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3452) Support session windows - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/11/24 16:46:58 UTC, 1 replies.
- [GitHub] kafka pull request #2166: KAFKA-3452: Support session windows - posted by dguy <gi...@git.apache.org> on 2016/11/24 16:48:27 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3452) Support session windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/24 16:48:58 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1710 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/24 16:56:35 UTC, 0 replies.
- Reply to Camberwell agent - posted by jupiter <ju...@gmail.com> on 2016/11/24 21:58:50 UTC, 0 replies.
- [jira] [Created] (KAFKA-4442) Controller should grab lock when it is being initialized to avoid race condition - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/25 04:03:59 UTC, 0 replies.
- [GitHub] kafka pull request #2167: KAFKA-4442; Controller should grab lock when it is... - posted by lindong28 <gi...@git.apache.org> on 2016/11/25 04:08:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4442) Controller should grab lock when it is being initialized to avoid race condition - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 04:09:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/25 04:20:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4444) Aggregate requests sent from controller to broker during controlled shutdown - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/25 04:23:58 UTC, 0 replies.
- [GitHub] kafka pull request #2168: KAFKA-4443; Controller should send UpdateMetadataR... - posted by lindong28 <gi...@git.apache.org> on 2016/11/25 04:33:14 UTC, 1 replies.
- [GitHub] kafka pull request #2169: KAFKA-4415; Reduce time to create and send Metadat... - posted by lindong28 <gi...@git.apache.org> on 2016/11/25 04:33:41 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 04:33:58 UTC, 5 replies.
- [jira] [Created] (KAFKA-4445) PreferredLeaderElectionCommand should query zk only once per topic - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/25 06:06:58 UTC, 0 replies.
- [GitHub] kafka pull request #2170: KAFKA-4445; PreferredLeaderElectionCommand should ... - posted by lindong28 <gi...@git.apache.org> on 2016/11/25 06:09:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4445) PreferredLeaderElectionCommand should query zk only once per topic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 06:10:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4446) If consumer offset topic created with less replicas than min.insync.replicas, consuming is not possible - posted by "Oliver Deakin (JIRA)" <ji...@apache.org> on 2016/11/25 12:20:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4446) If consumer offset topic created with less replicas than min.insync.replicas, consuming is not possible - posted by "Oliver Deakin (JIRA)" <ji...@apache.org> on 2016/11/25 12:21:58 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2016/11/25 15:41:58 UTC, 4 replies.
- [GitHub] kafka pull request #2171: KAFKA-4427: Skip topic groups with no tasks - posted by enothereska <gi...@git.apache.org> on 2016/11/25 15:53:58 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4427) Skip topicGroups with no tasks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 15:53:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4446) If consumer offset topic created with less replicas than min.insync.replicas, consuming is not possible - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2016/11/25 16:39:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time - posted by "Json Tu (JIRA)" <ji...@apache.org> on 2016/11/25 16:54:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time - posted by "Json Tu (JIRA)" <ji...@apache.org> on 2016/11/25 16:58:58 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-4446) If consumer offset topic created with less replicas than min.insync.replicas, consuming is not possible - posted by "Oliver Deakin (JIRA)" <ji...@apache.org> on 2016/11/25 17:16:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time - posted by "Json Tu (JIRA)" <ji...@apache.org> on 2016/11/25 17:19:58 UTC, 11 replies.
- [jira] [Work started] (KAFKA-4427) Skip topicGroups with no tasks - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/25 17:24:58 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time - posted by "Json Tu (JIRA)" <ji...@apache.org> on 2016/11/25 17:27:58 UTC, 8 replies.
- [jira] [Updated] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/25 17:41:59 UTC, 0 replies.
- [GitHub] kafka pull request #2172: HOTFIX: KAFKA-4245 follow up: remove gradle wrappe... - posted by ewencp <gi...@git.apache.org> on 2016/11/25 19:33:29 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4245) BlockingChannel#connect hides all exceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 19:33:59 UTC, 1 replies.
- Kafka - Roadmap - 2017 - posted by Costa Tsirbas <co...@gmail.com> on 2016/11/25 19:51:31 UTC, 1 replies.
- [jira] [Created] (KAFKA-4448) Add missing licenses to ducktape related files - posted by "Raghav Kumar Gautam (JIRA)" <ji...@apache.org> on 2016/11/25 22:07:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4449) Add Serializer/Deserializer for POJO - posted by "Jason Guo (JIRA)" <ji...@apache.org> on 2016/11/26 09:13:58 UTC, 0 replies.
- [GitHub] kafka pull request #2173: KAFKA-4449: Add Serializer/Deserializer for POJO - posted by habren <gi...@git.apache.org> on 2016/11/26 14:34:25 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4449) Add Serializer/Deserializer for POJO - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/26 14:34:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4449) Add Serializer/Deserializer for POJO - posted by "Jason Guo (JIRA)" <ji...@apache.org> on 2016/11/26 14:36:58 UTC, 1 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 2016/11/26 23:14:58 UTC, 14 replies.
- [jira] [Updated] (KAFKA-4156) Not able to download tests jar of kafka and kafka-streams from maven repo. - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/27 00:29:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4316) Kafka Streams 0.10.0.1 does not run on Windows x64 - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/27 00:47:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/27 00:52:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3400) Topic stop working / can't describe topic - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/27 00:52:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4063) Add support for infinite endpoints for range queries in Kafka Streams KV stores - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/27 00:52:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3963) Missing messages from the controller to brokers - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/27 00:53:59 UTC, 0 replies.
- [GitHub] kafka pull request #2174: MINOR: Make release notes script check resolutions... - posted by ewencp <gi...@git.apache.org> on 2016/11/27 00:55:13 UTC, 1 replies.
- Re: Reg: DefaultParititioner in Kafka - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2016/11/27 01:51:08 UTC, 0 replies.
- Re: KafkaProducer.java topics() call? - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2016/11/27 01:51:15 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4449) Add Serializer/Deserializer for POJO - posted by "Jason Guo (JIRA)" <ji...@apache.org> on 2016/11/27 03:17:59 UTC, 1 replies.
- [GitHub] kafka pull request #2175: KAFKA-4229:Controller can't start after several zk... - posted by pengwei-li <gi...@git.apache.org> on 2016/11/27 03:54:45 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4229) Controller can't start after several zk expired event - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/27 03:54:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4229) Controller can't start after several zk expired event - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2016/11/27 03:59:58 UTC, 2 replies.
- [jira] [Work started] (KAFKA-4229) Controller can't start after several zk expired event - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2016/11/27 04:01:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/27 05:13:59 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Abhi (JIRA)" <ji...@apache.org> on 2016/11/27 05:37:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4007) Improve fetch pipelining for low values of max.poll.records - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/27 06:03:58 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/27 09:01:09 UTC, 5 replies.
- [jira] [Work started] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2016/11/27 16:11:58 UTC, 0 replies.
- [GitHub] kafka pull request #2176: KAFKA-4403 Update KafkaBasedLog to use new endOffs... - posted by baluchicken <gi...@git.apache.org> on 2016/11/27 16:38:55 UTC, 1 replies.
- [jira] [Created] (KAFKA-4451) Recovering empty replica yields negative offsets in index of compact partitions - posted by "Michael Schiff (JIRA)" <ji...@apache.org> on 2016/11/28 01:20:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4451) Recovering empty replica yields negative offsets in index of compact partitions - posted by "Michael Schiff (JIRA)" <ji...@apache.org> on 2016/11/28 01:26:58 UTC, 3 replies.
- [jira] [Commented] (KAFKA-4451) Recovering empty replica yields negative offsets in index of compact partitions - posted by "Michael Schiff (JIRA)" <ji...@apache.org> on 2016/11/28 02:07:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4405) Kafka consumer improperly send prefetch request - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/28 02:18:58 UTC, 11 replies.
- [jira] [Comment Edited] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/28 05:11:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/28 05:44:58 UTC, 0 replies.
- [GitHub] kafka pull request #2177: KAFKA-3959: enforce offsets.topic.replication.fact... - posted by onurkaraman <gi...@git.apache.org> on 2016/11/28 06:09:09 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3940) Log should check the return value of dir.mkdirs() - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/11/28 08:16:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3715) Higher granularity streams metrics - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/28 09:25:58 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-3537) Provide access to low-level Metrics in ProcessorContext - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/28 11:32:58 UTC, 0 replies.
- How to commit bug fix to kafka mesos framework - posted by Yu Wei <yu...@hotmail.com> on 2016/11/28 15:00:03 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3715) Higher granularity streams metrics - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/11/28 15:55:59 UTC, 2 replies.
- [GitHub] kafka pull request #2178: Minor: Fix typos in KafkaConsumer docs - posted by jeffwidman <gi...@git.apache.org> on 2016/11/28 16:22:37 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time - posted by "Json Tu (JIRA)" <ji...@apache.org> on 2016/11/28 16:27:58 UTC, 1 replies.
- [GitHub] kafka pull request #2179: MINOR: Fix typos in KafkaConsumer docs - posted by jeffwidman <gi...@git.apache.org> on 2016/11/28 16:31:43 UTC, 0 replies.
- [GitHub] kafka pull request #2180: KAFKA-4439: NetworkClient: create a builder class ... - posted by cmccabe <gi...@git.apache.org> on 2016/11/28 17:51:53 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4439) Add a builder to NetworkClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 17:51:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4452) Server segfault in ContiguousSpace::block_size - posted by "Grant Rodgers (JIRA)" <ji...@apache.org> on 2016/11/28 18:22:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4452) Server segfault in ContiguousSpace::block_size - posted by "Grant Rodgers (JIRA)" <ji...@apache.org> on 2016/11/28 18:25:58 UTC, 1 replies.
- [DISCUSS] KIP-95: Incremental Batch Processing for Kafka Streams - posted by "Matthias J. Sax" <ma...@confluent.io> on 2016/11/28 18:47:56 UTC, 9 replies.
- [jira] [Created] (KAFKA-4453) add request prioritization - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/28 18:53:58 UTC, 0 replies.
- [GitHub] kafka pull request #2181: KAFKA-4453: add request prioritization - posted by onurkaraman <gi...@git.apache.org> on 2016/11/28 18:57:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4453) add request prioritization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 18:57:58 UTC, 0 replies.
- [GitHub] kafka pull request #2182: ConfigDef experimentation - support List and Ma... - posted by shikhar <gi...@git.apache.org> on 2016/11/28 19:32:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-4454) Authorizer should also include the Principal generated by the PrincipalBuilder. - posted by "Mayuresh Gharat (JIRA)" <ji...@apache.org> on 2016/11/28 20:08:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4455) Commit during rebalance does not close RocksDB which later causes: org.rocksdb.RocksDBException: IO error: lock .../LOCK: No locks available - posted by "Davor Poldrugo (JIRA)" <ji...@apache.org> on 2016/11/28 20:23:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4455) Commit during rebalance does not close RocksDB which later causes: org.rocksdb.RocksDBException: IO error: lock .../LOCK: No locks available - posted by "Davor Poldrugo (JIRA)" <ji...@apache.org> on 2016/11/28 20:24:58 UTC, 5 replies.
- [jira] [Created] (KAFKA-4456) Offsets of deleted topics are not removed from consumer groups - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/28 20:36:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3798) Kafka Consumer 0.10.0.0 killed after rebalancing exception - posted by "Evan Nelson (JIRA)" <ji...@apache.org> on 2016/11/28 21:33:58 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3798) Kafka Consumer 0.10.0.0 killed after rebalancing exception - posted by "Evan Nelson (JIRA)" <ji...@apache.org> on 2016/11/28 21:34:58 UTC, 1 replies.
- [jira] [Work started] (KAFKA-4437) Incremental Batch Processing for Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/11/28 21:58:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4436) Provide builder pattern for StreamsConfig - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2016/11/28 22:18:58 UTC, 4 replies.
- [jira] [Updated] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/28 22:32:59 UTC, 1 replies.
- [GitHub] kafka pull request #2183: Removed obsolete parameter form example config in ... - posted by soenkeliebau <gi...@git.apache.org> on 2016/11/28 22:56:29 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2122) Remove controller.message.queue.size Config - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 22:56:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4457) Add a command to list the broker version information - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2016/11/28 23:05:58 UTC, 0 replies.
- [GitHub] kafka pull request #2184: KAFKA-4457. Add BrokerVersionCommand - posted by cmccabe <gi...@git.apache.org> on 2016/11/28 23:13:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4457) Add a command to list the broker version information - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 23:13:58 UTC, 0 replies.
- Kafka Clients Survey - posted by Gwen Shapira <gw...@confluent.io> on 2016/11/28 23:26:26 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4457) Add a command to list the broker version information - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2016/11/28 23:32:03 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4439) Add a builder to NetworkClient - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2016/11/28 23:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-4458) Add per partition metrics for in-sync and assigned replica count - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2016/11/29 00:08:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4442) Controller should grab lock when it is being initialized to avoid race condition - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/29 00:27:58 UTC, 0 replies.
- [DISCUSS] KIP-96 - Add per partition metrics for in-sync and assigned replica count - posted by Xavier Léauté <xa...@confluent.io> on 2016/11/29 00:40:04 UTC, 3 replies.
- [GitHub] kafka pull request #2185: MINOR: added logging to debug test - posted by mjsax <gi...@git.apache.org> on 2016/11/29 00:46:15 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4454) Authorizer should also include the Principal generated by the PrincipalBuilder. - posted by "Mayuresh Gharat (JIRA)" <ji...@apache.org> on 2016/11/29 01:03:58 UTC, 1 replies.
- [GitHub] kafka pull request #2141: KAFKA-4444; Aggregate requests sent from controlle... - posted by lindong28 <gi...@git.apache.org> on 2016/11/29 01:09:26 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4444) Aggregate requests sent from controller to broker during controlled shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/29 01:09:58 UTC, 0 replies.
- [GitHub] kafka-site pull request #33: Update contact.html - posted by dossett <gi...@git.apache.org> on 2016/11/29 01:48:11 UTC, 0 replies.
- [jira] [Work started] (KAFKA-4453) add request prioritization - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/29 04:20:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4453) add request prioritization - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/29 04:21:58 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/29 04:21:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/11/29 04:21:59 UTC, 1 replies.
- [GitHub] kafka pull request #2186: KAFKA-4458 add per partition in-sync and assigned ... - posted by xvrl <gi...@git.apache.org> on 2016/11/29 05:43:28 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4458) Add per partition metrics for in-sync and assigned replica count - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/29 05:43:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4459) rat license check not running in Jenkins - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/29 08:42:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4459) rat license check not running in Jenkins - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/29 08:42:59 UTC, 0 replies.
- [GitHub] kafka pull request #2187: Revert "KAFKA-4345; Run decktape test for each pul... - posted by ijuma <gi...@git.apache.org> on 2016/11/29 09:26:29 UTC, 1 replies.
- [VOTE] KIP-87 - Add Compaction Tombstone Flag - posted by Michael Pearce <Mi...@ig.com> on 2016/11/29 11:18:30 UTC, 5 replies.
- [jira] [Updated] (KAFKA-4455) CommitFailedException during rebalance doesn't release resources in processors - posted by "Davor Poldrugo (JIRA)" <ji...@apache.org> on 2016/11/29 11:48:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4455) CommitFailedException during rebalance doesn't release resources in tasks/processors - posted by "Davor Poldrugo (JIRA)" <ji...@apache.org> on 2016/11/29 11:50:59 UTC, 0 replies.
- [GitHub] kafka pull request #2188: KAFKA-4455; ensure tasks are closed after CommitFa... - posted by dpoldrugo <gi...@git.apache.org> on 2016/11/29 12:42:13 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4455) CommitFailedException during rebalance doesn't release resources in tasks/processors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/29 12:42:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Abhi (JIRA)" <ji...@apache.org> on 2016/11/29 13:10:59 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-4419) Unable to GetOffset when the ACL of topic is defined - posted by "Mohammed amine GARMES (JIRA)" <ji...@apache.org> on 2016/11/29 13:11:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4460) Consumer stops getting messages when partition leader dies - posted by "Bernhard Bonigl (JIRA)" <ji...@apache.org> on 2016/11/29 14:48:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result - posted by "Hamidreza Afzali (JIRA)" <ji...@apache.org> on 2016/11/29 15:13:58 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4405) Kafka consumer improperly send prefetch request - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/29 15:26:58 UTC, 3 replies.
- [jira] [Updated] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/29 17:02:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/29 17:02:59 UTC, 3 replies.
- [jira] [Reopened] (KAFKA-4345) Run decktape test for each pull request - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/29 17:44:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4345) Run ducktape test for each pull request - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/29 17:45:58 UTC, 0 replies.
- [GitHub] kafka pull request #1814: MINOR: doc fix related to monitoring consumer lag. - posted by asfgit <gi...@git.apache.org> on 2016/11/29 17:58:27 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4439) Add a builder to NetworkClient - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2016/11/29 18:10:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4457) Add a command to list the broker version information - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2016/11/29 18:10:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/11/29 18:14:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/29 18:26:58 UTC, 1 replies.
- [VOTE] KIP-93: Improve invalid timestamp handling in Kafka Streams - posted by "Matthias J. Sax" <ma...@confluent.io> on 2016/11/29 18:34:30 UTC, 5 replies.
- [jira] [Issue Comment Deleted] (KAFKA-4271) The console consumer fails on Windows with new consumer is used - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/29 18:37:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-4462) Improved Kafka Client Compatibility Policy - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2016/11/29 18:45:58 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1061 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/29 18:48:26 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4462) Improved Kafka Client Compatibility Policy - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2016/11/29 18:49:58 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4448) Add missing licenses to ducktape related files - posted by "Raghav Kumar Gautam (JIRA)" <ji...@apache.org> on 2016/11/29 18:56:58 UTC, 0 replies.
- [DISCUSS] KIP-97: Improved Kafka Client RPC Compatibility Policy - posted by Colin McCabe <cm...@apache.org> on 2016/11/29 19:04:33 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-4427) Skip topicGroups with no tasks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/29 19:08:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4463) Setup travis-ci integration for ducktape tests - posted by "Raghav Kumar Gautam (JIRA)" <ji...@apache.org> on 2016/11/29 19:09:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4464) Clean shutdown of broker fails due to controller error - posted by "Xavier Lange (JIRA)" <ji...@apache.org> on 2016/11/29 19:14:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4464) Clean shutdown of broker fails due to controller error - posted by "Xavier Lange (JIRA)" <ji...@apache.org> on 2016/11/29 19:17:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-4465) Create docker image and scripts for running tests locally - posted by "Raghav Kumar Gautam (JIRA)" <ji...@apache.org> on 2016/11/29 19:25:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4464) Clean shutdown of broker fails due to controller error - posted by "Xavier Lange (JIRA)" <ji...@apache.org> on 2016/11/29 19:25:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4466) Add support to ducktape to run only a part of all tests - posted by "Raghav Kumar Gautam (JIRA)" <ji...@apache.org> on 2016/11/29 19:26:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4467) Run tests on travis-ci using docker - posted by "Raghav Kumar Gautam (JIRA)" <ji...@apache.org> on 2016/11/29 19:27:58 UTC, 0 replies.
- [GitHub] kafka pull request #1028: KAFKA-3123: Follower Broker cannot start if offset... - posted by soumyajit-sahu <gi...@git.apache.org> on 2016/11/29 20:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3123) Follower Broker cannot start if offsets are already out of range - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/29 20:15:58 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1063 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/29 21:06:34 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4458) Add per partition metrics for in-sync and assigned replica count - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2016/11/29 21:07:58 UTC, 0 replies.
- [GitHub] kafka pull request #2189: KAFKA-4271: Fix the server start script for Window... - posted by vahidhashemian <gi...@git.apache.org> on 2016/11/29 22:01:25 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4271) The console consumer fails on Windows with new consumer is used - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/29 22:01:59 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4271) The console consumer fails on Windows with new consumer is used - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/29 22:01:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/29 22:34:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/29 22:35:58 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2016/11/29 22:35:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4397) Refactor Connect backing stores for thread-safety - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/11/29 23:32:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/30 00:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/11/30 01:05:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/11/30 01:06:00 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1064 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/30 01:38:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-4469) Consumer throughput regression caused by decrease in max.poll.records - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/30 01:48:58 UTC, 0 replies.
- [GitHub] kafka pull request #2190: KAFKA-4469: Fix consumer performance regression fr... - posted by hachikuji <gi...@git.apache.org> on 2016/11/30 02:32:07 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4469) Consumer throughput regression caused by decrease in max.poll.records - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 02:32:58 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/30 02:55:59 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3893) Kafka Borker ID disappears from /borkers/ids - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/11/30 02:58:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3893) Kafka Broker ID disappears from /borkers/ids - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/11/30 03:04:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3893) Kafka Broker ID disappears from /brokers/ids - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/11/30 03:04:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/30 03:22:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/30 03:38:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4463) Setup travis-ci integration for ducktape tests - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/30 05:14:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4465) Create docker image and scripts for running tests locally - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/30 05:14:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4467) Run tests on travis-ci using docker - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/30 05:14:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4466) Add support to ducktape to run only a part of all tests - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/11/30 05:14:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/11/30 05:16:58 UTC, 0 replies.
- [GitHub] kafka pull request #2191: KAFKA-4447: Controller resigned but it also acts a... - posted by xiguantiaozhan <gi...@git.apache.org> on 2016/11/30 05:47:23 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #1065 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/30 05:49:24 UTC, 0 replies.
- [jira] [Created] (KAFKA-4470) Exception (java.lang.RuntimeException) encountered during startup: org.codehaus.jackson.JsonParseException: - posted by "JianwenSun (JIRA)" <ji...@apache.org> on 2016/11/30 06:09:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4470) Exception (java.lang.RuntimeException) encountered during startup: org.codehaus.jackson.JsonParseException: - posted by "JianwenSun (JIRA)" <ji...@apache.org> on 2016/11/30 06:15:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1066 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/30 07:15:08 UTC, 0 replies.
- [GitHub] kafka pull request #2192: MyKafka - posted by geeag <gi...@git.apache.org> on 2016/11/30 09:24:38 UTC, 0 replies.
- [GitHub] kafka pull request #2193: KAFKA-4405: Check max.poll.records before prefetch... - posted by enothereska <gi...@git.apache.org> on 2016/11/30 09:30:55 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4007) Improve fetch pipelining for low values of max.poll.records - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 09:43:59 UTC, 0 replies.
- [GitHub] kafka pull request #2194: KAFKA-4443: Minor comment clean-up - posted by ijuma <gi...@git.apache.org> on 2016/11/30 11:12:33 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4470) Exception (java.lang.RuntimeException) encountered during startup: org.codehaus.jackson.JsonParseException: - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/11/30 14:22:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-4471) KafkaConsumer unpauses queues after subscribe() - posted by "Sergey Alaev (JIRA)" <ji...@apache.org> on 2016/11/30 15:11:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4471) KafkaConsumer unpauses partitions after subscribe() - posted by "Sergey Alaev (JIRA)" <ji...@apache.org> on 2016/11/30 15:22:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4471) KafkaConsumer unpauses partitions after subscribe() - posted by "Sergey Alaev (JIRA)" <ji...@apache.org> on 2016/11/30 15:25:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4460) Consumer stops getting messages when partition leader dies - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:39:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4433) Kafka Controller Does not send a LeaderAndIsr to old leader of a topicPartition during reassignment, if the old leader is not a part of the new assigned replicas - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:41:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4412) Replication fetch stuck in loop on offset null - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:41:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4365) In case async producer closes the TCP connection to Kafka broker, last sent messages might be lost. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:43:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4358) Following a hung broker, newly elected leader is unnecessarily slow assuming leadership because of ReplicaFetcherThread - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:44:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4305) Possible race condition in log segment truncation and Kafka Request Handler - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:48:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4138) Producer data write network traffic to kafka brokers is increased for 50% - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:49:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4086) long processing consumer restart will stall - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:50:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:50:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4009) Data corruption or EIO leads to data loss - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:51:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3968) fsync() is not called on parent directory when new FileMessageSet is flushed to disk - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:53:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3971) Consumers drop from coordinator and cannot reconnect - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:53:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3889) Change default Scala version to 2.11 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 15:54:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed" - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:12:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:13:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1429) Yet another deadlock in controller shutdown - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:13:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2082) Kafka Replication ends up in a bad state - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:13:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3040) Broker didn't report new data after change in leader - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:13:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3919) Broker faills to start after ungraceful shutdown due to non-monotonically incrementing offsets in logs - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:14:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3693) Lost highwatermark at broker start-up - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:14:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3924) Data loss due to halting when LEO is larger than leader's LEO - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:14:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4150) Facing Message Loss When trying rolling updates - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:14:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:14:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3039) Temporary loss of leader resulted in log being completely truncated - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:15:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:15:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1120) Controller could miss a broker state change - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:15:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3795) Transient system test failure upgrade_test.TestUpgrade - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:16:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2758) Improve Offset Commit Behavior - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:17:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4418) Broker Leadership Election Fails If Missing ZK Path Raises Exception - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/11/30 16:20:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3309) Update Protocol Documentation WIP patch - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/11/30 18:20:59 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4471) KafkaConsumer unpauses partitions after subscribe() - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/11/30 18:29:58 UTC, 0 replies.
- [GitHub] kafka pull request #1664: KAFKA-1911: Async delete topic - posted by asfgit <gi...@git.apache.org> on 2016/11/30 18:41:39 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1911) Log deletion on stopping replicas should be async - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 18:41:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1911) Log deletion on stopping replicas should be async - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2016/11/30 19:04:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4469) Consumer throughput regression caused by inefficient list removal and copy - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/30 19:49:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1067 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/30 20:39:02 UTC, 0 replies.
- [VOTE] KIP-96 - Add per partition metrics for in-sync and replica count - posted by Xavier Léauté <xa...@confluent.io> on 2016/11/30 21:34:47 UTC, 4 replies.
- [jira] [Commented] (KAFKA-4469) Consumer throughput regression caused by inefficient list removal and copy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 21:34:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4469) Consumer throughput regression caused by inefficient list removal and copy - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/11/30 21:35:58 UTC, 0 replies.
- [GitHub] kafka pull request #2195: KAFKA-3994: Fix deadlock in Watchers by calling tr... - posted by hachikuji <gi...@git.apache.org> on 2016/11/30 22:09:51 UTC, 0 replies.
- [GitHub] kafka pull request #1738: KAFKA-3994: Fix deadlock in Watchers by calling tr... - posted by hachikuji <gi...@git.apache.org> on 2016/11/30 22:16:11 UTC, 0 replies.
- [DISCUSS] KIP-98: Exactly Once Delivery and Transactional Messaging - posted by Guozhang Wang <wa...@gmail.com> on 2016/11/30 22:19:16 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1068 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/30 22:47:45 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #1069 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/11/30 23:29:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3834) Consumer should not block in poll on coordinator discovery - posted by "Sönke Liebau (JIRA)" <ji...@apache.org> on 2016/11/30 23:49:58 UTC, 0 replies.