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

---

- [jira] [Updated] (KAFKA-3773) SocketServer inflightResponses collection leaks memory on client disconnect - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/01 00:03:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3773) SocketServer inflightResponses collection leaks memory on client disconnect - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/01 00:03:12 UTC, 0 replies.
- [GitHub] kafka pull request: KAFKA-3773: Remove from inflightResponses on client disc... - posted by hachikuji <gi...@git.apache.org> on 2016/06/01 00:03:25 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3773) SocketServer inflightResponses collection leaks memory on client disconnect - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 00:04:12 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2894) WorkerSinkTask doesn't handle rewinding offsets on rebalance - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2016/06/01 04:19:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3769) KStream job spending 60% of time writing metrics - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2016/06/01 05:23:12 UTC, 7 replies.
- Re: [jira] [Updated] (KAFKA-3772) MirrorMaker crashes on Corrupted Message - posted by Gerard Klijs <ge...@dizzit.com> on 2016/06/01 07:40:40 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1379) Partition reassignment resets clock for time-based retention - posted by "Luca Toscano (JIRA)" <ji...@apache.org> on 2016/06/01 10:08:59 UTC, 0 replies.
- Using zookeeper vs gossip protocols in Kafka - posted by Unmesh Joshi <un...@gmail.com> on 2016/06/01 10:17:53 UTC, 1 replies.
- [GitHub] kafka pull request: KAFKA-3561: Auto create through topic for KStream aggreg... - posted by dguy <gi...@git.apache.org> on 2016/06/01 13:25:29 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3561) Auto create through topic for KStream aggregation and join - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 13:25:59 UTC, 3 replies.
- [GitHub] kafka pull request #1454: MINOR: added spacing in streams doc in section 9.2 - posted by coughman <gi...@git.apache.org> on 2016/06/01 15:01:55 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1329 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/01 15:41:42 UTC, 0 replies.
- [GitHub] kafka pull request #1455: MINOR: Fix setting of ACLs and ZK shutdown in test... - posted by ijuma <gi...@git.apache.org> on 2016/06/01 16:22:16 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #665 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/01 16:23:44 UTC, 0 replies.
- KStreams Rewind Offset - posted by "Michael D. Coon" <md...@yahoo.com.INVALID> on 2016/06/01 18:21:12 UTC, 3 replies.
- [GitHub] kafka pull request #1456: MINOR: Add user overridden test logging events - posted by guozhangwang <gi...@git.apache.org> on 2016/06/01 18:33:28 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/01 20:26:59 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3129) Console Producer/Consumer Issue - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/01 20:26:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3129) Console producer issue when request-required-acks=0 - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/01 20:28:59 UTC, 1 replies.
- [jira] [Created] (KAFKA-3774) GetOffsetShell tool reports 'Missing required argument "[time]"' despite the default - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/01 20:43:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3774) GetOffsetShell tool reports 'Missing required argument "[time]"' despite the default - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/01 20:46:59 UTC, 2 replies.
- [GitHub] kafka pull request #1457: KAFKA-3774: Make 'time' an optional argument of Ge... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/01 20:52:47 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3774) GetOffsetShell tool reports 'Missing required argument "[time]"' despite the default - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 20:52:59 UTC, 1 replies.
- [GitHub] kafka pull request #1458: MINOR: close parenthesis in PartitionInfo.toString - posted by magnusr <gi...@git.apache.org> on 2016/06/01 21:53:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1995) JMS to Kafka: Inbuilt JMSAdaptor/JMSProxy/JMSBridge (Client can speak JMS but hit Kafka) - posted by "John Lonergan (JIRA)" <ji...@apache.org> on 2016/06/01 22:36:59 UTC, 1 replies.
- [GitHub] kafka pull request #1459: KAFKA-3748: Add consumer-property to console tools... - posted by bharatviswa504 <gi...@git.apache.org> on 2016/06/01 22:40:53 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3748) Add consumer-property to console tools consumer (similar to --producer-property) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 22:40:59 UTC, 3 replies.
- [jira] [Commented] (KAFKA-3763) Remove deprecated APIs - posted by "Amey (JIRA)" <ji...@apache.org> on 2016/06/01 23:47:59 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3748) Add consumer-property to console tools consumer (similar to --producer-property) - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/02 00:09:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #666 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 00:12:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3755) tightening the offset check in ReplicaFetcherThread - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/06/02 00:12:59 UTC, 3 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1330 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 00:39:03 UTC, 0 replies.
- Re: How to write Connect logs to file? - posted by Ewen Cheslack-Postava <ew...@confluent.io> on 2016/06/02 03:29:57 UTC, 0 replies.
- [GitHub] kafka pull request #1325: KAFKA-3660: Log exception message in ControllerBro... - posted by asfgit <gi...@git.apache.org> on 2016/06/02 04:04:22 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3660) Log exception message in ControllerBrokerRequestBatch - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/02 04:04:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3660) Log exception message in ControllerBrokerRequestBatch - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/02 04:04:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #667 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 04:12:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #111 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 04:20:18 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3711) Allow configuration of MetricsReporter subclasses - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/02 04:33:59 UTC, 4 replies.
- [GitHub] kafka pull request #1390: Add a newline to a Javadoc sample in KafkaConsumer - posted by asfgit <gi...@git.apache.org> on 2016/06/02 04:51:36 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #668 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 05:12:57 UTC, 0 replies.
- Re: [DISCUSS] KIP-62: Allow consumer to send heartbeats from a background thread - posted by Guozhang Wang <wa...@gmail.com> on 2016/06/02 05:23:10 UTC, 14 replies.
- [jira] [Commented] (KAFKA-3764) Error processing append operation on partition - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/02 05:27:59 UTC, 4 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1331 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 05:43:30 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1332 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 05:49:18 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #669 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 06:12:54 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1333 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 06:38:52 UTC, 0 replies.
- [jira] [Created] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams - posted by "Yuto Kawamura (JIRA)" <ji...@apache.org> on 2016/06/02 06:50:59 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams - posted by "Yuto Kawamura (JIRA)" <ji...@apache.org> on 2016/06/02 06:50:59 UTC, 0 replies.
- [GitHub] kafka pull request #1460: KAFKA-3775: Throttle maximum number of tasks assig... - posted by kawamuray <gi...@git.apache.org> on 2016/06/02 06:54:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/02 06:54:59 UTC, 17 replies.
- [jira] [Updated] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams - posted by "Yuto Kawamura (JIRA)" <ji...@apache.org> on 2016/06/02 06:54:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce - posted by "Michael Andre Pearce (IG) (JIRA)" <ji...@apache.org> on 2016/06/02 07:09:59 UTC, 1 replies.
- [DISCUSS] KIP-63: Unify store and downstream caching in streams - posted by Eno Thereska <en...@gmail.com> on 2016/06/02 10:30:33 UTC, 20 replies.
- [jira] [Created] (KAFKA-3776) Unify store and downstream caching in streams - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:38:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3777) Extract the LRU cache out of RocksDBStore - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:41:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3776) Unify store and downstream caching in streams - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:42:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3777) Extract the LRU cache out of RocksDBStore - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:42:59 UTC, 3 replies.
- [jira] [Created] (KAFKA-3778) Change the RocksDB implementation for KStream windowed aggregations, to not use “range queries” but multiple gets - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:49:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3779) Add the LRU cache for KTable.to() operator - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:51:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3780) Add new config cache.max.bytes.buffering to the streams configuration - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:52:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:55:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3101) Optimize Aggregation Outputs - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/02 10:56:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3560) Kafka is not working on Solaris - posted by "Marcus Gründler (JIRA)" <ji...@apache.org> on 2016/06/02 12:32:59 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3725) Update documentation with regards to XFS - posted by "Todd Palino (JIRA)" <ji...@apache.org> on 2016/06/02 13:18:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3725) Update documentation with regards to XFS - posted by "Todd Palino (JIRA)" <ji...@apache.org> on 2016/06/02 13:19:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3781) Errors.exceptionName() can throw NPE - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2016/06/02 14:12:59 UTC, 0 replies.
- Changing default logger to RollingFileAppender (KAFKA-2394) - posted by Dustin Cote <du...@confluent.io> on 2016/06/02 14:33:16 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3764) Error processing append operation on partition - posted by "Martin Nowak (JIRA)" <ji...@apache.org> on 2016/06/02 14:34:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2016/06/02 14:35:59 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2016/06/02 14:44:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Ravi Peri (JIRA)" <ji...@apache.org> on 2016/06/02 18:31:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3782) Transient failure with kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_bounce.clean=True - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2016/06/02 18:43:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/02 19:09:59 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-3764) Error processing append operation on partition - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2016/06/02 19:30:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3782) Transient failure with kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_bounce.clean=True - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2016/06/02 19:44:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3689) ERROR Processor got uncaught exception. (kafka.network.Processor) - posted by "Buvaneswari Ramanan (JIRA)" <ji...@apache.org> on 2016/06/02 19:52:59 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-3689) ERROR Processor got uncaught exception. (kafka.network.Processor) - posted by "Buvaneswari Ramanan (JIRA)" <ji...@apache.org> on 2016/06/02 19:53:59 UTC, 0 replies.
- Kafka take too long to update the client with metadata when a broker is gone - posted by safique ahemad <sa...@gmail.com> on 2016/06/02 20:16:42 UTC, 0 replies.
- [jira] [Created] (KAFKA-3783) Race condition on last ACL removal for a resource fails with a ZkBadVersionException - posted by "Sébastien Launay (JIRA)" <ji...@apache.org> on 2016/06/02 21:01:59 UTC, 0 replies.
- [GitHub] kafka pull request #1461: KAFKA-3783: Catch proper exception on path delete - posted by slaunay <gi...@git.apache.org> on 2016/06/02 21:06:53 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3783) Race condition on last ACL removal for a resource fails with a ZkBadVersionException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/02 21:06:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3689) ERROR Processor got uncaught exception. (kafka.network.Processor) - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/02 22:38:59 UTC, 0 replies.
- [GitHub] kafka pull request #1450: HOTFIX: updated JavaDoc example for 0.9 tech-prev ... - posted by asfgit <gi...@git.apache.org> on 2016/06/02 22:41:07 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3778) Change the RocksDB implementation for KStream windowed aggregations, to not use “range queries” but multiple gets - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/02 22:49:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3693) Race condition between highwatermark-checkpoint thread and handleLeaderAndIsrRequest at broker start-up - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/02 22:50:59 UTC, 16 replies.
- [jira] [Commented] (KAFKA-3778) Change the RocksDB implementation for KStream windowed aggregations, to not use “range queries” but multiple gets - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/02 22:50:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3778) Avoidin using range queries of RocksDBWindowStore on KStream windowed aggregations - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/02 22:51:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3779) Add the LRU cache for KTable.to() operator - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/02 22:52:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3335) Kafka Connect hangs in shutdown hook - posted by "Ben Kirwin (JIRA)" <ji...@apache.org> on 2016/06/02 23:12:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #670 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 23:14:30 UTC, 0 replies.
- [jira] [Created] (KAFKA-3784) TimeWindows#windowsFor misidentifies some windows if TimeWindows#advanceBy is used - posted by "Tom Rybak (JIRA)" <ji...@apache.org> on 2016/06/02 23:35:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1334 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/02 23:39:07 UTC, 0 replies.
- [GitHub] kafka pull request #1462: KAFKA-3784 TimeWindows#windowsFor misidentifies so... - posted by trybak <gi...@git.apache.org> on 2016/06/03 00:14:14 UTC, 1 replies.
- [GitHub] kafka pull request #1447: KAFKA-3769 - KStream job spending 60% of time writ... - posted by gfodor <gi...@git.apache.org> on 2016/06/03 00:14:32 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3784) TimeWindows#windowsFor misidentifies some windows if TimeWindows#advanceBy is used - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 00:14:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3777) Extract the LRU cache out of RocksDBStore - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2016/06/03 00:20:59 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3752) Provide a way for KStreams to recover from unclean shutdown - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/03 00:24:59 UTC, 0 replies.
- [GitHub] kafka pull request #1448: KAFKA-3770: KStream job should be able to specify ... - posted by gfodor <gi...@git.apache.org> on 2016/06/03 01:07:56 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3770) KStream job should be able to specify linger.ms - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 01:07:59 UTC, 2 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #671 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 01:13:44 UTC, 0 replies.
- [GitHub] kafka pull request #1463: KAFKA-3770: KStream job should be able to specify ... - posted by gfodor <gi...@git.apache.org> on 2016/06/03 01:14:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #112 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 01:20:36 UTC, 0 replies.
- [jira] [Created] (KAFKA-3785) Fetcher spending unnecessary time during metrics recording - posted by "Greg Fodor (JIRA)" <ji...@apache.org> on 2016/06/03 01:41:59 UTC, 0 replies.
- [GitHub] kafka pull request #1464: KAFKA-3785; Fetcher spending unnecessary time duri... - posted by gfodor <gi...@git.apache.org> on 2016/06/03 01:48:33 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3785) Fetcher spending unnecessary time during metrics recording - posted by "Greg Fodor (JIRA)" <ji...@apache.org> on 2016/06/03 01:48:59 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3785) Fetcher spending unnecessary time during metrics recording - posted by "Greg Fodor (JIRA)" <ji...@apache.org> on 2016/06/03 01:48:59 UTC, 2 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1335 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 01:54:52 UTC, 0 replies.
- [jira] [Created] (KAFKA-3786) AbstractConfig to only retain defined ConfigDef when parsing property map - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/03 02:43:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3786) AbstractConfig to only retain defined ConfigDef when parsing property map - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/03 02:49:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3786) Avoid unused property from parent configs causing WARN entries - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/03 03:42:59 UTC, 0 replies.
- [GitHub] kafka pull request #1465: KAFKA-3786: Let ConfigDef filter property key valu... - posted by guozhangwang <gi...@git.apache.org> on 2016/06/03 04:23:02 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3786) Avoid unused property from parent configs causing WARN entries - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 04:23:59 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-2305) Cluster Monitoring and Management UI - posted by "Soumyajit Sahu (JIRA)" <ji...@apache.org> on 2016/06/03 04:46:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2305) Cluster Monitoring and Management UI - posted by "Soumyajit Sahu (JIRA)" <ji...@apache.org> on 2016/06/03 04:47:59 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams - posted by "The Data Lorax (JIRA)" <ji...@apache.org> on 2016/06/03 07:24:59 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-3785) Fetcher spending unnecessary time during metrics recording - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/03 08:43:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3787) Preserve message timestamp in mirror mkaer - posted by "TAO XIAO (JIRA)" <ji...@apache.org> on 2016/06/03 08:57:59 UTC, 0 replies.
- [GitHub] kafka pull request #1466: KAFKA-3787: Preserve the message timestamp in mirr... - posted by xiaotao183 <gi...@git.apache.org> on 2016/06/03 09:12:36 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3787) Preserve message timestamp in mirror mkaer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 09:12:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3787) Preserve message timestamp in mirror mkaer - posted by "TAO XIAO (JIRA)" <ji...@apache.org> on 2016/06/03 09:14:59 UTC, 2 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #113 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 09:20:07 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1336 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 09:39:08 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #672 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 10:13:55 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #673 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 10:14:41 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #114 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 10:21:28 UTC, 0 replies.
- [jira] [Created] (KAFKA-3788) Potential message lost when switching to new segment - posted by "Arkadiusz Firus (JIRA)" <ji...@apache.org> on 2016/06/03 11:57:59 UTC, 0 replies.
- [GitHub] kafka pull request #1413: MINOR: set charset of Javadoc to UTF-8 - posted by asfgit <gi...@git.apache.org> on 2016/06/03 16:34:31 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3680) Make Java client classloading more flexible - posted by "Avi Flax (JIRA)" <ji...@apache.org> on 2016/06/03 16:58:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3789) Upgrade Snappy to fix snappy decompression errors - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2016/06/03 17:11:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #674 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 17:12:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3790) Default options when removing ACLs do not comply with documentation - posted by "Sébastien Launay (JIRA)" <ji...@apache.org> on 2016/06/03 17:13:59 UTC, 0 replies.
- [GitHub] kafka pull request #1467: KAFKA-3789: Upgrade Snappy to fix snappy decompres... - posted by granthenke <gi...@git.apache.org> on 2016/06/03 17:20:38 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3789) Upgrade Snappy to fix snappy decompression errors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 17:20:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3789) Upgrade Snappy to fix snappy decompression errors - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2016/06/03 17:21:59 UTC, 1 replies.
- [GitHub] kafka pull request #1468: KAFKA-3790: Allow for removal of non specific ACLs - posted by slaunay <gi...@git.apache.org> on 2016/06/03 17:48:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3790) Default options when removing ACLs do not comply with documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 17:48:59 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1337 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 17:54:31 UTC, 0 replies.
- Re: [DISCUSS] KIP-47 - Add timestamp-based log deletion policy - posted by Magnus Edenhill <ma...@edenhill.se> on 2016/06/03 18:02:29 UTC, 0 replies.
- Re: [DISCUSS] KIP-54 Sticky Partition Assignment Strategy - posted by Guozhang Wang <wa...@gmail.com> on 2016/06/03 18:33:08 UTC, 17 replies.
- [jira] [Updated] (KAFKA-3784) TimeWindows#windowsFor misidentifies some windows if TimeWindows#advanceBy is used - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/03 18:37:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3705) Support non-key joining in KTable - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/03 19:24:59 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-3784) TimeWindows#windowsFor misidentifies some windows if TimeWindows#advanceBy is used - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/03 20:22:59 UTC, 0 replies.
- [GitHub] kafka pull request #1425: KAFKA-3728 EndToEndAuthorizationTest offsets_topic... - posted by asfgit <gi...@git.apache.org> on 2016/06/03 20:31:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3728) EndToEndAuthorizationTest offsets_topic misconfigured - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 20:32:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1338 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 20:39:03 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3728) EndToEndAuthorizationTest offsets_topic misconfigured - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/03 20:50:59 UTC, 0 replies.
- Kafka 0.10.0.0 broker configuration to support older consumer/producer clients... - posted by Kiran Pillarisetty <pk...@gmail.com> on 2016/06/03 21:00:51 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #675 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 21:13:02 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #115 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/03 21:20:11 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3645) NPE in ConsumerGroupCommand and ConsumerOffsetChecker when running in a secure env - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/04 08:43:02 UTC, 0 replies.
- [GitHub] kafka pull request #1301: KAFKA-3645: Fix ConsumerGroupCommand and ConsumerO... - posted by asfgit <gi...@git.apache.org> on 2016/06/04 08:43:06 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3645) NPE in ConsumerGroupCommand and ConsumerOffsetChecker when running in a secure env - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/04 08:43:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #676 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/04 09:14:12 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1339 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/04 09:39:08 UTC, 0 replies.
- [GitHub] kafka pull request #1453: KAFKA-3561: Auto create through topic for KStream ... - posted by dguy <gi...@git.apache.org> on 2016/06/04 15:22:23 UTC, 0 replies.
- [GitHub] kafka pull request #1445: KAFKA-3768: Replace all pattern match on boolean v... - posted by asfgit <gi...@git.apache.org> on 2016/06/04 20:25:45 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3768) Replace all pattern match on boolean value by if/elase block. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/04 20:25:59 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3768) Replace all pattern match on boolean value by if/elase block. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/04 20:25:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3768) Replace all pattern match on boolean value by if/elase block. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/04 20:26:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1340 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/04 20:39:12 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1341 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/04 22:38:56 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #677 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/04 23:12:20 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #678 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/05 00:13:25 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-724) Allow automatic socket.send.buffer from operating system - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/06/05 00:59:59 UTC, 0 replies.
- [GitHub] kafka pull request #50: KAFKA-724: auto socket buffer set - posted by rekhajoshm <gi...@git.apache.org> on 2016/06/05 01:03:54 UTC, 0 replies.
- [jira] [Commented] (KAFKA-724) Allow automatic socket.send.buffer from operating system - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/05 01:03:59 UTC, 3 replies.
- Jenkins build is back to normal : kafka-0.10.0-jdk7 #116 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/05 01:10:11 UTC, 0 replies.
- [GitHub] kafka pull request #1469: KAFKA-724; Send, receive buffer size set if not -1 - posted by rekhajoshm <gi...@git.apache.org> on 2016/06/05 01:17:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-3791) Broken tools -- need better way to get offsets and other info - posted by "Greg Zoller (JIRA)" <ji...@apache.org> on 2016/06/05 04:37:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-724) Allow automatic socket.send.buffer from operating system - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/05 07:14:59 UTC, 1 replies.
- [GitHub] kafka pull request #1470: MINOR: Move `ConsoleProducerTest` to the unit test... - posted by ijuma <gi...@git.apache.org> on 2016/06/05 07:40:07 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #679 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/05 08:13:12 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #117 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/05 08:20:54 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1342 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/05 08:39:04 UTC, 0 replies.
- [GitHub] kafka pull request #1471: MINOR: Fix producer leak in `PlaintextProducerSend... - posted by ijuma <gi...@git.apache.org> on 2016/06/05 09:24:41 UTC, 1 replies.
- [GitHub] kafka pull request #1472: KAFKA-3561: Auto create through topic for KStream ... - posted by dguy <gi...@git.apache.org> on 2016/06/05 14:59:13 UTC, 1 replies.
- [jira] [Created] (KAFKA-3792) Fix log spam in clients when topic doesn't exist - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/06/05 18:34:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3793) Kafka Python Consumer library messages gets truncated - posted by "Rahul (JIRA)" <ji...@apache.org> on 2016/06/06 00:51:59 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1343 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 02:39:07 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #680 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 04:16:03 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0 - posted by "Manikumar Reddy (JIRA)" <ji...@apache.org> on 2016/06/06 04:25:59 UTC, 0 replies.
- [GitHub] kafka pull request #1451: KAFKA-3771; Improving Kafka core code - posted by asfgit <gi...@git.apache.org> on 2016/06/06 07:46:37 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3771) Improving Kafka code - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/06 07:46:55 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3771) Improving Kafka code - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/06 07:46:55 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #681 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 08:13:09 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1344 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 08:39:04 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1345 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 09:56:49 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1346 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 09:59:11 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1348 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 11:29:36 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3167) Use local to the workspace Gradle cache and recreate it on every build - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/06 12:13:21 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #118 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 12:14:20 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3764) Error processing append operation on partition - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/06 12:18:21 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #683 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 13:10:00 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #119 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 14:21:52 UTC, 0 replies.
- [GitHub] kafka pull request #1473: KAFKA-3792: Fix log spam in clients for unknown to... - posted by rajinisivaram <gi...@git.apache.org> on 2016/06/06 14:42:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3792) Fix log spam in clients when topic doesn't exist - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/06 14:43:20 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #120 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 16:45:14 UTC, 0 replies.
- [GitHub] kafka pull request #1474: KAFKA-3748: Add consumer-property to console tools... - posted by bharatviswa504 <gi...@git.apache.org> on 2016/06/06 18:11:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3748) Add consumer-property to console tools consumer (similar to --producer-property) - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/06 18:31:21 UTC, 2 replies.
- [GitHub] kafka pull request #645: KAFKA-2948: Remove unused topics from producer meta... - posted by asfgit <gi...@git.apache.org> on 2016/06/06 18:56:35 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2948) Kafka producer does not cope well with topic deletions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/06 18:57:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2948) Kafka producer does not cope well with topic deletions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/06 18:58:21 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2016/06/06 18:58:21 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #684 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/06 20:15:33 UTC, 0 replies.
- [GitHub] kafka pull request #1168: KAFKA-1981 Make log compaction point configurable - posted by ewasserman <gi...@git.apache.org> on 2016/06/06 20:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1981) Make log compaction point configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/06 20:33:21 UTC, 6 replies.
- [jira] [Created] (KAFKA-3794) Add Stream / Table prefix in print functions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/06 20:53:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3795) Transient system test failure upgrade_test.TestUpgrade - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/06 21:16:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3795) Transient system test failure upgrade_test.TestUpgrade - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/06 21:46:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3796) SslTransportLayerTest.testInvalidEndpointIdentification fails on trunk - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/06/06 22:26:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3167) Use local to the workspace Gradle cache and recreate it on every build - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/06 22:45:21 UTC, 1 replies.
- [jira] [Work started] (KAFKA-3167) Use local to the workspace Gradle cache and recreate it on every build - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/06 22:46:20 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3794) Add Stream / Table prefix in print functions - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/06/06 23:22:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3794) Add Stream / Table prefix in print functions - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/06/06 23:22:21 UTC, 2 replies.
- [GitHub] kafka pull request #1475: MINOR: Add comment for round robin partitioner wit... - posted by Ishiihara <gi...@git.apache.org> on 2016/06/06 23:52:31 UTC, 1 replies.
- [GitHub] kafka pull request #1469: KAFKA-724; Allow automatic socket.send.buffer from... - posted by asfgit <gi...@git.apache.org> on 2016/06/07 00:20:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3396) Unauthorized topics are returned to the user - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 00:27:20 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3783) Race condition on last ACL removal for a resource fails with a ZkBadVersionException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 00:39:21 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3783) Race condition on last ACL removal for a resource fails with a ZkBadVersionException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 00:41:20 UTC, 1 replies.
- [jira] [Closed] (KAFKA-3783) Race condition on last ACL removal for a resource fails with a ZkBadVersionException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 00:42:21 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-3783) Race condition on last ACL removal for a resource fails with a ZkBadVersionException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 00:42:21 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1981) Make log compaction point configurable - posted by "Eric Wasserman (JIRA)" <ji...@apache.org> on 2016/06/07 00:56:21 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-3781) Errors.exceptionName() can throw NPE - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 01:41:21 UTC, 0 replies.
- [GitHub] kafka pull request #1476: KAFKA-3781; Errors.exceptionName() can throw NPE - posted by ijuma <gi...@git.apache.org> on 2016/06/07 02:34:27 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3781) Errors.exceptionName() can throw NPE - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 02:35:21 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3781) Errors.exceptionName() can throw NPE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 02:35:21 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1350 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/07 02:38:37 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #685 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/07 02:40:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-570) Kafka should not need snappy jar at runtime - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 02:45:21 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-570) Kafka should not need snappy jar at runtime - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 02:45:21 UTC, 0 replies.
- Jenkins build is back to normal : kafka-0.10.0-jdk7 #121 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/07 02:49:11 UTC, 0 replies.
- [GitHub] kafka pull request #1410: KAFKA-3443 [Kafka Streams] added support for subsc... - posted by bbejeck <gi...@git.apache.org> on 2016/06/07 02:54:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3443) Support regex topics in addSource() and stream() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 02:55:21 UTC, 2 replies.
- [jira] [Commented] (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/06/07 02:59:21 UTC, 2 replies.
- [jira] [Updated] (KAFKA-2720) Periodic purging groups in the coordinator - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 03:00:24 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3248) AdminClient Blocks Forever in send Method - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 03:03:20 UTC, 1 replies.
- [GitHub] kafka pull request #1477: KAFKA-3443 [Kafka Stream] support for adding sourc... - posted by bbejeck <gi...@git.apache.org> on 2016/06/07 03:25:11 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3796) SslTransportLayerTest.testInvalidEndpointIdentification fails on trunk - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/07 03:35:21 UTC, 1 replies.
- [jira] [Created] (KAFKA-3797) Improve security of __consumer_offsets topic - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/07 04:18:21 UTC, 0 replies.
- [GitHub] kafka pull request #1185: KAFKA-3501: Console consumer process hangs on exit - posted by asfgit <gi...@git.apache.org> on 2016/06/07 04:35:13 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3501) Console consumer process hangs on SIGINT - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 04:35:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3501) Console consumer process hangs on SIGINT - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/07 04:35:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3797) Improve security of __consumer_offsets topic - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/07 04:44:21 UTC, 7 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1351 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/07 05:21:43 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #122 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/07 06:10:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3793) Kafka Python Consumer library messages gets truncated - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/07 06:10:21 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #687 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/07 06:39:08 UTC, 0 replies.
- [jira] [Created] (KAFKA-3798) Kafka Consumer 0.10.0.0 killed after rebalancing exception - posted by "Sahitya Agrawal (JIRA)" <ji...@apache.org> on 2016/06/07 06:51:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3480) Autogenerate metrics documentation - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/07 06:51:21 UTC, 2 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #688 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/07 08:15:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3799) Turn on endpoint validation in SSL system tests - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/06/07 08:35:21 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3562) Null Pointer Exception Found when delete topic and Using New Producer - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/06/07 11:57:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3800) java client can`t poll msg - posted by "frank (JIRA)" <ji...@apache.org> on 2016/06/07 12:02:20 UTC, 0 replies.
- [GitHub] kafka pull request #1478: KAFKA-3562: Handle topic deletion during a send - posted by rajinisivaram <gi...@git.apache.org> on 2016/06/07 12:53:14 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3562) Null Pointer Exception Found when delete topic and Using New Producer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 12:53:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3753) Metrics for StateStores - posted by "Jeff Klukas (JIRA)" <ji...@apache.org> on 2016/06/07 14:08:21 UTC, 3 replies.
- [GitHub] kafka pull request #1479: KAFKA-3711: Ensure a RecordingMap is passed to con... - posted by jklukas <gi...@git.apache.org> on 2016/06/07 16:03:35 UTC, 1 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/06/07 16:32:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3801) Provide static serialize() and deserialize() for use as method references - posted by "Jeff Klukas (JIRA)" <ji...@apache.org> on 2016/06/07 16:32:21 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3797) Improve security of __consumer_offsets topic - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/07 17:10:21 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3061) Get rid of Guava dependency - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/06/07 17:16:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3061) Get rid of Guava dependency - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/07 19:11:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3802) log mtimes reset on broker restart - posted by "Andrew Otto (JIRA)" <ji...@apache.org> on 2016/06/07 19:47:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3802) log mtimes reset on broker restart - posted by "Andrew Otto (JIRA)" <ji...@apache.org> on 2016/06/07 19:48:21 UTC, 8 replies.
- Re: [DISCUSS] KIP-55: Secure quotas for authenticated users - posted by Jun Rao <ju...@confluent.io> on 2016/06/07 19:49:22 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2016/06/07 20:16:21 UTC, 1 replies.
- [VOTE] KIP-55: Secure quotas for authenticated users - posted by Rajini Sivaram <ra...@googlemail.com> on 2016/06/07 20:55:44 UTC, 35 replies.
- [GitHub] kafka pull request #1480: KAFKA-3762 Log.loadSegments() should log the messa... - posted by imandhan <gi...@git.apache.org> on 2016/06/07 21:34:58 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3762) Log.loadSegments() should log the message in exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 21:35:21 UTC, 2 replies.
- [jira] [Created] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals() - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/07 21:50:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3804) Kafka Connect's Struct objects rehydrated with JSON converter are not equal - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/07 21:50:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals() - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/07 21:50:21 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3804) Kafka Connect's Struct objects rehydrated with JSON converter are not equal - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/07 21:52:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals() - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/07 21:53:21 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals() - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/07 22:26:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3800) java client can`t poll msg - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/08 03:21:20 UTC, 4 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #689 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/08 04:26:22 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1354 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/08 05:33:26 UTC, 0 replies.
- kafka 9 group offset - posted by 揣立武 <ch...@meituan.com> on 2016/06/08 09:10:53 UTC, 0 replies.
- [jira] [Created] (KAFKA-3805) Java_org_rocksdb_RocksDB_write error - posted by "Andres Gomez Ferrer (JIRA)" <ji...@apache.org> on 2016/06/08 10:59:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3805) Java_org_rocksdb_RocksDB_write error - posted by "Andres Gomez Ferrer (JIRA)" <ji...@apache.org> on 2016/06/08 11:00:26 UTC, 6 replies.
- [jira] [Commented] (KAFKA-3805) Java_org_rocksdb_RocksDB_write error - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/08 11:34:20 UTC, 8 replies.
- [jira] [Comment Edited] (KAFKA-3805) Java_org_rocksdb_RocksDB_write error - posted by "Andres Gomez Ferrer (JIRA)" <ji...@apache.org> on 2016/06/08 11:50:21 UTC, 5 replies.
- Questions about Kafka Scripts - posted by Kamal C <ka...@gmail.com> on 2016/06/08 13:13:52 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3805) Running multiple instances of a Streams app on the same machine results in Java_org_rocksdb_RocksDB_write error - posted by "Michael Noll (JIRA)" <ji...@apache.org> on 2016/06/08 13:31:20 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-3805) Running multiple instances of a Streams app on the same machine results in Java_org_rocksdb_RocksDB_write error - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/08 13:33:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3805) Running multiple instances of a Streams app on the same machine results in Java_org_rocksdb_RocksDB_write error - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/08 13:34:21 UTC, 12 replies.
- [jira] [Created] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes - posted by "Michal Turek (JIRA)" <ji...@apache.org> on 2016/06/08 15:16:21 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3805) Running multiple instances of a Streams app on the same machine results in Java_org_rocksdb_RocksDB_write error - posted by "Andres Gomez Ferrer (JIRA)" <ji...@apache.org> on 2016/06/08 16:32:21 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-3711) Allow configuration of MetricsReporter subclasses - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/08 16:34:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/08 17:00:25 UTC, 9 replies.
- [jira] [Commented] (KAFKA-3788) Potential message lost when switching to new segment - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/08 17:31:20 UTC, 2 replies.
- [jira] [Commented] (KAFKA-2904) Consumer Fails to Reconnect after 30s post restarts - posted by "mjuarez (JIRA)" <ji...@apache.org> on 2016/06/08 18:08:21 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1355 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/08 18:20:34 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2904) Consumer Fails to Reconnect after 30s post restarts - posted by "mjuarez (JIRA)" <ji...@apache.org> on 2016/06/08 18:22:21 UTC, 0 replies.
- Kafka Streams aggregation store - posted by Alexander Jipa <al...@gmail.com> on 2016/06/08 18:47:05 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #690 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/08 19:02:34 UTC, 0 replies.
- [GitHub] kafka pull request #1481: MINOR: Pass absolute directory path to RocksDB.ope... - posted by jklukas <gi...@git.apache.org> on 2016/06/08 19:51:26 UTC, 1 replies.
- [jira] [Created] (KAFKA-3807) OffsetValidationTest - transient failure on test_broker_rolling_bounce - posted by "Geoff Anderson (JIRA)" <ji...@apache.org> on 2016/06/08 20:38:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3807) OffsetValidationTest - transient failure on test_broker_rolling_bounce - posted by "Geoff Anderson (JIRA)" <ji...@apache.org> on 2016/06/08 20:39:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3808) Transient failure in ReplicaVerificationToolTest - posted by "Geoff Anderson (JIRA)" <ji...@apache.org> on 2016/06/08 20:48:21 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2003) Add upgrade tests - posted by "Geoff Anderson (JIRA)" <ji...@apache.org> on 2016/06/08 21:55:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-168) Support locality in consumer partition assignment algorithm - posted by "Dominic Chambers (JIRA)" <ji...@apache.org> on 2016/06/08 22:16:20 UTC, 0 replies.
- [jira] [Created] (KAFKA-3809) Auto-generate documentation for topic-level configuration - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/09 01:27:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3809) Auto-generate documentation for topic-level configuration - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/09 01:47:20 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3809) Auto-generate documentation for topic-level configuration - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/09 02:08:20 UTC, 5 replies.
- [GitHub] kafka pull request #1482: MINOR: Fix a variable name semantically correct. - posted by uchan-nos <gi...@git.apache.org> on 2016/06/09 06:59:57 UTC, 1 replies.
- [GitHub] kafka pull request #1483: KAFKA-3799: Enable SSL endpoint validation in syst... - posted by rajinisivaram <gi...@git.apache.org> on 2016/06/09 07:02:14 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3799) Turn on endpoint validation in SSL system tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/09 07:02:20 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3788) Potential message lost when switching to new segment - posted by "Arkadiusz Firus (JIRA)" <ji...@apache.org> on 2016/06/09 07:51:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3562) Null Pointer Exception Found when delete topic and Using New Producer - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/06/09 08:35:20 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3799) Turn on endpoint validation in SSL system tests - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/06/09 08:36:20 UTC, 0 replies.
- [jira] [Created] (KAFKA-3810) replication of internal topics should not be limited by replica.fetch.max.bytes - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2016/06/09 09:42:20 UTC, 0 replies.
- [GitHub] kafka pull request #1484: KAFKA-3810: replication of internal topics should ... - posted by onurkaraman <gi...@git.apache.org> on 2016/06/09 09:51:44 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3810) replication of internal topics should not be limited by replica.fetch.max.bytes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/09 09:52:21 UTC, 2 replies.
- Re: [DISCUSS] scalability limits in the coordinator - posted by Onur Karaman <ok...@linkedin.com.INVALID> on 2016/06/09 10:03:52 UTC, 6 replies.
- [GitHub] kafka pull request #1485: KAFKA-3805: Check if DB is null. Do not release lo... - posted by enothereska <gi...@git.apache.org> on 2016/06/09 14:47:02 UTC, 0 replies.
- [GitHub] kafka pull request #1486: KAFKA-3753: Add size() method to KeyValueStore int... - posted by jklukas <gi...@git.apache.org> on 2016/06/09 15:12:58 UTC, 0 replies.
- [GitHub] kafka pull request #1487: kafka-run-class.sh now runs under Cygwin. - posted by deragon <gi...@git.apache.org> on 2016/06/09 15:14:24 UTC, 0 replies.
- Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism - posted by Harsha <ka...@harsha.io> on 2016/06/09 16:48:49 UTC, 7 replies.
- [jira] [Created] (KAFKA-3811) Introduce KStream metrics recording levels - posted by "Greg Fodor (JIRA)" <ji...@apache.org> on 2016/06/09 18:00:26 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3811) Introduce Kafka Streams metrics recording levels - posted by "Greg Fodor (JIRA)" <ji...@apache.org> on 2016/06/09 18:00:26 UTC, 4 replies.
- [jira] [Work started] (KAFKA-3805) Running multiple instances of a Streams app on the same machine results in Java_org_rocksdb_RocksDB_write error - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/09 18:22:20 UTC, 0 replies.
- [jira] [Created] (KAFKA-3812) State store locking is incorrect - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/09 18:29:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3813) Let SourceConnector implementations access the offset reader - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 18:48:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3813) Let SourceConnector implementations access the offset reader - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 18:53:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3814) Connectors should be able to know their name - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 19:03:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3753) Add size() to the StateStore interface for metrics reporting - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/09 19:07:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3815) Support command line arguments in Kafka Connect distribute worker - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 19:16:20 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3815) Support command line arguments in Kafka Connect distributed worker - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 19:18:21 UTC, 2 replies.
- [jira] [Created] (KAFKA-3816) Provide more context in Kafka Connect log messages - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 19:29:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3816) Provide more context in Kafka Connect log messages - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 19:36:21 UTC, 2 replies.
- [jira] [Commented] (KAFKA-2082) Kafka Replication ends up in a bad state - posted by "Evan Huus (JIRA)" <ji...@apache.org> on 2016/06/09 20:42:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3802) log mtimes reset on broker restart - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/09 20:43:21 UTC, 1 replies.
- [jira] [Created] (KAFKA-3817) KTableRepartitionMap should handle null inputs - posted by "Jeff Klukas (JIRA)" <ji...@apache.org> on 2016/06/09 20:44:21 UTC, 0 replies.
- Question on Kafka Consumer - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/06/09 20:47:49 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3753) Add size() to the StateStore interface for metrics reporting - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2016/06/09 20:52:21 UTC, 1 replies.
- [jira] [Created] (KAFKA-3818) Change Mirror Maker default assignment strategy to round robin - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/09 20:54:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3819) Provide utilities for polling source connectors - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/09 20:56:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3819) Provide utilities for polling source connectors - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/09 20:56:21 UTC, 2 replies.
- [jira] [Created] (KAFKA-3820) Provide utilities for tracking source offsets - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/09 21:00:23 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3811) Introduce Kafka Streams metrics recording levels - posted by "aarti gupta (JIRA)" <ji...@apache.org> on 2016/06/09 21:03:21 UTC, 9 replies.
- [jira] [Commented] (KAFKA-3814) Connectors should be able to know their name - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/09 21:22:20 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3814) Connectors should be able to know their name - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 21:28:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 21:37:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/09 21:46:20 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-3818) Change Mirror Maker default assignment strategy to round robin - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/09 22:08:20 UTC, 0 replies.
- [GitHub] kafka pull request #1488: KAFKA-3817: handle null keys in KTableRepartitionM... - posted by guozhangwang <gi...@git.apache.org> on 2016/06/09 22:41:56 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3817) KTableRepartitionMap should handle null inputs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/09 22:42:20 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3234) Minor documentation edits: clarify minISR; some topic-level configs are missing - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/09 22:56:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3801) Provide static serialize() and deserialize() for use as method references - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/09 23:02:21 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-3820) Provide utilities for tracking source offsets - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2016/06/09 23:05:20 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3816) Provide more context in Kafka Connect log messages - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/10 01:08:20 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2934) Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig - posted by "Peter Davis (JIRA)" <ji...@apache.org> on 2016/06/10 01:24:20 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-3693) Race condition between highwatermark-checkpoint thread and handleLeaderAndIsrRequest at broker start-up - posted by "Maysam Yabandeh (JIRA)" <ji...@apache.org> on 2016/06/10 03:55:21 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1 - posted by "Petr Novotnik (JIRA)" <ji...@apache.org> on 2016/06/10 09:01:21 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2016/06/10 13:13:21 UTC, 9 replies.
- [jira] [Assigned] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2016/06/10 13:28:21 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2016/06/10 15:27:20 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3811) Introduce Kafka Streams metrics recording levels - posted by "aarti gupta (JIRA)" <ji...@apache.org> on 2016/06/10 15:30:21 UTC, 0 replies.
- [GitHub] kafka pull request #1489: KAFKA-2945: CreateTopic - protocol and server side... - posted by granthenke <gi...@git.apache.org> on 2016/06/10 16:20:50 UTC, 0 replies.
- [GitHub] kafka pull request #626: KAFKA-2945: CreateTopic - protocol and server side ... - posted by granthenke <gi...@git.apache.org> on 2016/06/10 16:21:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2945) CreateTopic - protocol and server side implementation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/10 16:21:21 UTC, 1 replies.
- [DISCUSS] KIP-4 Create Topic Schema - posted by Grant Henke <gh...@cloudera.com> on 2016/06/10 16:21:34 UTC, 26 replies.
- [jira] [Created] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected - posted by "Alexander Cook (JIRA)" <ji...@apache.org> on 2016/06/10 16:48:21 UTC, 0 replies.
- Re: [VOTE] KIP-33 - Add a time based log index - posted by Becket Qin <be...@gmail.com> on 2016/06/10 17:07:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected - posted by "Alexander Cook (JIRA)" <ji...@apache.org> on 2016/06/10 17:15:21 UTC, 1 replies.
- [jira] [Created] (KAFKA-3823) QuickStart documentation is still showing MirrorMakers supports more than one consumer.config - posted by "Chak Lee (JIRA)" <ji...@apache.org> on 2016/06/10 18:44:21 UTC, 0 replies.
- [GitHub] kafka pull request #1490: KAFKA-3769: Optimize metrics recording overhead - posted by guozhangwang <gi...@git.apache.org> on 2016/06/10 19:39:04 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/06/10 19:42:21 UTC, 10 replies.
- [jira] [Resolved] (KAFKA-3817) KTableRepartitionMap should handle null inputs - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/10 20:15:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3753) Add approximateNumEntries() to the StateStore interface for metrics reporting - posted by "Jeff Klukas (JIRA)" <ji...@apache.org> on 2016/06/10 21:02:21 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/06/10 21:23:21 UTC, 0 replies.
- [GitHub] kafka pull request #1491: remove size and message count constraints - posted by ewasserman <gi...@git.apache.org> on 2016/06/10 21:37:29 UTC, 3 replies.
- Jenkins build is back to normal : kafka-0.10.0-jdk7 #123 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/10 21:38:06 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2016/06/10 22:00:23 UTC, 0 replies.
- [GitHub] kafka pull request #1492: Change Mirror Maker default assignment strategy to... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/10 22:34:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1356 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/10 22:38:33 UTC, 0 replies.
- [GitHub] kafka pull request #1492: KAFKA-3818: Change Mirror Maker default assignment... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/10 22:44:54 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3818) Change Mirror Maker default assignment strategy to round robin - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/10 22:45:21 UTC, 8 replies.
- [GitHub] kafka pull request #1493: KAFKA-3818: Change Mirror Maker default assignment... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/10 22:46:38 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3818) Change Mirror Maker default assignment strategy to round robin - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/10 22:49:20 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3801) Provide static serialize() and deserialize() for use as method references - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/10 22:54:20 UTC, 0 replies.
- [GitHub] kafka pull request #1494: KAFKA-1981Make log compaction point configurable - posted by ewasserman <gi...@git.apache.org> on 2016/06/10 22:56:27 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3791) Broken tools -- need better way to get offsets and other info - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/10 23:14:21 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3791) Broken tools -- need better way to get offsets and other info - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/10 23:15:21 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1120) Controller could miss a broker state change - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/10 23:28:20 UTC, 0 replies.
- [GitHub] kafka pull request #1495: Minor: Respect the default value for partition arg... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/10 23:57:31 UTC, 0 replies.
- [jira] [Created] (KAFKA-3824) Docs indicate auto.commit breaks at least once delivery but that is incorrect - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2016/06/11 04:01:20 UTC, 0 replies.
- [GitHub] kafka pull request #1496: MINOR: Fix connect development guide. - posted by uchan-nos <gi...@git.apache.org> on 2016/06/11 08:12:43 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3408) consumer rebalance fail - posted by "kambiz shahri (JIRA)" <ji...@apache.org> on 2016/06/11 11:20:21 UTC, 2 replies.
- [jira] [Created] (KAFKA-3825) Allow users to specify different types of state stores in Streams DSL - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/11 18:53:20 UTC, 0 replies.
- [GitHub] kafka pull request #1497: KAFKA-3802 log mtimes reset on broker restart / sh... - posted by msiuts <gi...@git.apache.org> on 2016/06/11 20:34:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3073) KafkaConnect should support regular expression for topics - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/11 23:43:21 UTC, 0 replies.
- [GitHub] kafka pull request #1495: MINOR: Respect the default value of partition argu... - posted by asfgit <gi...@git.apache.org> on 2016/06/12 00:51:10 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1357 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/12 01:32:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-3826) Sampling on throughput / latency metrics recording in Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/12 02:46:20 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #692 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/12 03:12:55 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1358 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/12 03:23:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1452) Killing last replica for partition doesn't change ISR/Leadership if replica is running controller - posted by "Stevo Slavic (JIRA)" <ji...@apache.org> on 2016/06/12 11:30:25 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1452) Killing last replica for partition doesn't change ISR/Leadership if replica is running controller - posted by "Stevo Slavic (JIRA)" <ji...@apache.org> on 2016/06/12 11:32:21 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3824) Docs indicate auto.commit breaks at least once delivery but that is incorrect - posted by "kambiz shahri (JIRA)" <ji...@apache.org> on 2016/06/12 11:44:21 UTC, 0 replies.
- [jira] [Closed] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams - posted by "Yuto Kawamura (JIRA)" <ji...@apache.org> on 2016/06/12 15:21:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3824) Docs indicate auto.commit breaks at least once delivery but that is incorrect - posted by "kambiz shahri (JIRA)" <ji...@apache.org> on 2016/06/12 20:22:21 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-3824) Docs indicate auto.commit breaks at least once delivery but that is incorrect - posted by "kambiz shahri (JIRA)" <ji...@apache.org> on 2016/06/12 20:23:20 UTC, 4 replies.
- [jira] [Created] (KAFKA-3827) log.message.format.version should default to inter.broker.protocol.version - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/12 20:58:20 UTC, 0 replies.
- [jira] [Created] (KAFKA-3828) Consumer thread stalls after consumer re balance for some partition - posted by "Joseph Aliase (JIRA)" <ji...@apache.org> on 2016/06/13 01:52:20 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3827) log.message.format.version should default to inter.broker.protocol.version - posted by "Manasvi Gupta (JIRA)" <ji...@apache.org> on 2016/06/13 03:59:20 UTC, 0 replies.
- Re: Any restrictions on consumer group name? - posted by Jaikiran Pai <ja...@gmail.com> on 2016/06/13 04:36:14 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3811) Introduce Kafka Streams metrics recording levels - posted by "aarti gupta (JIRA)" <ji...@apache.org> on 2016/06/13 05:52:21 UTC, 0 replies.
- Kafka Streaming - Window expiration - posted by Pariksheet Barapatre <pa...@gmail.com> on 2016/06/13 07:31:13 UTC, 2 replies.
- [jira] [Created] (KAFKA-3829) Warn that kafka-connect group.id must not conflice with connector names - posted by "Barry Kaplan (JIRA)" <ji...@apache.org> on 2016/06/13 09:13:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3828) Consumer thread stalls after consumer re balance for some partition - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/13 09:30:21 UTC, 6 replies.
- [jira] [Commented] (KAFKA-3209) Support single message transforms in Kafka Connect - posted by "Pablo Casares (JIRA)" <ji...@apache.org> on 2016/06/13 11:59:20 UTC, 2 replies.
- [jira] [Created] (KAFKA-3830) getTGT() debug logging exposes confidential information - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/13 13:07:20 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3576) Unify KStream and KTable API - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/13 13:19:21 UTC, 1 replies.
- [GitHub] kafka pull request #1498: KAFKA-3830; getTGT() debug logging exposes confide... - posted by ijuma <gi...@git.apache.org> on 2016/06/13 13:24:19 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3830) getTGT() debug logging exposes confidential information - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/13 13:24:21 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3830) getTGT() debug logging exposes confidential information - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/13 13:25:20 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1464) Add a throttling option to the Kafka replication tool - posted by "Ralph Weires (JIRA)" <ji...@apache.org> on 2016/06/13 15:10:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3831) Preparation for updating the default partition assignment strategy of Mirror Maker to round robin - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/13 15:49:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/13 16:52:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3833) Feature Request: allow Kafka clients to retrieve Kafka broker versions - posted by "Hari Sekhon (JIRA)" <ji...@apache.org> on 2016/06/13 16:52:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3833) Feature Request: allow Kafka clients to retrieve Kafka broker versions - posted by "Hari Sekhon (JIRA)" <ji...@apache.org> on 2016/06/13 16:53:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-3834) Consumer should not block in poll on coordinator discovery - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/13 17:03:21 UTC, 0 replies.
- [GitHub] kafka pull request #1499: KAFKA-3831: Prepare for updating Mirror Maker's de... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/13 17:14:14 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3831) Preparation for updating the default partition assignment strategy of Mirror Maker to round robin - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/13 17:14:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3831) Preparation for updating the default partition assignment strategy of Mirror Maker to round robin - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/13 18:46:30 UTC, 0 replies.
- RE: Migrating from 07.1 .100 - posted by Subhash Agrawal <ag...@opentext.com> on 2016/06/13 19:07:53 UTC, 0 replies.
- [GitHub] kafka pull request #1500: MINOR: Fix javadoc typos in ConsumerRebalanceListe... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/13 20:05:27 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-3786) Avoid unused property from parent configs causing WARN entries - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/13 21:16:03 UTC, 0 replies.
- [GitHub] kafka pull request #1501: MINOR: Expose window store sequence number - posted by theduderog <gi...@git.apache.org> on 2016/06/13 22:58:01 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #693 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/13 23:27:46 UTC, 0 replies.
- [GitHub] kafka pull request #1502: MINOR: Clarify the at least once delivery with aut... - posted by Ishiihara <gi...@git.apache.org> on 2016/06/13 23:50:55 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3686) Kafka producer is not fault tolerant - posted by "radha (JIRA)" <ji...@apache.org> on 2016/06/14 02:01:03 UTC, 0 replies.
- Re: Migrating from 07.1 .100 - posted by Gerard Klijs <ge...@dizzit.com> on 2016/06/14 05:21:47 UTC, 0 replies.
- [jira] [Created] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/14 10:04:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/14 12:22:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3737) Closing connection during produce request should be log with WARN level. - posted by "Florian Hussonnois (JIRA)" <ji...@apache.org> on 2016/06/14 13:21:07 UTC, 0 replies.
- [GitHub] kafka pull request #1503: MINOR: Small enhancement to Deserializer Javadoc - posted by aviflax <gi...@git.apache.org> on 2016/06/14 14:32:29 UTC, 0 replies.
- [jira] [Created] (KAFKA-3836) KStreamReduce and KTableReduce should not pass nulls to Deserializers - posted by "Avi Flax (JIRA)" <ji...@apache.org> on 2016/06/14 14:41:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-3837) Report the name of the blocking thread when throwing ConcurrentModificationException - posted by "Simon Cooper (JIRA)" <ji...@apache.org> on 2016/06/14 14:47:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-3838) Bump zkclient and Zookeeper versions - posted by "FIlipe Azevedo (JIRA)" <ji...@apache.org> on 2016/06/14 15:50:01 UTC, 0 replies.
- [GitHub] kafka pull request #1504: KAFKA-3838 zkClient and Zookeeper version bump - posted by mangas <gi...@git.apache.org> on 2016/06/14 15:50:35 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3838) Bump zkclient and Zookeeper versions - posted by "FIlipe Azevedo (JIRA)" <ji...@apache.org> on 2016/06/14 15:51:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3838) Bump zkclient and Zookeeper versions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/14 15:51:01 UTC, 3 replies.
- [GitHub] kafka pull request #1395: KAFKA-3699: Update protocol page on website to exp... - posted by asfgit <gi...@git.apache.org> on 2016/06/14 16:51:09 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3699) Update protocol page on website to explain how KIP-35 should be used - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/14 16:51:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3699) Update protocol page on website to explain how KIP-35 should be used - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/14 16:51:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3836) KStreamReduce and KTableReduce should not pass nulls to Deserializers - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/14 18:16:27 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3762) Log.loadSegments() should log the message in exception - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/14 18:55:27 UTC, 0 replies.
- [GitHub] kafka pull request #1402: MINOR: Catch Throwable in commitSourceTask() - posted by asfgit <gi...@git.apache.org> on 2016/06/14 20:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3837) Report the name of the blocking thread when throwing ConcurrentModificationException - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/14 21:06:30 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/14 21:16:30 UTC, 7 replies.
- [jira] [Created] (KAFKA-3839) Handling null keys in KTable.groupBy - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/14 22:01:30 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3839) Handling null keys in KTable.groupBy - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/14 22:01:30 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3837) Report the name of the blocking thread when throwing ConcurrentModificationException - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/14 22:15:30 UTC, 6 replies.
- [GitHub] kafka pull request #1505: KAFKA-3837: Report the thread id of the blocking t... - posted by bharatviswa504 <gi...@git.apache.org> on 2016/06/14 22:16:45 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3837) Report the name of the blocking thread when throwing ConcurrentModificationException - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/14 22:18:30 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3837) Report the name of the blocking thread when throwing ConcurrentModificationException - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/14 22:22:30 UTC, 2 replies.
- [jira] [Created] (KAFKA-3840) OS auto tuning for socket buffer size in clients not allowed through configuration - posted by "Sébastien Launay (JIRA)" <ji...@apache.org> on 2016/06/14 22:28:30 UTC, 0 replies.
- [GitHub] kafka pull request #1506: KAFKA-3755 Tightening the offset check in ReplicaF... - posted by imandhan <gi...@git.apache.org> on 2016/06/14 22:29:50 UTC, 1 replies.
- [GitHub] kafka pull request #1507: KAFKA-3840; Allow clients default OS buffer sizes - posted by slaunay <gi...@git.apache.org> on 2016/06/14 22:33:07 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3840) OS auto tuning for socket buffer size in clients not allowed through configuration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/14 22:33:30 UTC, 1 replies.
- [jira] [Created] (KAFKA-3841) MirrorMaker topic renaming - posted by "Ning Zhang (JIRA)" <ji...@apache.org> on 2016/06/14 22:54:30 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3841) MirrorMaker topic renaming - posted by "Ning Zhang (JIRA)" <ji...@apache.org> on 2016/06/14 22:59:30 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3841) MirrorMaker topic renaming - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/14 23:04:30 UTC, 3 replies.
- [jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2016/06/14 23:16:30 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1894) Avoid long or infinite blocking in the consumer - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2016/06/14 23:18:30 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3839) Handling null keys in KTable.groupBy - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/06/14 23:30:30 UTC, 3 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1361 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/14 23:47:39 UTC, 0 replies.
- Memory consumption of Kafka-examples Kafka-streams around 1.5 GB - posted by Philippe Derome <ph...@gmail.com> on 2016/06/14 23:50:06 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-3144) report members with no assigned partitions in ConsumerGroupCommand - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/15 00:27:06 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-3839) Handling null keys in KTable.groupBy - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 04:10:09 UTC, 0 replies.
- [jira] [Created] (KAFKA-3842) Add Helper Functions Into TestUtils - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/06/15 04:27:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3842) Add Helper Functions Into TestUtils - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/06/15 04:42:09 UTC, 3 replies.
- [jira] [Commented] (KAFKA-3144) report members with no assigned partitions in ConsumerGroupCommand - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/15 07:33:09 UTC, 10 replies.
- [jira] [Created] (KAFKA-3843) Endless consuming messages in Kafka cluster - posted by "Tomas Benc (JIRA)" <ji...@apache.org> on 2016/06/15 09:04:09 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1429) Yet another deadlock in controller shutdown - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2016/06/15 10:48:09 UTC, 1 replies.
- [jira] [Work started] (KAFKA-3839) Handling null keys in KTable.groupBy - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/06/15 10:56:09 UTC, 0 replies.
- Complexe Event Processing on top of KafkaStreams - posted by Florian Hussonnois <fh...@gmail.com> on 2016/06/15 10:59:02 UTC, 2 replies.
- [jira] [Created] (KAFKA-3844) Sort configuration items in log - posted by "Xing Huang (JIRA)" <ji...@apache.org> on 2016/06/15 11:01:09 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed" - posted by "Debowczyk (JIRA)" <ji...@apache.org> on 2016/06/15 13:11:09 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed" - posted by "Debowczyk (JIRA)" <ji...@apache.org> on 2016/06/15 13:12:09 UTC, 0 replies.
- [GitHub] kafka pull request #1508: MINOR: Fix quota violation exception message - posted by rajinisivaram <gi...@git.apache.org> on 2016/06/15 14:41:44 UTC, 1 replies.
- [GitHub] kafka pull request #1509: KAFKA-3691: Confusing logging during metadata upda... - posted by granthenke <gi...@git.apache.org> on 2016/06/15 15:20:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3691) Confusing logging during metadata update timeout - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/15 15:20:10 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3691) Confusing logging during metadata update timeout - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2016/06/15 15:21:09 UTC, 4 replies.
- [jira] [Updated] (KAFKA-3008) Connect should parallelize task start/stop - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 15:43:09 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-2944) NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 15:53:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2483) Add support for batch/scheduled Copycat connectors - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 15:56:09 UTC, 3 replies.
- [GitHub] kafka pull request #1510: Minor: warn if the TGT cannot be renewed. - posted by harshach <gi...@git.apache.org> on 2016/06/15 16:05:08 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2376) Add Copycat metrics - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 16:51:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-2378) Add Copycat embedded API - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 16:53:09 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-2365) Copycat checklist - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 16:54:10 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3254) Add Connect storage topic prefix for easier configuration - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 16:56:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3106) After PUT a connector config from REST API, GET a connector config will fail - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:10:10 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3524) ConnectorTaskId should also also include cluster id - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:11:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:11:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3351) Kafka Connect Rest restarts all connectors on POST or DELETE - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:12:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3500) KafkaOffsetBackingStore set method needs to handle null - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:13:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3759) Incorrect JDBC credentials cause Connect worker to permanently fail - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:13:09 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3759) Incorrect JDBC credentials cause Connect worker to permanently fail - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:15:10 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3734) Exceptions in SourceTask.commit() methods should cause task to stop and report failed state - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:16:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-2894) WorkerSinkTask doesn't handle rewinding offsets on rebalance - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:24:09 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3782) Transient failure with kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_bounce.clean=True - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:26:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3813) Let SourceConnector implementations access the offset reader - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:27:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3820) Provide utilities for tracking source offsets - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:29:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3487) Support per-connector/per-task classloaders in Connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:30:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3816) Provide more context in Kafka Connect log messages - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:30:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3073) KafkaConnect should support regular expression for topics - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:31:09 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3209) Support single message transforms in Kafka Connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:32:09 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:32:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3054) Connect Herder fail forever if sent a wrong connector config or task config - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:35:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2941) Docs for key/value converter in Kafka connect are unclear - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:36:09 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2925) NullPointerException if FileStreamSinkTask is stopped before initialization finishes - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:38:09 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2925) NullPointerException if FileStreamSinkTask is stopped before initialization finishes - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 17:39:09 UTC, 0 replies.
- [jira] [Created] (KAFKA-3845) Support per-connector converters - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 18:12:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3845) Support per-connector converters - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 18:12:09 UTC, 0 replies.
- [jira] [Created] (KAFKA-3846) Connect record types should include timestamps - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 18:16:10 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 18:19:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3400) Topic stop working / can't describe topic - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/15 18:36:09 UTC, 0 replies.
- [jira] [Created] (KAFKA-3847) Connect tasks should not share a producer - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/15 18:45:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3543) Allow a variant of transform() which can emit multiple values - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:47:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3708) Rethink exception handling in KafkaStreams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:48:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:48:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3741) KStream config for changelog min.in.sync.replicas - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:48:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3770) KStream job should be able to specify linger.ms - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:48:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3576) Unify KStream and KTable API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:49:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3752) Provide a way for KStreams to recover from unclean shutdown - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:49:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3545) Generalized Serdes for List/Map - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:50:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:50:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3535) Add metrics ability for streams serde components - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:50:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3701) Expose KafkaStreams metrics in public API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:51:09 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3836) KStreamReduce and KTableReduce should not pass nulls to Deserializers - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/15 18:51:09 UTC, 1 replies.
- [jira] [Created] (KAFKA-3848) Mirror Maker sometimes fails to mirror first batch of messages - posted by "James Clarke (JIRA)" <ji...@apache.org> on 2016/06/15 19:46:09 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #696 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/15 20:01:06 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1362 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/15 20:09:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3848) Mirror Maker sometimes fails to mirror first batch of messages - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/15 20:27:09 UTC, 3 replies.
- Embedding zookeeper and kafka in java process. - posted by Subhash Agrawal <ag...@opentext.com> on 2016/06/15 20:56:21 UTC, 7 replies.
- [jira] [Work started] (KAFKA-3837) Report the name of the blocking thread when throwing ConcurrentModificationException - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/15 21:33:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/15 21:44:09 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #697 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/15 21:50:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3849) Make consumer poll time in MirrorMaker configurable. - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/15 22:21:09 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3536) ReplicaFetcherThread should not log errors when leadership changes - posted by "Jason Rosenberg (JIRA)" <ji...@apache.org> on 2016/06/15 22:34:09 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3818) Change Mirror Maker default assignment strategy to round robin - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/15 23:05:33 UTC, 0 replies.
- [GitHub] kafka pull request #1486: KAFKA-3753: Add approximateNumEntries() method to ... - posted by asfgit <gi...@git.apache.org> on 2016/06/16 00:09:03 UTC, 0 replies.
- [GitHub] kafka pull request #1511: KAFKA-XXXX: WorkerSinkTask commit prior to rebalan... - posted by hachikuji <gi...@git.apache.org> on 2016/06/16 00:43:54 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #698 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/16 01:46:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3443) Support regex topics in addSource() and stream() - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/16 02:21:05 UTC, 0 replies.
- [GitHub] kafka pull request #1427: KAFKA-2720: expire group metadata when all offsets... - posted by asfgit <gi...@git.apache.org> on 2016/06/16 02:48:34 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2720) Periodic purging groups in the coordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/16 02:49:05 UTC, 2 replies.
- [jira] [Created] (KAFKA-3850) WorkerSinkTask should retry commits if woken up during rebalance or shutdown - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/16 03:02:05 UTC, 0 replies.
- [GitHub] kafka pull request #1511: KAFKA-3850: WorkerSinkTask commit prior to rebalan... - posted by hachikuji <gi...@git.apache.org> on 2016/06/16 03:02:22 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3850) WorkerSinkTask should retry commits if woken up during rebalance or shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/16 03:03:05 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3850) WorkerSinkTask should retry commits if woken up during rebalance or shutdown - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/16 03:03:05 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #699 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/16 04:29:34 UTC, 0 replies.
- [GitHub] kafka pull request #1512: KAFKA-3838 zkClient and Zookeeper version bump - posted by mangas <gi...@git.apache.org> on 2016/06/16 07:58:20 UTC, 1 replies.
- Re: FYI - Apache ZooKeeper Backup, a Treatise - posted by Flavio Junqueira <fp...@apache.org> on 2016/06/16 08:03:13 UTC, 8 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #700 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/16 08:19:53 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3840) OS auto tuning for socket buffer size in clients not allowed through configuration - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/16 12:40:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3370) Add options to auto.offset.reset to reset offsets upon initialization only - posted by "James Clarke (JIRA)" <ji...@apache.org> on 2016/06/16 13:10:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #701 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/16 15:12:26 UTC, 0 replies.
- [jira] [Created] (KAFKA-3851) Add references to important installation/upgrade notes to release notes - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/16 16:42:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3852) Clarify how to handle message format upgrade without killing performance - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/16 16:46:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3851) Add references to important installation/upgrade notes to release notes - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/16 16:47:05 UTC, 0 replies.
- [GitHub] kafka pull request #1513: MINOR: Follow-up from KAFKA-2720 with comment/styl... - posted by hachikuji <gi...@git.apache.org> on 2016/06/16 17:03:49 UTC, 1 replies.
- [jira] [Created] (KAFKA-3853) Report offsets for empty groups in ConsumerGroupCommand - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/16 17:18:05 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3853) Report offsets for empty groups in ConsumerGroupCommand - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/16 17:23:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3854) Consecutive regex subscription calls fail - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/16 18:08:05 UTC, 0 replies.
- avro-console-producer issue for Kafka Stream example PageViewRegionLambdaExample - posted by Philippe Derome <ph...@gmail.com> on 2016/06/16 18:33:06 UTC, 2 replies.
- [VOTE] KIP-62: Allow consumer to send heartbeats from a background thread - posted by Jason Gustafson <ja...@confluent.io> on 2016/06/16 18:44:04 UTC, 21 replies.
- [jira] [Created] (KAFKA-3855) Guard race conditions in TopologyBuilder - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/16 18:49:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3856) Move inner classes accessible only functions in TopologyBuilder out of public APIs - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/16 18:56:05 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3561) Auto create through topic for KStream aggregation and join - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/16 18:57:05 UTC, 0 replies.
- [GitHub] kafka pull request #1514: MINOR: Mention `log.message.format.version=0.10.0`... - posted by ijuma <gi...@git.apache.org> on 2016/06/16 18:59:52 UTC, 1 replies.
- [jira] [Created] (KAFKA-3857) Additional log cleaner metrics - posted by "Kiran Pillarisetty (JIRA)" <ji...@apache.org> on 2016/06/16 19:20:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-789) Producer-side persistence for delivery guarantee - posted by "radha (JIRA)" <ji...@apache.org> on 2016/06/16 19:41:05 UTC, 0 replies.
- [GitHub] kafka pull request #1515: KAFKA-3849: Make consumer poll time in MirrorMaker... - posted by SinghAsDev <gi...@git.apache.org> on 2016/06/16 19:44:52 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3849) Make consumer poll time in MirrorMaker configurable. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/16 19:45:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3849) Make consumer poll time in MirrorMaker configurable. - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/16 19:46:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #702 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/16 20:01:57 UTC, 0 replies.
- [DISCUSS] Java 8 as a minimum requirement - posted by Ismael Juma <is...@juma.me.uk> on 2016/06/16 20:45:58 UTC, 21 replies.
- [jira] [Created] (KAFKA-3858) Add functions to print stream topologies - posted by "Roger Hoover (JIRA)" <ji...@apache.org> on 2016/06/16 21:07:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3858) Add functions to print stream topologies - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/16 21:21:05 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3858) Add functions to print stream topologies - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/16 21:21:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1369 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/16 21:33:02 UTC, 0 replies.
- [VOTE] KIP-4 Create Topics Schema - posted by Grant Henke <gh...@cloudera.com> on 2016/06/16 21:50:57 UTC, 13 replies.
- [GitHub] kafka pull request #1516: KAFKA-3837: Report the thread name of the blocking... - posted by bharatviswa504 <gi...@git.apache.org> on 2016/06/16 21:54:58 UTC, 0 replies.
- Reg: Build Validation Jenkins - posted by BigData dev <bi...@gmail.com> on 2016/06/16 21:59:06 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3740) Add configs for RocksDBStores - posted by "Roger Hoover (JIRA)" <ji...@apache.org> on 2016/06/16 22:16:05 UTC, 4 replies.
- [jira] [Commented] (KAFKA-3185) Allow users to cleanup internal data - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/06/16 22:44:05 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-3755) tightening the offset check in ReplicaFetcherThread - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/16 22:50:05 UTC, 0 replies.
- [GitHub] kafka pull request #1485: KAFKA-3805: Check if DB is null. - posted by asfgit <gi...@git.apache.org> on 2016/06/16 23:18:32 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3805) Running multiple instances of a Streams app on the same machine results in Java_org_rocksdb_RocksDB_write error - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/16 23:19:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3859) Consumer group is stuck in rebalancing status - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/16 23:29:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3859) Consumer group is stuck in rebalancing status - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/16 23:30:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1370 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/16 23:30:34 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3859) Consumer group is stuck in rebalancing status - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/16 23:34:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3854) Consecutive regex subscription calls fail - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/16 23:38:05 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder - posted by "Bharat Viswanadham (JIRA)" <ji...@apache.org> on 2016/06/16 23:45:05 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3854) Consecutive regex subscription calls fail - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/16 23:53:05 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3853) Report offsets for empty groups in ConsumerGroupCommand - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/16 23:53:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #703 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/17 00:12:16 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1371 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/17 00:31:12 UTC, 0 replies.
- Jenkins build is back to normal : kafka-0.10.0-jdk7 #127 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/17 01:04:31 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #704 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/17 01:16:02 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3842) Add Helper Functions Into TestUtils - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/06/17 02:04:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3860) No broker partitions consumed by consumer thread - posted by "Kundan (JIRA)" <ji...@apache.org> on 2016/06/17 06:43:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3860) No broker partitions consumed by consumer thread - posted by "Kundan (JIRA)" <ji...@apache.org> on 2016/06/17 06:58:05 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3576) Unify KStream and KTable API - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/17 07:00:13 UTC, 0 replies.
- [GitHub] kafka pull request #1517: [Kafka Streams] Clean-up script [WIP] - posted by mjsax <gi...@git.apache.org> on 2016/06/17 09:37:18 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #705 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/17 09:50:35 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3185) Allow users to cleanup internal data - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/06/17 11:15:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3487) Support per-connector/per-task classloaders in Connect - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2016/06/17 14:59:05 UTC, 3 replies.
- [jira] [Created] (KAFKA-3861) Shrunk ISR before leader crash makes the partition unavailable - posted by "Maysam Yabandeh (JIRA)" <ji...@apache.org> on 2016/06/17 15:41:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2359) New consumer - partitions auto assigned only on poll - posted by "Mirza Gaush Beg (JIRA)" <ji...@apache.org> on 2016/06/17 15:45:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3861) Shrunk ISR before leader crash makes the partition unavailable - posted by "Maysam Yabandeh (JIRA)" <ji...@apache.org> on 2016/06/17 15:50:05 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-2359) New consumer - partitions auto assigned only on poll - posted by "Mirza Gaush Beg (JIRA)" <ji...@apache.org> on 2016/06/17 16:42:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3862) Kafka streams documentation: partition<->thread<->task assignment unclear - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/06/17 16:45:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3862) Kafka streams documentation: partition<->thread<->task assignment unclear - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/06/17 16:47:05 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3838) Bump zkclient and Zookeeper versions - posted by "FIlipe Azevedo (JIRA)" <ji...@apache.org> on 2016/06/17 18:25:05 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3836) KStreamReduce and KTableReduce should not pass nulls to Deserializers - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/06/17 19:20:05 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3862) Kafka streams documentation: partition<->thread<->task assignment unclear - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/06/17 19:53:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3862) Kafka streams documentation: partition<->thread<->task assignment unclear - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/06/17 19:53:05 UTC, 1 replies.
- [GitHub] kafka pull request #1518: KAFKA-3632; remove fetcher metrics on shutdown and... - posted by hachikuji <gi...@git.apache.org> on 2016/06/17 20:18:59 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3632) ConsumerLag metrics persist after partition migration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 20:19:05 UTC, 1 replies.
- [jira] [Created] (KAFKA-3863) Add system test for connector failure/restart - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/17 21:38:06 UTC, 0 replies.
- [GitHub] kafka pull request #1519: KAFKA-3863: System tests covering connector/task f... - posted by hachikuji <gi...@git.apache.org> on 2016/06/17 21:43:55 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3863) Add system test for connector failure/restart - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 21:44:05 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3861) Shrunk ISR before leader crash makes the partition unavailable - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/17 22:07:05 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3839) Handling null keys in KTable.groupBy - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/17 23:00:07 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3839) Handling null keys in KTable.groupBy - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/17 23:01:05 UTC, 0 replies.
- [GitHub] kafka pull request #1520: HOTFIX: Check hasNext in KStreamWindowReduce - posted by guozhangwang <gi...@git.apache.org> on 2016/06/17 23:32:12 UTC, 1 replies.
- [GitHub] kafka pull request #1521: MINOR: Check null keys in KTableSource - posted by guozhangwang <gi...@git.apache.org> on 2016/06/17 23:34:59 UTC, 1 replies.
- [jira] [Updated] (KAFKA-1429) Yet another deadlock in controller shutdown - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2016/06/18 01:23:05 UTC, 0 replies.
- test of producer's delay and consumer's delay - posted by Kafka <ka...@126.com> on 2016/06/18 03:28:30 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-1789) Issue with Async producer - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2016/06/18 11:32:27 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1789) Issue with Async producer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/18 13:32:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3864) Kafka Connect Struct.get returning defaultValue from Struct not the field schema - posted by "Andrew Stevenson (JIRA)" <ji...@apache.org> on 2016/06/18 13:51:05 UTC, 0 replies.
- Operator order - posted by Jeyhun Karimov <je...@gmail.com> on 2016/06/18 15:33:26 UTC, 6 replies.
- Initiating a new KIP - posted by Arvind Kandhare <sw...@gmail.com> on 2016/06/18 17:53:54 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3246) Transient Failure in kafka.producer.SyncProducerTest.testProduceCorrectlyReceivesResponse - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/18 18:20:05 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-3103) Transient Failure in kafka.integration.PlaintextTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/18 18:22:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3865) Transient failures in org.apache.kafka.connect.runtime.WorkerSourceTaskTest.testSlowTaskStart - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/18 18:25:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #706 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/18 19:50:23 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1373 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/18 20:38:22 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1374 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/18 22:27:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/18 22:42:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3867) KIP-64 -Allow underlying distributed filesystem to take over replication depending on configuration - posted by "Arvind Kandhare (JIRA)" <ji...@apache.org> on 2016/06/18 23:37:05 UTC, 0 replies.
- [GitHub] kafka pull request #1522: KAFKA-3866; KerberosLogin refresh time bug and oth... - posted by ijuma <gi...@git.apache.org> on 2016/06/18 23:43:47 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/18 23:44:05 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/18 23:45:05 UTC, 0 replies.
- [DISCUSS] KIP-64 -Allow underlying distributed filesystem to take over replication depending on configuration - posted by Arvind Kandhare <sw...@gmail.com> on 2016/06/18 23:46:26 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3632) ConsumerLag metrics persist after partition migration - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/19 00:24:05 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #707 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/19 11:06:06 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1375 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/19 11:28:52 UTC, 0 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #129 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/19 12:19:27 UTC, 0 replies.
- Reduce function Null checks - posted by Jeyhun Karimov <je...@gmail.com> on 2016/06/19 12:46:54 UTC, 1 replies.
- Consumer autocommit interference via unintentional/internal poll() calls - posted by Dana Powers <da...@gmail.com> on 2016/06/19 16:20:38 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3864) Kafka Connect Struct.get returning defaultValue from Struct not the field schema - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/19 17:28:05 UTC, 1 replies.
- [GitHub] kafka pull request #1523: Support exponential backoff policy via reconnect.b... - posted by dpkp <gi...@git.apache.org> on 2016/06/19 18:16:20 UTC, 0 replies.
- Re: [DISCUSS] KIP-53 Add custom policies for reconnect attempts to NetworkdClient - posted by Dana Powers <da...@gmail.com> on 2016/06/19 18:42:33 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3810) replication of internal topics should not be limited by replica.fetch.max.bytes - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/19 18:43:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #708 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/19 21:12:32 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1376 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/19 21:33:29 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3825) Allow users to specify different types of state stores in Streams DSL - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/06/19 23:42:05 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1377 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/20 00:25:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-3868) New producer metric record-size-avg does not provide average record size as advertised - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/20 00:37:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #709 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/20 01:12:22 UTC, 0 replies.
- Jenkins build is back to normal : kafka-0.10.0-jdk7 #130 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/20 01:17:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3663) Proposal for a kafka broker command - kafka-brokers.sh - posted by "Jayesh Thakrar (JIRA)" <ji...@apache.org> on 2016/06/20 02:51:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3868) New producer metric record-size-avg does not provide average record size as advertised - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/20 03:38:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3824) Docs indicate auto.commit breaks at least once delivery but that is incorrect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/20 05:40:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3827) log.message.format.version should default to inter.broker.protocol.version - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/20 05:43:05 UTC, 4 replies.
- Kafka Connect Transformers - posted by Nisarg Shah <sn...@gmail.com> on 2016/06/20 05:43:31 UTC, 2 replies.
- [jira] [Updated] (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/06/20 05:49:05 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3827) log.message.format.version should default to inter.broker.protocol.version - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 05:55:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3834) Consumer should not block in poll on coordinator discovery - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/20 06:07:05 UTC, 2 replies.
- [jira] [Created] (KAFKA-3869) Fix streams example - posted by "Masahiko Sakamoto (JIRA)" <ji...@apache.org> on 2016/06/20 07:53:05 UTC, 0 replies.
- [GitHub] kafka pull request #1524: KAFKA-3869 Fix streams example - posted by sakamotomsh <gi...@git.apache.org> on 2016/06/20 07:58:43 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3869) Fix streams example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/20 07:59:05 UTC, 1 replies.
- Kafka HDFS Connector - posted by Pariksheet Barapatre <pa...@gmail.com> on 2016/06/20 09:06:44 UTC, 9 replies.
- [GitHub] kafka pull request #1525: MINOR: speed up streams integration tests - posted by dguy <gi...@git.apache.org> on 2016/06/20 09:33:49 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3420) Transient failure in OffsetCommitTest.testNonExistingTopicOffsetCommit - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 10:06:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3420) Transient failure in OffsetCommitTest.testNonExistingTopicOffsetCommit - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 10:09:05 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3420) Transient failure in OffsetCommitTest.testNonExistingTopicOffsetCommit - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 10:09:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3155) Transient Failure in kafka.api.PlaintextProducerSendTest.testFlush - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 10:13:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1313) Support adding replicas to existing topic partitions - posted by "Adebiy Abdurrahman (JIRA)" <ji...@apache.org> on 2016/06/20 10:14:06 UTC, 0 replies.
- [jira] [Created] (KAFKA-3870) Remove the window name from Windows class - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/20 10:16:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3155) Transient Failure in kafka.api.PlaintextProducerSendTest.testFlush - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 10:16:05 UTC, 1 replies.
- [jira] [Created] (KAFKA-3871) Transient test failure: testSimpleConsumption - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 10:35:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3871) Transient test failure: testSimpleConsumption - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 10:36:05 UTC, 0 replies.
- [GitHub] kafka pull request #1526: KAFKA-3870: Removed name from Windows class - posted by enothereska <gi...@git.apache.org> on 2016/06/20 11:00:23 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3870) Remove the window name from Windows class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/20 11:01:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2363) ProducerSendTest.testCloseWithZeroTimeoutFromCallerThread Transient Failure - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 11:08:05 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2059) ZookeeperConsumerConnectorTest.testBasic transient failure - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 11:19:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3871) Transient test failure: testSimpleConsumption - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2016/06/20 11:23:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3871) Transient test failure: SslConsumerTest.testSimpleConsumption - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 11:26:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3872) OOM while running Kafka Streams integration tests - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 12:17:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3872) OOM while running Kafka Streams integration tests - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 12:19:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3873) Gradle Test Executor non-zero exit code when running streams tests - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 12:24:05 UTC, 0 replies.
- Connection reset by peer Error - posted by Avi Asulin <av...@plarium.com> on 2016/06/20 12:28:46 UTC, 1 replies.
- [jira] [Created] (KAFKA-3874) Transient test failure: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 12:51:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 13:01:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3876) Transient test failure: kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 13:03:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-3877) Gradle compiler daemon exits with non-zero exit code while running LogOffsetTest - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 13:07:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3873) Gradle Test Executor non-zero exit code when running streams tests - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/20 13:12:05 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3873) Gradle Test Executor non-zero exit code when running streams tests - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/20 13:19:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 13:42:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3876) Transient test failure: kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 13:45:05 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3870) Remove the window name from Windows class - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/20 14:26:05 UTC, 0 replies.
- [GitHub] kafka pull request #1505: KAFKA-3837: Report the thread name of the blocking... - posted by bharatviswa504 <gi...@git.apache.org> on 2016/06/20 16:48:47 UTC, 0 replies.
- [GitHub] kafka pull request #1527: KAFKA-3809: Auto-generate documentation for topic-... - posted by wushujames <gi...@git.apache.org> on 2016/06/20 17:03:15 UTC, 0 replies.
- [jira] [Created] (KAFKA-3878) Support exponential backoff for broker reconnect attempts - posted by "Dana Powers (JIRA)" <ji...@apache.org> on 2016/06/20 17:13:05 UTC, 0 replies.
- [GitHub] kafka pull request #1528: KAFKA-3864: make field.get return field's default ... - posted by rollulus <gi...@git.apache.org> on 2016/06/20 17:13:25 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3864) Kafka Connect Struct.get returning defaultValue from Struct not the field schema - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/20 17:14:05 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3878) Support exponential backoff for broker reconnect attempts - posted by "Dana Powers (JIRA)" <ji...@apache.org> on 2016/06/20 17:18:05 UTC, 0 replies.
- [DISCUSS] KIP-4 Delete Topic Schema - posted by Grant Henke <gh...@cloudera.com> on 2016/06/20 19:09:02 UTC, 6 replies.
- [jira] [Created] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/20 19:12:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/20 19:12:58 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3864) Kafka Connect Struct.get returning defaultValue from Struct not the field schema - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/20 19:33:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3880) Disallow Join Windows with size zero - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/06/20 19:36:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/20 19:48:58 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-3865) Transient failures in org.apache.kafka.connect.runtime.WorkerSourceTaskTest.testSlowTaskStart - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/20 20:45:58 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #710 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/20 20:54:55 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1379 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/20 21:01:26 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3829) Warn that kafka-connect group.id must not conflict with connector names - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2016/06/20 21:15:58 UTC, 0 replies.
- [GitHub] kafka pull request #1529: Kafka-3880: Disallow Join Window with size zero - posted by mjsax <gi...@git.apache.org> on 2016/06/20 21:20:50 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3880) Disallow Join Windows with size zero - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/06/20 21:24:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-3881) Remove the replacing logic from "." to "_" in Fetcher - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/20 21:31:58 UTC, 0 replies.
- [GitHub] kafka pull request #922: KAFKA-3176: Add partition/offset options to the new... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/20 21:42:29 UTC, 8 replies.
- [jira] [Commented] (KAFKA-3176) Allow console consumer to consume from particular partitions when new consumer is used. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/20 21:42:57 UTC, 12 replies.
- [jira] [Assigned] (KAFKA-3868) New producer metric record-size-avg does not provide average record size as advertised - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2016/06/20 21:49:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3849) Avoid polling every second in MirrorMaker if no data is available. - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/20 21:55:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3868) New producer metric record-size-avg does not provide average record size as advertised - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/20 22:34:57 UTC, 1 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1380 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/20 22:40:43 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #711 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/20 22:55:53 UTC, 0 replies.
- Error while sending message to Kafka broker on SSL with Kafka 0.10.0.0 - posted by Subhash Agrawal <ag...@opentext.com> on 2016/06/20 23:20:12 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3874) Transient test failure: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/20 23:22:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3874) Transient test failure: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/20 23:22:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3872) OOM while running Kafka Streams integration tests - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/20 23:27:58 UTC, 2 replies.
- [jira] [Created] (KAFKA-3882) Integration failures on low-end machines - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/20 23:29:57 UTC, 0 replies.
- [GitHub] kafka pull request #1530: KAFKA-3769: Create new sensors per-thread in Kafka... - posted by guozhangwang <gi...@git.apache.org> on 2016/06/20 23:30:37 UTC, 0 replies.
- [GitHub] kafka pull request #1531: KAFKA-3865: Fix transient failure in WorkerSourceT... - posted by hachikuji <gi...@git.apache.org> on 2016/06/21 00:20:40 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3865) Transient failures in org.apache.kafka.connect.runtime.WorkerSourceTaskTest.testSlowTaskStart - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/21 00:20:58 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-3705) Support non-key joining in KTable - posted by "Jan Filipiak (JIRA)" <ji...@apache.org> on 2016/06/21 00:36:57 UTC, 3 replies.
- [GitHub] kafka pull request #1532: KAFKA-3482: consolidate utility methods to TestUti... - posted by bbejeck <gi...@git.apache.org> on 2016/06/21 02:53:17 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3482) [DOC] - Remove the part about LinkedIn running ZK 3.3.X - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/21 02:53:57 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3869) Fix streams example - posted by "Masahiko Sakamoto (JIRA)" <ji...@apache.org> on 2016/06/21 02:55:57 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3865) Transient failures in org.apache.kafka.connect.runtime.WorkerSourceTaskTest.testSlowTaskStart - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/21 03:44:58 UTC, 0 replies.
- [GitHub] kafka pull request #1336: KAFKA-3144: Report members with no assigned partit... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/21 04:12:58 UTC, 3 replies.
- [jira] [Created] (KAFKA-3883) Remove ThreadedTest from Connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/21 04:45:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3176) Allow console consumer to consume from particular partitions when new consumer is used. - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/21 05:28:57 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3872) OOM while running Kafka Streams integration tests - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/21 06:01:06 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3872) OOM while running Kafka Streams integration tests - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/21 06:05:57 UTC, 0 replies.
- [GitHub] kafka pull request #1533: KAFKA-3872: Reduce log cleaner buffer size to 2 MB - posted by enothereska <gi...@git.apache.org> on 2016/06/21 06:09:13 UTC, 1 replies.
- Build failed in Jenkins: kafka-0.10.0-jdk7 #132 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/21 06:18:08 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #712 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/21 07:12:53 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1382 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/21 07:30:38 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3482) [DOC] - Remove the part about LinkedIn running ZK 3.3.X - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 08:41:58 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #713 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/21 09:07:30 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 09:29:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3884) KGroupedStreamIntegrationTest.shouldAggregate seems to be hanging - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 09:34:57 UTC, 0 replies.
- [GitHub] kafka pull request #1534: MINOR: update streams.html with KStream API change... - posted by dguy <gi...@git.apache.org> on 2016/06/21 11:47:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3874) Transient test failure: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/21 11:55:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3885) Kafka new producer cannot failover - posted by "wateray (JIRA)" <ji...@apache.org> on 2016/06/21 12:22:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3885) Kafka new producer cannot failover - posted by "wateray (JIRA)" <ji...@apache.org> on 2016/06/21 12:22:58 UTC, 0 replies.
- KafkaConsumer - Poll consumes more records than needed - posted by Asier Aranbarri Beldarrain <ar...@gmail.com> on 2016/06/21 12:31:11 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3828) Consumer thread stalls after consumer re balance for some partition - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 15:55:58 UTC, 0 replies.
- [GitHub] kafka pull request #1535: KAFKA-3727 - ConsumerListener for UnknownTopicOrPa... - posted by edoardocomar <gi...@git.apache.org> on 2016/06/21 17:45:27 UTC, 0 replies.
- [GitHub] kafka pull request #1536: MINOR: KAFKA-3176 Follow-up to fix minor issues - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/21 17:53:42 UTC, 2 replies.
- [jira] [Created] (KAFKA-3886) Consumer should handle wakeups while rebalancing more gracefully - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/21 19:55:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3886) Consumer should handle wakeups while rebalancing more gracefully - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/21 19:58:57 UTC, 0 replies.
- [GitHub] kafka pull request #952: KAFKA-3263 - Support for markdown generation. - posted by jcustenborder <gi...@git.apache.org> on 2016/06/21 20:25:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3263) Add Markdown support for ConfigDef - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/21 20:25:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 20:29:57 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3872) OOM while running Kafka Streams integration tests - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 20:52:58 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1383 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/21 21:24:24 UTC, 0 replies.
- [jira] [Created] (KAFKA-3888) Allow consumer to send heartbeats in background thread (KIP-62) - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/21 21:58:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 22:01:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3846) Connect record types should include timestamps - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/06/21 22:13:58 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 22:17:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3889) Change default Scala version to 2.11 - posted by "Kevin Lafferty (JIRA)" <ji...@apache.org> on 2016/06/21 22:36:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3889) Change default Scala version to 2.11 - posted by "Kevin Lafferty (JIRA)" <ji...@apache.org> on 2016/06/21 22:39:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3889) Change default Scala version to 2.11 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/21 22:40:58 UTC, 2 replies.
- [GitHub] kafka pull request #1537: KAFKA-3846: include timestamp in Connect record ty... - posted by shikhar <gi...@git.apache.org> on 2016/06/22 00:44:47 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3846) Connect record types should include timestamps - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/22 00:44:58 UTC, 2 replies.
- [jira] [Created] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/22 02:15:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/22 02:19:57 UTC, 0 replies.
- [GitHub] kafka pull request #1538: AFKA-3890 Kafka Streams: task assignment is not ma... - posted by HenryCaiHaiying <gi...@git.apache.org> on 2016/06/22 02:24:17 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/22 02:24:57 UTC, 5 replies.
- [jira] [Work started] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/22 02:25:57 UTC, 0 replies.
- [GitHub] kafka pull request #1536: MINOR: KAFKA-3176 follow-up to fix minor issues - posted by asfgit <gi...@git.apache.org> on 2016/06/22 08:22:48 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #716 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/22 09:32:06 UTC, 0 replies.
- [jira] [Created] (KAFKA-3891) A KTable with Long values with a numeric filter apparently may retain null values - posted by "Phil Derome (JIRA)" <ji...@apache.org> on 2016/06/22 11:01:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3891) A KTable with Long values with a numeric filter apparently may retain null values - posted by "Phil Derome (JIRA)" <ji...@apache.org> on 2016/06/22 11:01:57 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3891) A KTable with Long values with a numeric filter apparently may retain null values - posted by "Phil Derome (JIRA)" <ji...@apache.org> on 2016/06/22 11:02:57 UTC, 0 replies.
- [GitHub] kafka pull request #1539: KAFKA-3663 - posted by JThakrar <gi...@git.apache.org> on 2016/06/22 15:15:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3663) Proposal for a kafka broker command - kafka-brokers.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/22 15:15:58 UTC, 1 replies.
- Possibly very minor typo in documentation.html - posted by Tyler <di...@gmail.com> on 2016/06/22 17:56:35 UTC, 1 replies.
- [jira] [Created] (KAFKA-3892) Clients retain metadata for non-subscribed topics - posted by "Noah Sloan (JIRA)" <ji...@apache.org> on 2016/06/22 20:09:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3892) Clients retain metadata for non-subscribed topics - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/22 20:14:16 UTC, 10 replies.
- [GitHub] kafka pull request #1540: MINOR: Verify acls for group resource on all serve... - posted by SinghAsDev <gi...@git.apache.org> on 2016/06/22 20:19:51 UTC, 1 replies.
- [GitHub] kafka pull request #1541: KAFKA-3892 prune metadata response to subscribed t... - posted by iamnoah <gi...@git.apache.org> on 2016/06/22 20:24:54 UTC, 1 replies.
- [GitHub] kafka pull request #1542: KAFKA-3892 prune metadata response to subscribed t... - posted by iamnoah <gi...@git.apache.org> on 2016/06/22 21:05:04 UTC, 0 replies.
- [jira] [Created] (KAFKA-3893) Kafka not disconnecting zookeeper connection even after time configured for timeout has crossed - posted by "chaitra (JIRA)" <ji...@apache.org> on 2016/06/22 21:18:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3893) Kafka not disconnecting zookeeper connection even after time configured for timeout has crossed - posted by "chaitra (JIRA)" <ji...@apache.org> on 2016/06/22 21:19:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3893) Kafka not trying re-register back in Zookeeper - posted by "chaitra (JIRA)" <ji...@apache.org> on 2016/06/22 21:20:16 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3893) Kafka not trying re-register back in Zookeeper - posted by "chaitra (JIRA)" <ji...@apache.org> on 2016/06/22 21:27:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3893) Kafka Borker ID disappears from /borkers/ids - posted by "chaitra (JIRA)" <ji...@apache.org> on 2016/06/22 22:11:16 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-3893) Kafka Borker ID disappears from /borkers/ids - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2016/06/22 22:31:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3893) Kafka Borker ID disappears from /borkers/ids - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2016/06/22 22:31:16 UTC, 0 replies.
- [jira] [Created] (KAFKA-3894) Log Cleaner thread crashes and never restarts - posted by "Tim Carey-Smith (JIRA)" <ji...@apache.org> on 2016/06/22 22:32:16 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1386 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/22 22:38:24 UTC, 0 replies.
- [GitHub] kafka pull request #1538: KAFKA-3890 Kafka Streams: task assignment is not m... - posted by HenryCaiHaiying <gi...@git.apache.org> on 2016/06/22 23:12:10 UTC, 2 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #717 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/22 23:12:26 UTC, 0 replies.
- [GitHub] kafka pull request #1543: KAFKA-3890 Kafka Streams: task assignment is not m... - posted by HenryCaiHaiying <gi...@git.apache.org> on 2016/06/22 23:14:28 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3863) Add system test for connector failure/restart - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/23 00:08:16 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #718 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/23 00:12:17 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1387 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/23 01:59:34 UTC, 0 replies.
- Jenkins build is back to normal : kafka-0.10.0-jdk7 #133 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/23 02:31:52 UTC, 0 replies.
- [GitHub] kafka pull request #1544: MINOR: Clean `Metrics.defaultRegistry` to avoid tr... - posted by ijuma <gi...@git.apache.org> on 2016/06/23 08:15:16 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-3892) Clients retain metadata for non-subscribed topics - posted by "Noah Sloan (JIRA)" <ji...@apache.org> on 2016/06/23 12:04:16 UTC, 0 replies.
- KTable.filter usage, memory consumption and materialized view semantics - posted by Philippe Derome <ph...@gmail.com> on 2016/06/23 12:50:35 UTC, 16 replies.
- [jira] [Commented] (KAFKA-3894) Log Cleaner thread crashes and never restarts - posted by "Tom Crayford (JIRA)" <ji...@apache.org> on 2016/06/23 13:57:16 UTC, 4 replies.
- [GitHub] kafka pull request #1545: KAFKA-3727 - ClientListener for UnknownTopicOrPart... - posted by edoardocomar <gi...@git.apache.org> on 2016/06/23 15:58:37 UTC, 0 replies.
- [jira] [Created] (KAFKA-3895) Implement a default queue for expired messages - posted by "Krish Iyer (JIRA)" <ji...@apache.org> on 2016/06/23 17:33:16 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3888) Allow consumer to send heartbeats in background thread (KIP-62) - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2016/06/23 17:39:16 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3846) Connect record types should include timestamps - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/06/23 17:41:16 UTC, 0 replies.
- [DISCUSS] KIP-65 Expose timestamps to Connect - posted by Shikhar Bhushan <sh...@confluent.io> on 2016/06/23 18:06:09 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-3879) KafkaConsumer with auto commit enabled gets stuck when killed after broker is dead - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/23 20:04:16 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/23 20:16:16 UTC, 0 replies.
- [jira] [Created] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations - posted by "Ashish K Singh (JIRA)" <ji...@apache.org> on 2016/06/23 20:36:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/23 20:50:17 UTC, 4 replies.
- [GitHub] kafka pull request #1546: HOTFIX: Remove Java verion 1.6 in quick-start docs - posted by guozhangwang <gi...@git.apache.org> on 2016/06/23 21:41:54 UTC, 1 replies.
- [jira] [Created] (KAFKA-3897) Improve Unit Tests for New Consumer's Regex Subscription - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/23 21:47:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3897) Improve Unit Tests for New Consumer's Regex Subscription - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/23 21:48:16 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3897) Improve Unit Tests for New Consumer's Regex Subscription - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/06/23 21:49:16 UTC, 0 replies.
- [DISCUSS] KAFKA-3761: Controller has RunningAsBroker instead of RunningAsController state - posted by Roger Hoover <ro...@gmail.com> on 2016/06/23 21:57:30 UTC, 3 replies.
- [GitHub] kafka pull request #1547: KAFKA-3594; After calling MemoryRecords.close() me... - posted by ijuma <gi...@git.apache.org> on 2016/06/23 23:02:06 UTC, 1 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1388 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/23 23:21:47 UTC, 0 replies.
- [GitHub] kafka pull request #1548: KAFKA-2857 ConsumerGroupCommand throws GroupCoordi... - posted by imandhan <gi...@git.apache.org> on 2016/06/23 23:47:45 UTC, 2 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #719 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/23 23:53:44 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3809) Auto-generate documentation for topic-level configuration - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/24 00:22:16 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3480) Autogenerate metrics documentation - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/24 00:23:16 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3480) Autogenerate metrics documentation - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2016/06/24 00:23:16 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-3522) Consider adding version information into rocksDB storage format - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/06/24 00:53:16 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3794) Add Stream / Table prefix in print functions - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/06/24 03:25:16 UTC, 0 replies.
- [VOTE] KIP-4 Delete Topics Schema - posted by Grant Henke <gh...@cloudera.com> on 2016/06/24 03:32:04 UTC, 7 replies.
- [jira] [Updated] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/24 06:53:16 UTC, 0 replies.
- [GitHub] kafka pull request #1549: KAFKA-3896: Unstable test KStreamRepartitionJoinTe... - posted by dguy <gi...@git.apache.org> on 2016/06/24 07:16:38 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3898) KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures after mapValues etc - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/24 07:26:16 UTC, 1 replies.
- [jira] [Created] (KAFKA-3898) KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures after mapValues etc - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/24 07:26:16 UTC, 0 replies.
- Re: [DISCUSS] KIP-50 - Enhance Authorizer interface to be aware of supported Principal Types - posted by Ismael Juma <is...@juma.me.uk> on 2016/06/24 07:34:07 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3898) KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures after mapValues etc - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/24 07:53:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/24 08:59:16 UTC, 0 replies.
- Build failed in Jenkins: kafka_0.9.0_jdk7 #135 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/24 10:14:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2016/06/24 11:33:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2016/06/24 11:39:16 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2016/06/24 11:56:16 UTC, 0 replies.
- [jira] [Created] (KAFKA-3900) High CPU util on broker - posted by "Andrey Konyaev (JIRA)" <ji...@apache.org> on 2016/06/24 15:16:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3296) All consumer reads hang indefinately - posted by "Piotr Trzpil (JIRA)" <ji...@apache.org> on 2016/06/24 16:09:16 UTC, 0 replies.
- [VOTE] KIP-65 Expose timestamps to Connect - posted by Shikhar Bhushan <sh...@confluent.io> on 2016/06/24 17:59:23 UTC, 7 replies.
- [GitHub] kafka pull request #1550: MINOR: Improve doc string in PartitionGrouper - posted by guozhangwang <gi...@git.apache.org> on 2016/06/24 18:47:09 UTC, 1 replies.
- [GitHub] kafka pull request #1551: MINOR: fix grammatical errors in DataException mes... - posted by LaurierMantel <gi...@git.apache.org> on 2016/06/24 19:11:22 UTC, 1 replies.
- [GitHub] kafka pull request #1552: MINOR: Typo fix in docs ops - posted by thanasis00 <gi...@git.apache.org> on 2016/06/24 20:42:35 UTC, 0 replies.
- [GitHub] kafka pull request #1532: KAFKA-3842: consolidate utility methods to TestUti... - posted by asfgit <gi...@git.apache.org> on 2016/06/24 20:45:28 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3842) Add Helper Functions Into TestUtils - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/24 20:54:16 UTC, 4 replies.
- [jira] [Created] (KAFKA-3901) KStreamTransformValues$KStreamTransformValuesProcessor#process() forwards null values - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/06/24 20:59:16 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3901) KStreamTransformValues$KStreamTransformValuesProcessor#process() forwards null values - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2016/06/24 21:02:16 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1390 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/24 23:37:29 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #720 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/25 00:12:26 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1391 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/25 00:56:14 UTC, 0 replies.
- [jira] [Created] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/25 05:05:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/25 05:06:16 UTC, 1 replies.
- delay of producer and consumer in kafka 0.9 is too big to be accepted - posted by Kafka <ka...@126.com> on 2016/06/25 07:14:48 UTC, 2 replies.
- [jira] [Created] (KAFKA-3903) Convert tests to use static helper methods for Consumer/Producer/StreamsConfigs setup - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2016/06/25 19:24:37 UTC, 0 replies.
- [GitHub] kafka pull request #1553: KAFKA-3740: Add configs for RocksDBStore - posted by HenryCaiHaiying <gi...@git.apache.org> on 2016/06/25 20:24:47 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic - posted by "Phil Derome (JIRA)" <ji...@apache.org> on 2016/06/25 23:52:37 UTC, 4 replies.
- [GitHub] kafka pull request #1554: MINOR: Follow-up from KAFKA-3842 with suggested fi... - posted by bbejeck <gi...@git.apache.org> on 2016/06/26 01:25:27 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic - posted by "Phil Derome (JIRA)" <ji...@apache.org> on 2016/06/26 03:22:11 UTC, 1 replies.
- [jira] [Created] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/26 06:01:33 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/26 06:03:33 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/26 07:08:33 UTC, 8 replies.
- [GitHub] kafka pull request #1555: MINOR: Fix ambiguous log message in RecordCollecto... - posted by kawamuray <gi...@git.apache.org> on 2016/06/26 08:00:29 UTC, 3 replies.
- [GitHub] kafka pull request #1556: KAFKA-3902 - posted by phderome <gi...@git.apache.org> on 2016/06/26 12:33:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3825) Allow users to specify different types of state stores in Streams DSL - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/06/26 13:16:33 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic - posted by "Phil Derome (JIRA)" <ji...@apache.org> on 2016/06/26 15:56:33 UTC, 1 replies.
- [GitHub] kafka pull request #1557: Improved warning to be clear on first read. - posted by LuboVarga <gi...@git.apache.org> on 2016/06/27 06:24:20 UTC, 0 replies.
- [jira] [Created] (KAFKA-3905) remove null from subscribed topics in KafkaConsumer#subscribe - posted by "Xing Huang (JIRA)" <ji...@apache.org> on 2016/06/27 08:22:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1889) Refactor shell wrapper scripts - posted by "Carlo Alberto Ferraris (JIRA)" <ji...@apache.org> on 2016/06/27 09:42:52 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3900) High CPU util on broker - posted by "Andrey Konyaev (JIRA)" <ji...@apache.org> on 2016/06/27 12:28:52 UTC, 0 replies.
- [GitHub] kafka pull request #1558: org.apache.kafka.streams.errors.StreamsException: ... - posted by stathmarxis <gi...@git.apache.org> on 2016/06/27 13:43:25 UTC, 0 replies.
- [GitHub] kafka pull request #1559: KAFKA-3844; Sort configuration items in log - posted by rekhajoshm <gi...@git.apache.org> on 2016/06/27 18:00:42 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3844) Sort configuration items in log - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/27 18:00:54 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3844) Sort configuration items in log - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/06/27 18:01:52 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3905) remove null from subscribed topics in KafkaConsumer#subscribe - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/06/27 18:09:52 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/27 18:51:52 UTC, 0 replies.
- [jira] [Created] (KAFKA-3906) Connect logical types do not support nulls. - posted by "Jeremy Custenborder (JIRA)" <ji...@apache.org> on 2016/06/27 18:59:52 UTC, 0 replies.
- [GitHub] kafka pull request #1560: KAFKA-3906 - Connect logical types do not support ... - posted by jcustenborder <gi...@git.apache.org> on 2016/06/27 19:05:08 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3906) Connect logical types do not support nulls. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/27 19:05:52 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #722 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/27 20:34:54 UTC, 0 replies.
- [GitHub] kafka pull request #1561: KAFKA-3905:remove null from subscribed topics in K... - posted by rekhajoshm <gi...@git.apache.org> on 2016/06/27 20:47:43 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3905) remove null from subscribed topics in KafkaConsumer#subscribe - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/27 20:48:16 UTC, 4 replies.
- [jira] [Created] (KAFKA-3907) Better support for user-specific committing in the Streams DSL - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/27 21:22:17 UTC, 0 replies.
- [jira] [Created] (KAFKA-3908) Set SendBufferSize for socket used by Processor - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2016/06/27 22:35:56 UTC, 0 replies.
- [GitHub] kafka pull request #1562: KAFKA-3908; Set SendBufferSize for socket used by ... - posted by lindong28 <gi...@git.apache.org> on 2016/06/27 22:38:31 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3908) Set SendBufferSize for socket used by Processor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/27 22:38:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3885) Kafka new producer cannot failover - posted by "wateray (JIRA)" <ji...@apache.org> on 2016/06/28 01:18:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format - posted by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/06/28 01:27:57 UTC, 1 replies.
- How to create a KIP? - posted by "Pengwei (L)" <pe...@huawei.com> on 2016/06/28 05:24:54 UTC, 1 replies.
- [GitHub] kafka pull request #1563: KAFKA-3904: File descriptor leaking (Too many open... - posted by HenryCaiHaiying <gi...@git.apache.org> on 2016/06/28 05:34:37 UTC, 1 replies.
- [GitHub] kafka pull request #1564: KAFKA-3905:check collection elements in KafkaConsu... - posted by iBuddha <gi...@git.apache.org> on 2016/06/28 08:04:25 UTC, 1 replies.
- [DISCUSS] KIP-67: Queryable state for Kafka Stream - posted by Damian Guy <da...@gmail.com> on 2016/06/28 08:34:20 UTC, 0 replies.
- [jira] [Created] (KAFKA-3909) Queryable state for Kafka Streams - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/28 08:39:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3870) Remove the window name from Windows class - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/28 08:41:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3870) Expose state store names to DSL - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/28 08:42:57 UTC, 1 replies.
- [jira] [Created] (KAFKA-3910) Cyclic schema support in ConnectSchema and SchemaBuilder - posted by "John Hofman (JIRA)" <ji...@apache.org> on 2016/06/28 08:44:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3911) Enforce KTable materialization - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/28 08:45:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3912) Query local state stores - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/28 09:01:06 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3912) Query local state stores - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/28 09:02:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3910) Cyclic schema support in ConnectSchema and SchemaBuilder - posted by "John Hofman (JIRA)" <ji...@apache.org> on 2016/06/28 09:54:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3913) Old consumer's metrics error when using IPv6 - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2016/06/28 10:38:56 UTC, 0 replies.
- [GitHub] kafka pull request #1565: KAFKA-3912: Query local state stores - posted by dguy <gi...@git.apache.org> on 2016/06/28 10:45:28 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3913) Old consumer's metrics error when using IPv6 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/28 10:45:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3912) Query local state stores - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/28 10:45:57 UTC, 0 replies.
- [jira] [Work started] (KAFKA-3912) Query local state stores - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/28 10:54:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3914) Global discovery of state stores - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/28 11:08:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-3915) LogCleaner IO buffers do not account for potential size difference due to message format change - posted by "Tommy Becker (JIRA)" <ji...@apache.org> on 2016/06/28 14:59:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3915) LogCleaner IO buffers do not account for potential size difference due to message format change - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/28 16:11:57 UTC, 2 replies.
- [DISCUSS] Client Side Auto Topic Creation - posted by Grant Henke <gh...@cloudera.com> on 2016/06/28 16:26:14 UTC, 8 replies.
- [jira] [Work started] (KAFKA-3911) Enforce KTable materialization - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2016/06/28 16:34:57 UTC, 0 replies.
- [GitHub] kafka pull request #1566: MINOR: bug fixes to ducktape services - posted by alexlod <gi...@git.apache.org> on 2016/06/28 16:35:38 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3915) LogCleaner IO buffers do not account for potential size difference due to message format change - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/28 17:14:57 UTC, 5 replies.
- [GitHub] kafka pull request #1567: Minor: fix Bash shebang on vagrant/ scripts - posted by shikhar <gi...@git.apache.org> on 2016/06/28 18:09:08 UTC, 0 replies.
- [GitHub] kafka pull request #1437: KAFKA-3761: Remove BrokerState "RunningAsControlle... - posted by theduderog <gi...@git.apache.org> on 2016/06/28 18:39:29 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3761) Controller has RunningAsBroker instead of RunningAsController state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/28 18:39:57 UTC, 1 replies.
- Issue? With java Producer (v9) - posted by "Fumo, Vincent" <Vi...@comcast.com> on 2016/06/28 19:00:32 UTC, 1 replies.
- [GitHub] kafka pull request #1568: MINOR: Fix consumer constructor doc string - posted by granthenke <gi...@git.apache.org> on 2016/06/28 20:47:23 UTC, 0 replies.
- [jira] [Created] (KAFKA-3916) Connection from controller to broker disconnects - posted by "Dave Powell (JIRA)" <ji...@apache.org> on 2016/06/28 21:17:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3916) Connection from controller to broker disconnects - posted by "Dave Powell (JIRA)" <ji...@apache.org> on 2016/06/28 21:18:57 UTC, 1 replies.
- [jira] [Created] (KAFKA-3917) Some __consumer_offsets replicas grow way too big - posted by "Maxim Vladimirskiy (JIRA)" <ji...@apache.org> on 2016/06/28 23:41:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3252) compression type for a topic should be used during log compaction - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2016/06/29 01:26:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX - posted by "Sergey Vergun (JIRA)" <ji...@apache.org> on 2016/06/29 09:41:21 UTC, 0 replies.
- [GitHub] kafka pull request #1569: Kafka 3836: KStreamReduce and KTableReduce should ... - posted by jeyhunkarimov <gi...@git.apache.org> on 2016/06/29 11:58:31 UTC, 0 replies.
- [jira] [Created] (KAFKA-3918) Broker faills to start after ungraceful shutdown due to non-monotonically incrementing offsets in logs - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2016/06/29 12:38:36 UTC, 0 replies.
- [jira] [Created] (KAFKA-3919) Broker faills to start after ungraceful shutdown due to non-monotonically incrementing offsets in logs - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2016/06/29 12:38:36 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3919) Broker faills to start after ungraceful shutdown due to non-monotonically incrementing offsets in logs - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2016/06/29 12:38:37 UTC, 0 replies.
- [jira] [Commented] (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/06/29 14:23:17 UTC, 2 replies.
- Kafka:3663 : Help with Jenkin Check Failures in Pull Request on Github - posted by Jayesh Thakrar <j_...@yahoo.com.INVALID> on 2016/06/29 15:13:07 UTC, 0 replies.
- [GitHub] kafka pull request #1570: KAFKA-3914: Global discovery of state stores - posted by dguy <gi...@git.apache.org> on 2016/06/29 15:14:53 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3914) Global discovery of state stores - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/29 15:15:17 UTC, 2 replies.
- [jira] [Work started] (KAFKA-3914) Global discovery of state stores - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2016/06/29 15:37:22 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3854) Consecutive regex subscription calls fail - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/29 15:53:00 UTC, 2 replies.
- [Kafka Streams] Source Nodes - posted by mishadoff <mi...@gmail.com> on 2016/06/29 16:02:05 UTC, 2 replies.
- [jira] [Updated] (KAFKA-3854) Subsequent regex subscription calls fail - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2016/06/29 17:11:17 UTC, 3 replies.
- [jira] [Updated] (KAFKA-3900) High CPU util on broker - posted by "Andrey Konyaev (JIRA)" <ji...@apache.org> on 2016/06/29 18:10:17 UTC, 1 replies.
- [GitHub] kafka pull request #1571: Fix few documentation errors in streams quickstart - posted by glikson <gi...@git.apache.org> on 2016/06/29 20:43:37 UTC, 0 replies.
- Use Kafka 0.9.0.1 or 0.10.0.0 with Zookeeper 3.5 - posted by Luciano Afranllie <li...@gmail.com> on 2016/06/29 21:16:49 UTC, 2 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #723 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/29 21:54:45 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3890) Kafka Streams: task assignment is not maintained on cluster restart or rolling restart - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/29 22:23:46 UTC, 0 replies.
- [GitHub] kafka pull request #1572: KAFKA-3854: Fix issues with new consumer's subsequ... - posted by vahidhashemian <gi...@git.apache.org> on 2016/06/29 23:18:29 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3854) Subsequent regex subscription calls fail - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/29 23:19:30 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1393 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/29 23:38:26 UTC, 0 replies.
- [jira] [Created] (KAFKA-3920) Add Schema source connector to Kafka Connect - posted by "Liquan Pei (JIRA)" <ji...@apache.org> on 2016/06/29 23:46:12 UTC, 0 replies.
- [GitHub] kafka pull request #1573: hotfix: check join window boundaries - posted by mjsax <gi...@git.apache.org> on 2016/06/29 23:59:53 UTC, 1 replies.
- [GitHub] kafka pull request #1574: KAFKA-3920: Add Schema source connector to Kafka C... - posted by Ishiihara <gi...@git.apache.org> on 2016/06/30 00:05:13 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3920) Add Schema source connector to Kafka Connect - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/30 00:06:12 UTC, 0 replies.
- [GitHub] kafka pull request #1575: hotfix: check join window boundaries - posted by mjsax <gi...@git.apache.org> on 2016/06/30 00:07:10 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3628) Native Schema Registry in Kafka - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2016/06/30 00:16:12 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk8 #724 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/30 00:37:05 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1394 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/30 00:43:56 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3918) Broker faills to start after ungraceful shutdown due to non-monotonically incrementing offsets in logs - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2016/06/30 06:24:10 UTC, 0 replies.
- Re: [DISCUSS] KIP-60 - Make Java client class loading more flexible - posted by Rajini Sivaram <ra...@googlemail.com> on 2016/06/30 08:52:59 UTC, 0 replies.
- [GitHub] kafka pull request #1576: KAFKA-3914: Global discovery of state stores - posted by dguy <gi...@git.apache.org> on 2016/06/30 09:15:54 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3761) Controller has RunningAsBroker instead of RunningAsController state - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/30 11:27:10 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3761) Controller has RunningAsBroker instead of RunningAsController state - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/30 11:27:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3360) Add a protocol page/section to the official Kafka documentation - posted by "Petr Novotnik (JIRA)" <ji...@apache.org> on 2016/06/30 11:48:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3877) Gradle compiler daemon exits with non-zero exit code while running LogOffsetTest - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/30 17:46:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3103) Transient Failure in kafka.integration.PlaintextTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/30 17:47:11 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3103) Transient Failure in kafka.integration.PlaintextTopicMetadataTest.testIsrAfterBrokerShutDownAndJoinsBack - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/30 17:48:10 UTC, 1 replies.
- [jira] [Created] (KAFKA-3921) Periodic refresh of metadata causes spurious log messages - posted by "Steven Schlansker (JIRA)" <ji...@apache.org> on 2016/06/30 18:03:10 UTC, 0 replies.
- [jira] [Created] (KAFKA-3922) Add a copy-constructor to AbstractStream - posted by "Florian Hussonnois (JIRA)" <ji...@apache.org> on 2016/06/30 18:31:10 UTC, 0 replies.
- Jenkins build is back to normal : kafka-trunk-jdk7 #1395 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/30 20:34:58 UTC, 0 replies.
- Can I get a code review on my PR for KAFKA-3809? "Auto-generate documentation for topic-level configuration" - posted by James Cheng <wu...@gmail.com> on 2016/06/30 20:51:32 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3360) Add a protocol page/section to the official Kafka documentation - posted by "Petr Novotnik (JIRA)" <ji...@apache.org> on 2016/06/30 20:57:10 UTC, 0 replies.
- [GitHub] kafka pull request #1537: KAFKA-3846: KIP-65: include timestamp in Connect r... - posted by asfgit <gi...@git.apache.org> on 2016/06/30 21:00:06 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3846) Connect record types should include timestamps - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2016/06/30 21:00:14 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/06/30 21:14:10 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk8 #726 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/30 21:56:15 UTC, 0 replies.
- Build failed in Jenkins: kafka-trunk-jdk7 #1396 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/06/30 23:04:03 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process - posted by "Henry Cai (JIRA)" <ji...@apache.org> on 2016/06/30 23:28:10 UTC, 0 replies.