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

---

- [jira] [Commented] (KAFKA-5671) Add StreamsBuilder and deprecate KStreamBuilder - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/01 00:36:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2526) Console Producer / Consumer's serde config is not working - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/08/01 03:30:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5683) Dedicated thread pool for Kafka Streams tasks - posted by "Abhishek Gupta (JIRA)" <ji...@apache.org> on 2017/08/01 05:18:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1944) Rename LogCleaner and related classes to LogCompactor - posted by "Pranav Maniar (JIRA)" <ji...@apache.org> on 2017/08/01 06:38:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-1944) Rename LogCleaner and related classes to LogCompactor - posted by "Pranav Maniar (JIRA)" <ji...@apache.org> on 2017/08/01 06:40:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5674) max.connections.per.ip minimum value to be zero to allow IP address blocking - posted by "Tristan Stevens (JIRA)" <ji...@apache.org> on 2017/08/01 07:01:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test - posted by "Chanchal Singh (JIRA)" <ji...@apache.org> on 2017/08/01 07:10:00 UTC, 11 replies.
- [jira] [Updated] (KAFKA-1120) Controller could miss a broker state change - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/01 07:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1120) Controller could miss a broker state change - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/01 07:59:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1120) Controller could miss a broker state change - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/01 08:00:00 UTC, 12 replies.
- [jira] [Commented] (KAFKA-5643) Using _DUCKTAPE_OPTIONS has no effect on executing tests - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/08/01 08:38:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout. - posted by "tuyang (JIRA)" <ji...@apache.org> on 2017/08/01 09:05:00 UTC, 8 replies.
- [jira] [Commented] (KAFKA-5547) Return topic authorization failed if no topic describe access - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/01 10:04:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5637) Document compatibility and release policies - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/08/01 11:12:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/08/01 12:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5674) max.connections.per.ip minimum value to be zero to allow IP address blocking - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/08/01 12:58:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/08/01 13:40:00 UTC, 14 replies.
- [jira] [Commented] (KAFKA-2111) Command Line Standardization - Add Help Arguments & List Required Fields - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/01 13:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 14:08:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5685) Interface of ReadOnlyKeyValueStore should provide a non blocking interface for stores with non blocking capabilities - posted by "Chris Wewerka (JIRA)" <ji...@apache.org> on 2017/08/01 14:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5686) Documentation inconsistency on the "Compression" - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5686) Documentation inconsistency on the "Compression" - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:25:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-4314) Kafka Streams documentation needs definitive rework and improvement - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4314) Kafka Streams documentation needs definitive rework and improvement - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:34:00 UTC, 1 replies.
- [jira] [Closed] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-) - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:36:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-4316) Kafka Streams 0.10.0.1 does not run on Windows x64 - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:37:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-4849) Bug in KafkaStreams documentation - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:37:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-4312) void KTableImpl.writeAsText(String filePath) throws NullPointerException when filePath is empty String - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:38:01 UTC, 0 replies.
- [jira] [Closed] (KAFKA-4314) Kafka Streams documentation needs definitive rework and improvement - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/01 14:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5672) Move measureLatencyNs from StreamsMetricsImpl to StreamsMetrics - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 14:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5687) Retention settings are inconsistent between broker and topic - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2017/08/01 15:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5688) Add a modifier to the REST endpoint to only show errors - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2017/08/01 15:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5687) Retention settings are inconsistent between broker and topic - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/01 15:27:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5687) Retention settings are inconsistent between broker and topic - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2017/08/01 15:39:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/01 16:00:04 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5154) Kafka Streams throws NPE during rebalance - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 16:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5668) queryable state window store range scan only returns results from one store - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 16:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5654) Add new API methods to KGroupedStream - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 17:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5652) Add new api methods to KStream - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 17:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5655) Add new API methods to KGroupedTable - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 17:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5651) KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 17:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5673) Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the outermost store - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 17:13:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5653) Add new API methods to KTable - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 17:13:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5689) Refactor WindowStore hierarchy so that Metered Store is the outermost store - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/01 17:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade - posted by "Fernando Vega (JIRA)" <ji...@apache.org> on 2017/08/01 17:59:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5454) Add a new Kafka Streams example IoT oriented - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/01 18:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5638) Inconsistency in consumer group related ACLs - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/08/01 18:37:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-5638) Inconsistency in consumer group related ACLs - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/08/01 18:39:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5690) kafka-acls command should be able to list per principal - posted by "Koelli Mungee (JIRA)" <ji...@apache.org> on 2017/08/01 20:56:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/08/01 22:35:02 UTC, 15 replies.
- [jira] [Commented] (KAFKA-5690) kafka-acls command should be able to list per principal - posted by "Sanjoy Dasgupta (JIRA)" <ji...@apache.org> on 2017/08/01 22:49:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3623) Make KStreamTestDriver extending from ExternalResource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/01 23:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5152) Kafka Streams keeps restoring state after shutdown is initiated during startup - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/02 00:11:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2017/08/02 03:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/02 03:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5690) kafka-acls command should be able to list per principal - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/02 03:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2244) Document Kafka metrics configuration properties - posted by "Pranav Maniar (JIRA)" <ji...@apache.org> on 2017/08/02 07:00:02 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2244) Document Kafka metrics configuration properties - posted by "Pranav Maniar (JIRA)" <ji...@apache.org> on 2017/08/02 07:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5641) Metadata request should always be allowed to send no regardless of value for max.in.flight.requests.per.connection - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/02 08:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5641) Metadata request should always be allowed to send no regardless of value for max.in.flight.requests.per.connection - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/02 08:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5358) Consumer perf tool should count rebalance time separately - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/02 09:44:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-5152) Kafka Streams keeps restoring state after shutdown is initiated during startup - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/02 09:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5459) Support kafka-console-producer.sh messages as whole file - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/02 10:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/08/02 12:29:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5096) Only log invalid user configs and overwrite with correct one - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/02 13:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/08/02 14:18:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/08/02 15:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/08/02 15:19:02 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5561) Rewrite TopicCommand using the new Admin client - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2017/08/02 16:07:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled - posted by "Sumant Tambe (JIRA)" <ji...@apache.org> on 2017/08/02 16:37:01 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-5621) The producer should retry expired batches when retries are enabled - posted by "Sumant Tambe (JIRA)" <ji...@apache.org> on 2017/08/02 16:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/08/02 16:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/08/02 17:04:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3657) NewProducer NullPointerException on ProduceRequest - posted by "Shubham Rander (JIRA)" <ji...@apache.org> on 2017/08/02 17:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/02 18:07:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5694) Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113) - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/08/02 18:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/02 21:35:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/02 21:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/02 22:56:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-5663) LogDirFailureTest system test fails - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/02 22:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5560) LogManager should be able to create new logs based on free disk space - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/03 00:50:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2360) The kafka-consumer-perf-test.sh script help information print useless parameters. - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/03 03:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2360) The kafka-consumer-perf-test.sh script help information print useless parameters. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/03 03:14:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/08/03 04:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/03 05:00:11 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3268) Refactor existing CLI scripts to use KafkaAdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/08/03 09:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3268) Refactor existing CLI scripts to use KafkaAdminClient - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/08/03 10:00:02 UTC, 4 replies.
- [jira] [Commented] (KAFKA-4541) Add capability to create delegation token - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/03 15:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4541) Add capability to create delegation token - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/03 15:34:07 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4544) Add system tests for delegation token based authentication - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/03 15:57:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/08/03 18:53:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration - posted by "Oleg Kuznetsov (JIRA)" <ji...@apache.org> on 2017/08/03 20:12:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/03 22:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5698) Sort processor node based on name suffix in TopologyDescription.toString() - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/03 22:44:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2959) Remove temporary mapping to deserialize functions in RequestChannel - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/03 23:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2507) Replace ControlledShutdown{Request,Response} with org.apache.kafka.common.requests equivalent - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/03 23:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2507) Replace ControlledShutdown{Request,Response} with org.apache.kafka.common.requests equivalent - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/03 23:16:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5699) Validate and Create connector endpoint should take the same format message body - posted by "Robin Moffatt (JIRA)" <ji...@apache.org> on 2017/08/03 23:20:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5467) setting offset retention minutes to a lower value is not reflecting - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/04 00:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5698) Sort processor node based on name suffix in TopologyDescription.toString() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 00:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5698) Sort processor node based on name suffix in TopologyDescription.toString() - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/04 00:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5700) producer missed header information when splitting batches - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/04 03:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5700) producer missed header information when splitting batches - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 03:24:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5665) Incorrect interruption invoking method used for Heartbeat thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 03:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5665) Incorrect interruption invoking method used for Heartbeat thread - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/04 03:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5694) Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 05:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5647) Use async ZookeeperClient for Admin operations - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/04 10:28:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5461) KIP-168: Add GlobalTopicCount metric per cluster - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 10:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5461) KIP-168: Add GlobalTopicCount metric per cluster - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/04 10:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5647) Use async ZookeeperClient for Admin operations - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/04 10:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5700) producer missed header information when splitting batches - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/04 11:00:05 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5599) ConsoleConsumer : --new-consumer option as deprecated - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 11:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5619) Make --new-consumer option as deprecated in all tools - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 11:49:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5588) ConsoleConsumer : uselss --new-consumer option - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 12:01:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5388) Replace zkClient.subscribe*Changes method with an equivalent zkUtils method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 13:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5102) Refactor core components to use zkUtils methods instead of zkUtils.zkClient - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2017/08/04 13:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5701) Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/04 14:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 14:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/04 14:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5701) Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/08/04 14:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 14:48:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5546) Temporary loss of availability data when the leader is disconnected - posted by "Björn Eriksson (JIRA)" <ji...@apache.org> on 2017/08/04 14:55:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5546) Temporary loss of availability data when the leader is disconnected - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/04 16:13:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5617) Update to the list of third-party clients - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/04 16:54:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5644) Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 17:25:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5535) Transformations - tranformations for value broken on tombstone events - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 17:27:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5644) Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/04 17:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5703) allow debug-level logging for RequestChannel's request logger - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/08/04 18:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5703) allow debug-level logging for RequestChannel's request logger - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/04 18:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5703) allow debug-level logging for RequestChannel's request logger - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/08/04 18:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5681) jarAll does not build all scala versions anymore. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/04 19:53:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/04 20:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/04 20:23:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5704) Auto topic creation causes failure with older clusters - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/08/04 21:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5705) Kafka Server start failed and reports "unsafe memory access operation" - posted by "Chen He (JIRA)" <ji...@apache.org> on 2017/08/04 22:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3408) consumer rebalance fail - posted by "Chen He (JIRA)" <ji...@apache.org> on 2017/08/04 22:22:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2499) kafka-producer-perf-test should use something more realistic than empty byte arrays - posted by "Chen He (JIRA)" <ji...@apache.org> on 2017/08/04 22:28:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5704) Auto topic creation causes failure with older clusters - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/04 22:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5704) Auto topic creation causes failure with older clusters - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/04 22:52:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5705) Kafka Server start failed and reports "unsafe memory access operation" - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/04 22:54:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5706) log the name of the error instead of the error code in response objects - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/08/05 00:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5706) log the name of the error instead of the error code in response objects - posted by "Manasvi Gupta (JIRA)" <ji...@apache.org> on 2017/08/05 04:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5706) log the name of the error instead of the error code in response objects - posted by "Manasvi Gupta (JIRA)" <ji...@apache.org> on 2017/08/05 04:54:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5602) Add --custom-ducktape flag to ducker-ak - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/05 08:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5602) Add --custom-ducktape flag to ducker-ak - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/05 08:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5430) new consumers getting data for revoked partitions - posted by "Lior Chaga (JIRA)" <ji...@apache.org> on 2017/08/06 09:47:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5430) new consumers getting data for revoked partitions - posted by "Lior Chaga (JIRA)" <ji...@apache.org> on 2017/08/06 09:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test - posted by "Chanchal Singh (JIRA)" <ji...@apache.org> on 2017/08/06 17:28:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-5707) Remove useless `--force` option for both TopicCommand and ConfigCommand - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/07 01:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5707) Remove useless `--force` option for both TopicCommand and ConfigCommand - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/07 01:43:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5643) Using _DUCKTAPE_OPTIONS has no effect on executing tests - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/08/07 04:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5700) producer missed header information when splitting batches - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/07 05:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5708) Update Jackson dependencies (from 2.8.5 to 2.9.x) - posted by "Dejan Stojadinović (JIRA)" <ji...@apache.org> on 2017/08/07 07:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5707) Remove useless `--force` option for both TopicCommand and ConfigCommand - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/07 08:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/07 09:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5138) MirrorMaker doesn't exit on send failure occasionally - posted by "Tamas Mate (JIRA)" <ji...@apache.org> on 2017/08/07 11:29:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-3417) Invalid characters in config properties not being validated? - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/07 11:54:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2017/08/07 13:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2017/08/07 13:33:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/07 14:29:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/07 14:30:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5516) Formatting verifiable producer/consumer output in a similar fashion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/07 15:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5430) new consumers getting data for revoked partitions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/07 15:52:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/07 16:15:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2017/08/07 16:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5581) Streams can be smarter in deciding when to create changelog topics for state stores - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2017/08/07 16:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/07 18:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5705) Kafka Server start failed and reports "unsafe memory access operation" - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/07 18:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Oleg Kuznetsov (JIRA)" <ji...@apache.org> on 2017/08/07 18:11:00 UTC, 8 replies.
- [jira] [Updated] (KAFKA-5704) Auto topic creation causes failure with older clusters - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/07 19:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5709) Improve logging to include errors from state-change log in server log - posted by "Alla Tumarkin (JIRA)" <ji...@apache.org> on 2017/08/07 20:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5681) jarAll does not build all scala versions anymore. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/08/07 21:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5701) Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/07 22:22:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5708) Update Jackson dependencies (from 2.8.5 to 2.9.x) - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/08/08 01:52:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5710) KafkaAdminClient should remove inflight call correctly after response is received - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/08/08 08:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5710) KafkaAdminClient should remove inflight call correctly after response is received - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/08 08:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5658) Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/08 08:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5711) Bulk Restore Should Handle Deletes - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/08/08 14:05:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-5705) Kafka Server start failed and reports "unsafe memory access operation" - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/08 17:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5712) Expose ProducerConfig in the KafkaProducer clients - posted by "Leo Xuzhang Lin (JIRA)" <ji...@apache.org> on 2017/08/08 17:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5712) Expose ProducerConfig in the KafkaProducer clients - posted by "Leo Xuzhang Lin (JIRA)" <ji...@apache.org> on 2017/08/08 17:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5711) Bulk Restore Should Handle Deletes - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/08 17:54:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5713) Improve '--group' option to understand strings with wildcards - posted by "Alla Tumarkin (JIRA)" <ji...@apache.org> on 2017/08/08 18:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5713) Improve '--group' option to understand strings with wildcards - posted by "Alla Tumarkin (JIRA)" <ji...@apache.org> on 2017/08/08 18:11:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5714) Allow whitespaces in the principal name - posted by "Alla Tumarkin (JIRA)" <ji...@apache.org> on 2017/08/08 18:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5407) Mirrormaker dont start after upgrade - posted by "Fernando Vega (JIRA)" <ji...@apache.org> on 2017/08/08 20:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4501) Support Java 9 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/09 00:24:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5715) ConsumerGroupCommand failed to show in ascending order for partitions without consumers - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/09 03:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5715) ConsumerGroupCommand failed to show in ascending order for partitions without consumers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/09 03:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5704) Auto topic creation causes failure with older clusters - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/08/09 03:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2017/08/09 10:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic - posted by "Bart Vercammen (JIRA)" <ji...@apache.org> on 2017/08/09 10:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5717) [streams] 'null' values in state stores - posted by "Bart Vercammen (JIRA)" <ji...@apache.org> on 2017/08/09 10:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5717) [streams] 'null' values in state stores - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/09 13:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5717) [streams] 'null' values in state stores - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/09 13:27:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5718) Better document what LogAppendTime means - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2017/08/09 13:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2360) The kafka-consumer-perf-test.sh script help information print useless parameters. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/09 14:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5717) [streams] 'null' values in state stores - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/09 19:05:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2017/08/09 20:09:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5629) Console Consumer overrides auto.offset.reset property when provided on the command line without warning about it. - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/09 20:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5629) Console Consumer overrides auto.offset.reset property when provided on the command line without warning about it. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/09 20:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2017/08/09 20:35:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2017/08/09 20:37:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5719) Create a quickstart archetype project for Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/09 21:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5720) In Jenkins, kafka.api.SaslSslAdminClientIntegrationTest failed with org.apache.kafka.common.errors.TimeoutException - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/09 22:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5720) In Jenkins, kafka.api.SaslSslAdminClientIntegrationTest failed with org.apache.kafka.common.errors.TimeoutException - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/09 22:18:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5470) Replace -XX:+DisableExplicitGC with -XX:+ExplicitGCInvokesConcurrent in kafka-run-class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/09 22:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5507) kafka-run-class.sh doesn't check for empty $CLASSPATH - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/09 23:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5507) kafka-run-class.sh doesn't check for empty $CLASSPATH - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/09 23:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5721) Kafka broker stops after network failure - posted by "Val Feron (JIRA)" <ji...@apache.org> on 2017/08/10 00:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5721) Kafka broker stops after network failure - posted by "Val Feron (JIRA)" <ji...@apache.org> on 2017/08/10 00:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5077) Make server start script work against Java 9 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/10 01:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5077) Make server start script work against Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/10 01:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5077) Make server start script work against Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/10 01:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5077) Make server start script work against Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/10 01:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the new AdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/08/10 09:48:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5722) Refactor ConfigCommand to use the new AdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/08/10 09:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the KafkaAdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/08/10 09:49:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the KafkaAdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/08/10 09:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3389) ReplicaStateMachine areAllReplicasForTopicDeleted check not handling well case when there are no replicas for topic - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/10 11:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5562) Do streams state directory cleanup on a single thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/10 11:54:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5718) Better document what LogAppendTime means - posted by "Umesh Chaudhary (JIRA)" <ji...@apache.org> on 2017/08/10 11:54:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-1718) "Message Size Too Large" error when only small messages produced with Snappy - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2017/08/10 23:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/08/10 23:54:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5663) LogDirFailureTest system test fails - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/11 00:09:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5724) AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero - posted by "Allen Wang (JIRA)" <ji...@apache.org> on 2017/08/11 01:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5724) AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/11 07:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5724) AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/11 07:26:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-5714) Allow whitespaces in the principal name - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/11 09:20:00 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-5714) Allow whitespaces in the principal name - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/11 09:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the new AdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/08/11 12:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5725) Additional failure testing for streams with bouncing brokers - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/11 13:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4643) Improve test coverage of StreamsKafkaClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/11 14:40:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the new AdminClient - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/08/11 15:27:00 UTC, 11 replies.
- [jira] [Created] (KAFKA-5726) KafkaConsumer.subscribe() override that takes just Pattern without ConsumerRebalanceListener - posted by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2017/08/11 15:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5726) KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/11 15:37:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5727) Add the archetype project along with "write applications" web docs. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/11 19:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5727) Add the archetype project along with "write applications" web docs. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/11 19:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5727) Add the archetype project along with "write applications" web docs. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/11 19:21:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5728) Stopping consumer thread cause loosing message in the partition - posted by "Vasudevan Karnan (JIRA)" <ji...@apache.org> on 2017/08/11 20:00:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4585) KIP-163: Offset fetch and commit requests use the same permissions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/11 20:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1379) Partition reassignment resets clock for time-based retention - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/08/11 21:21:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5729) Consumer should verify offset commits are from assigned partitions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/11 22:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5730) Consumer should ensure consistent ordering between sync and async offset commits - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/11 23:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/11 23:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/11 23:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5074) Transition to OnlinePartition without preferred leader in ISR fails - posted by "Pierre Mage (JIRA)" <ji...@apache.org> on 2017/08/12 00:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5732) Kafka 0.11 Consumer.Poll() hangs for consumer.subscribe() - posted by "Ramkumar (JIRA)" <ji...@apache.org> on 2017/08/12 18:57:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the new AdminClient - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/08/13 21:03:01 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/13 23:42:00 UTC, 7 replies.
- [jira] [Updated] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/14 00:19:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established - posted by "Braedon Vickers (JIRA)" <ji...@apache.org> on 2017/08/14 04:37:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace - posted by "Ondrej Tomcik (JIRA)" <ji...@apache.org> on 2017/08/14 08:52:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5673) Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the outermost store - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/14 09:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5733) System tests get exception RocksDBException: db has more levels than options.num_levels - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/14 13:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5733) System tests get exception RocksDBException: db has more levels than options.num_levels - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/08/14 14:00:03 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-3984) Broker doesn't retry reconnecting to an expired Zookeeper connection - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/08/14 15:24:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-658) Implement "Exact Mirroring" functionality in mirror maker - posted by "Paul Wilkinson (JIRA)" <ji...@apache.org> on 2017/08/14 15:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5595) Illegal state in SocketServer; attempt to send with another send in progress - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/14 16:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4643) Improve test coverage of StreamsKafkaClient - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/14 17:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5567) With transformations that mutate the topic-partition committing offsets should to refer to the original topic-partition - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2017/08/14 18:42:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5567) With transformations that mutate the topic-partition committing offsets should to refer to the original topic-partition - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2017/08/14 18:43:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5730) Consumer should ensure consistent ordering between sync and async offset commits - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/14 19:03:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5606) Review consumer's RequestFuture usage pattern - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/15 02:49:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5679) Add logging to distinguish between internally and externally initiated shutdown of Kafka - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/15 07:57:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5726) KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/15 09:21:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5734) Heap (Old generation space) gradually increase - posted by "jang (JIRA)" <ji...@apache.org> on 2017/08/15 10:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5734) Heap (Old generation space) gradually increase - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/15 10:56:00 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-5718) Better document what LogAppendTime means - posted by "Umesh Chaudhary (JIRA)" <ji...@apache.org> on 2017/08/15 11:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5735) Client-ids are not handled consistently by clients and broker - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/08/15 12:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead - posted by "Tommy Becker (JIRA)" <ji...@apache.org> on 2017/08/15 14:41:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead - posted by "Tommy Becker (JIRA)" <ji...@apache.org> on 2017/08/15 14:42:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-5679) Add logging to distinguish between internally and externally initiated shutdown of Kafka - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/15 16:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/15 17:33:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5603) Streams should not abort transaction when closing zombie task - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/15 17:34:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-1821) Example shell scripts broken - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/15 17:40:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/15 17:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5727) Add the archetype project along with "write applications" web docs. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/15 18:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2206) Add AlterConfig and DescribeConfig requests to Kafka - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/15 18:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace - posted by "Soumabrata Chakraborty (JIRA)" <ji...@apache.org> on 2017/08/15 18:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2220) Improvement: Could we support rewind by time ? - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/15 18:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2283) scheduler exception on non-controller node when shutdown - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/15 18:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5713) Improve kafka-acls options to understand strings with wildcards - posted by "Alla Tumarkin (JIRA)" <ji...@apache.org> on 2017/08/15 20:58:01 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5735) Client-ids are not handled consistently by clients and broker - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/08/15 22:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2017/08/15 22:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/15 22:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/15 23:00:06 UTC, 1 replies.
- [jira] [Created] (KAFKA-5737) KafkaAdminClient thread should be daemon - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/15 23:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5737) KafkaAdminClient thread should be daemon - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/15 23:22:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/16 00:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/08/16 07:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5735) Client-ids are not handled consistently by clients and broker - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/08/16 09:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/16 10:11:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3689) Exception when attempting to decrease connection count for address with no connections - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5272) Improve validation for Alter Configs (KIP-133) - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:42:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5403) Transactions system test should dedup consumed messages by offset - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:44:02 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:44:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4686) Null Message payload is shutting down broker - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:44:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1923) Negative offsets in replication-offset-checkpoint file - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5284) Add tools and metrics to diagnose problems with the idempotent producer and transactions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:45:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5026) DebuggingConsumerId and DebuggingMessageFormatter and message format v2 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5383) Additional Test Cases for ReplicaManager - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5347) OutOfSequence error should be fatal - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:46:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5342) Distinguish abortable failures in transactional producer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:46:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5441) Fix transaction marker grouping by producerId in TC - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5445) Document exceptions thrown by AdminClient methods - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5482) A CONCURRENT_TRANASCTIONS error for the first AddPartitionsToTxn request slows down transactions significantly - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:48:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5543) We don't remove the LastStableOffsetLag metric when a partition is moved away from a broker - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:49:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5327) Console Consumer should only poll for up to max messages - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 10:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5152) Kafka Streams keeps restoring state after shutdown is initiated during startup - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/16 10:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5738) Add cumulative count attribute for all Kafka rate metrics - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/08/16 12:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3087) Fix documentation for retention.ms property and update documentation for LogConfig.scala class - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 12:30:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 12:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/16 13:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5739) Rewrite KStreamPeekTest at processor level avoiding driver usage - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/08/16 13:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5739) Rewrite KStreamPeekTest at processor level avoiding driver usage - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/08/16 13:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4834) Kafka cannot delete topic with ReplicaStateMachine went wrong - posted by "Joao Santos (JIRA)" <ji...@apache.org> on 2017/08/16 14:42:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4834) Kafka cannot delete topic with ReplicaStateMachine went wrong - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/16 14:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5740) Use separate file for HTTP logs - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/16 16:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4951) KafkaProducer may send duplicated message sometimes - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4889) 2G8lc - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4865) 2X8BF - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4847) 1Y30J - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5741) Prioritize threads in Connect distributed worker process - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/16 17:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4821) 9244L - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4804) TdOZY - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:21:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4803) OT6Y1 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4813) 2h6R1 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5741) Prioritize threads in Connect distributed worker process - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/16 17:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3796) SslTransportLayerTest.testInvalidEndpointIdentification fails on trunk - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/16 17:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/16 18:24:00 UTC, 7 replies.
- [jira] [Updated] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/16 18:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5441) Fix transaction marker grouping by producerId in TC - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/16 18:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5740) Use separate file for HTTP logs - posted by "CJ Woolard (JIRA)" <ji...@apache.org> on 2017/08/16 20:59:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5742) Support passing ZK chroot in system tests - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2017/08/16 21:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5742) Support passing ZK chroot in system tests - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2017/08/16 21:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5742) Support passing ZK chroot in system tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/16 21:19:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-5567) With transformations that mutate the topic-partition committing offsets should to refer to the original topic-partition - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/08/16 21:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5233) Changes to punctuate semantics (KIP-138) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/16 22:27:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5743) Ducktape services should store their files in subdirectories of /mnt - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/16 22:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5076) Remove usage of java.xml.bind.* classes hidden by default in JDK9 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/16 22:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5744) ShellTest: add tests for attempting to run nonexistent program, error return - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/16 22:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5744) ShellTest: add tests for attempting to run nonexistent program, error return - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/16 22:48:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-5743) All ducktape services should store their files in subdirectories of /mnt - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/16 23:15:03 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5743) All ducktape services should store their files in subdirectories of /mnt - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/16 23:56:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5745) Partition.makeLeader() should convert HW to OffsetMetadata before becoming the leader - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/08/17 01:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5745) Partition.makeLeader() should convert HW to OffsetMetadata before becoming the leader - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/08/17 01:15:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-5745) Partition.makeLeader() should convert HW to OffsetMetadata before becoming the leader - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/17 03:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5403) Transactions system test should dedup consumed messages by offset - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/17 04:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5482) A CONCURRENT_TRANASCTIONS error for the first AddPartitionsToTxn request slows down transactions significantly - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/17 04:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5543) We don't remove the LastStableOffsetLag metric when a partition is moved away from a broker - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/17 04:17:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5403) Transactions system test should dedup consumed messages by offset - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/17 04:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5725) Additional failure testing for streams with bouncing brokers - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/17 08:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5531) Check exception handling in all streams tests - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/17 08:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5417) Clients get inconsistent connection states when SASL/SSL connection is marked CONECTED and DISCONNECTED at the same time - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/17 08:48:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/17 08:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5734) Heap (Old generation space) gradually increase - posted by "jang (JIRA)" <ji...@apache.org> on 2017/08/17 09:02:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-2206) Add AlterConfig and DescribeConfig requests to Kafka - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/17 09:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5746) Add new metrics to support health checks - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/08/17 09:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5689) Refactor WindowStore hierarchy so that Metered Store is the outermost store - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/08/17 10:02:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5686) Documentation inconsistency on the "Compression" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/17 10:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5668) queryable state window store range scan only returns results from one store - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/17 10:41:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5738) Add cumulative count attribute for all Kafka rate metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/17 10:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-196) Topic creation fails on large values - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/17 11:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-186) no clean way to getCompressionCodec from Java-the-language - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/17 11:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-236) Make 'autooffset.reset' accept a delay in addition to {smallest,largest} - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/17 11:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-276) Enforce max.message.size on the total message size, not just on payload size - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/17 11:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-275) max.message.size is not enforced for compressed messages - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/17 12:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-359) Add message constructor that takes payload as a byte buffer - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/17 12:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-357) Refactor zookeeper code in KafkaZookeeper into reusable components - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/17 12:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2218) reassignment tool needs to parse and validate the json - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/17 12:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5726) KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener - posted by "Attila Kreiner (JIRA)" <ji...@apache.org> on 2017/08/17 13:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/17 16:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5733) System tests get exception RocksDBException: db has more levels than options.num_levels - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/17 16:30:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5733) System tests get exception RocksDBException: db has more levels than options.num_levels - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/17 16:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3856) Cleanup Kafka Streams builder API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/17 16:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3741) Allow setting of default topic configs via StreamsConfig - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/17 16:49:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/17 16:49:02 UTC, 1 replies.
- [jira] [Created] (KAFKA-5747) Broker crashes on startup when trying to parse empty snapshot files - posted by "Lukasz Mierzwa (JIRA)" <ji...@apache.org> on 2017/08/17 19:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5747) Broker crashes on startup when trying to parse empty snapshot files - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2017/08/17 19:09:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-4341) KIP-87 - Add Compaction Tombstone Flag - posted by "Michael Andre Pearce (JIRA)" <ji...@apache.org> on 2017/08/17 19:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5537) Subscribe Earliest is not working as in 0.10.2.1 - posted by "Michael Andre Pearce (JIRA)" <ji...@apache.org> on 2017/08/17 19:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5747) Broker crashes on startup when trying to parse empty snapshot files - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/17 20:30:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5747) Broker crashes on startup when trying to parse empty snapshot files - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/17 20:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5733) System tests get exception RocksDBException: db has more levels than options.num_levels - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/17 21:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "Joseph Aliase (JIRA)" <ji...@apache.org> on 2017/08/17 21:40:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5748) Fix console producer to set timestamp and partition - posted by "Ran Ma (JIRA)" <ji...@apache.org> on 2017/08/17 22:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5748) Fix console producer to set timestamp and partition - posted by "Ran Ma (JIRA)" <ji...@apache.org> on 2017/08/17 22:00:02 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5730) Consumer should ensure consistent ordering between sync and async offset commits - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/17 22:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5742) Support passing ZK chroot in system tests - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/08/17 22:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5559) Metrics should throw if two client registers with same ID - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/08/18 00:14:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5651) KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/08/18 07:40:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5744) ShellTest: add tests for attempting to run nonexistent program, error return - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/18 11:00:03 UTC, 1 replies.
- [jira] [Created] (KAFKA-5749) Refactor SessionStore hierarchy - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/18 13:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5750) Elevate log messages for denials to WARN in SimpleAclAuthorizer class - posted by "Phillip Walker (JIRA)" <ji...@apache.org> on 2017/08/18 13:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5734) Heap (Old generation space) gradually increase - posted by "jang (JIRA)" <ji...@apache.org> on 2017/08/18 13:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5745) Partition.makeLeader() should convert HW to OffsetMetadata before becoming the leader - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/18 15:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5750) Elevate log messages for denials to WARN in SimpleAclAuthorizer class - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/18 15:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak - posted by "Lawrence Weikum (JIRA)" <ji...@apache.org> on 2017/08/18 15:46:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5725) Additional failure testing for streams with bouncing brokers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/18 17:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5725) Additional failure testing for streams with bouncing brokers - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/18 17:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/08/18 17:30:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5751) Kafka cannot start; corrupted index file(s) - posted by "Martin M (JIRA)" <ji...@apache.org> on 2017/08/18 17:59:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/18 18:00:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5751) Kafka cannot start; corrupted index file(s) - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/18 18:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5750) Elevate log messages for denials to WARN in SimpleAclAuthorizer class - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 06:57:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5737) KafkaAdminClient thread should be daemon - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 07:01:14 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5744) ShellTest: add tests for attempting to run nonexistent program, error return - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 07:55:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4856) Calling KafkaProducer.close() from multiple threads may cause spurious error - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/19 08:01:16 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3322) recurring errors - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 08:09:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5752) Delete topic and re-create topic immediate will delete the new topic's timeindex - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2017/08/19 09:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5752) Delete topic and re-create topic immediate will delete the new topic's timeindex - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/19 09:14:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-2105) NullPointerException in client on MetadataRequest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/19 14:55:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3327) Warning from kafka mirror maker about ssl properties not valid - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 15:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3413) Load Error Message should be a Warning - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 15:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4078) VIP for Kafka doesn't work - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3953) start kafka fail - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:08:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3951) kafka.common.KafkaStorageException: I/O exception in append to log - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1495) Kafka Example SimpleConsumerDemo - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:12:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2053) Make initZk a protected function - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:15:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2093) Remove logging error if we throw exception - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:17:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2296) Not able to delete topic on latest kafka - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2231) Deleting a topic fails - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:23:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2289) KafkaProducer logs erroneous warning on startup - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/19 16:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5750) Elevate log messages for denials to WARN in SimpleAclAuthorizer class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/19 17:29:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails locally - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/19 18:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5754) Refactor Streams to use LogContext - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/19 18:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5755) Refactor Producer to use LogContext - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/19 18:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5752) Delete topic and re-create topic immediate will delete the new topic's timeindex - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/19 19:17:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5571) Possible deadlock during shutdown in setState in kafka streams 10.2 - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/20 07:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled - posted by "Bhaskar Gollapudi (JIRA)" <ji...@apache.org> on 2017/08/20 08:41:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled - posted by "Tomas Benc (JIRA)" <ji...@apache.org> on 2017/08/20 16:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5756) Synchronization issue on flush - posted by "Oleg Kuznetsov (JIRA)" <ji...@apache.org> on 2017/08/20 21:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5756) Synchronization issue on flush - posted by "Oleg Kuznetsov (JIRA)" <ji...@apache.org> on 2017/08/20 21:37:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5756) Synchronization issue on flush - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/20 22:01:06 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/21 00:33:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-5744) ShellTest: add tests for attempting to run nonexistent program, error return - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/21 02:41:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5744) ShellTest: add tests for attempting to run nonexistent program, error return - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/21 02:42:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5755) Refactor Producer to use LogContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/21 03:04:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5755) Refactor Producer to use LogContext - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/21 03:04:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails locally - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/21 03:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails locally - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/21 03:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5748) Fix console producer to set timestamp and partition - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/21 06:00:04 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5746) Add new metrics to support health checks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/21 13:32:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5153) KAFKA Cluster : 0.10.2.0 : Servers Getting disconnected : Service Impacting - posted by "Arthur (JIRA)" <ji...@apache.org> on 2017/08/21 14:00:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-5153) KAFKA Cluster : 0.10.2.0 : Servers Getting disconnected : Service Impacting - posted by "Arthur (JIRA)" <ji...@apache.org> on 2017/08/21 14:01:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5757) Scheduled or Delayed connector start - posted by "Dhananjay Patkar (JIRA)" <ji...@apache.org> on 2017/08/21 14:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file - posted by "Mikhail Lesyk (JIRA)" <ji...@apache.org> on 2017/08/21 14:19:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5635) KIP-181 Kafka-Connect integrate with kafka ReST Proxy - posted by "Dhananjay Patkar (JIRA)" <ji...@apache.org> on 2017/08/21 14:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5757) Scheduled or Delayed connector start - posted by "Dhananjay Patkar (JIRA)" <ji...@apache.org> on 2017/08/21 14:23:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails locally - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/21 15:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails locally - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/21 15:00:03 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails on macOS - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/21 15:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails on macOS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/21 15:02:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics - posted by "David van Geest (JIRA)" <ji...@apache.org> on 2017/08/21 17:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics - posted by "David van Geest (JIRA)" <ji...@apache.org> on 2017/08/21 17:14:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-5747) Broker crashes on startup when trying to parse empty snapshot files - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/21 17:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5753) ShellTest.testRunProgramWithErrorReturn fails on macOS - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/21 17:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5061) client.id should be set for Connect producers/consumers - posted by "Satyajit varma (JIRA)" <ji...@apache.org> on 2017/08/21 21:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5061) client.id should be set for Connect producers/consumers - posted by "Satyajit varma (JIRA)" <ji...@apache.org> on 2017/08/21 21:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4764) Improve diagnostics for SASL authentication failures - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/21 21:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics - posted by "David van Geest (JIRA)" <ji...@apache.org> on 2017/08/21 22:00:04 UTC, 7 replies.
- [jira] [Created] (KAFKA-5759) Allow user to specify relative path as log directory - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/08/22 00:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5759) Allow user to specify relative path as log directory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/22 00:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5760) The kafka Consumer can not poll the message by multi-thread - posted by "Julius (JIRA)" <ji...@apache.org> on 2017/08/22 02:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5760) The kafka Consumer can not poll the message by multi-thread - posted by "Julius (JIRA)" <ji...@apache.org> on 2017/08/22 02:24:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5749) Refactor SessionStore hierarchy - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/08/22 05:15:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-4741) Memory leak in RecordAccumulator.append - posted by "Julius Žaromskis (JIRA)" <ji...@apache.org> on 2017/08/22 09:17:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 09:20:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5761) Serializer API should support ByteBuffer - posted by "Bhaskar Gollapudi (JIRA)" <ji...@apache.org> on 2017/08/22 09:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5752) Delete topic and re-create topic immediate will delete the new topic's timeindex - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 09:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 09:25:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5754) Refactor Streams to use LogContext - posted by "Umesh Chaudhary (JIRA)" <ji...@apache.org> on 2017/08/22 09:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5689) Refactor WindowStore hierarchy so that Metered Store is the outermost store - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/22 10:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5751) Kafka cannot start; corrupted index file(s) - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 10:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5686) Documentation inconsistency on the "Compression" - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 10:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5720) In Jenkins, kafka.api.SaslSslAdminClientIntegrationTest failed with org.apache.kafka.common.errors.TimeoutException - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 12:18:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 12:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5762) Refactor AdminClient to use LogContext - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 12:41:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-5763) Refactor NetworkClient to use LogContext - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 12:43:06 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4856) Calling KafkaProducer.close() from multiple threads may cause spurious error - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 12:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 12:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4856) Calling KafkaProducer.close() from multiple threads may cause spurious error - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 14:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5764) KafkaShortnamer should allow for case inensitive matches - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2017/08/22 14:56:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5681) jarAll does not build all scala versions anymore. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 15:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5465) FetchResponse v0 does not return any messages when max_bytes smaller than v2 message set - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/22 15:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5762) Refactor AdminClient to use LogContext - posted by "Kamal Chandraprakash (JIRA)" <ji...@apache.org> on 2017/08/22 15:56:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/22 16:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2017/08/22 17:25:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5401) Kafka Over TLS Error - Failed to send SSL Close message - Broken Pipe - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 17:27:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5547) Return topic authorization failed if no topic describe access - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 17:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/22 18:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4840) There are are still cases where producer buffer pool will not remove waiters. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 18:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5239) Producer buffer pool allocates memory inside a lock. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 18:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5239) Producer buffer pool allocates memory inside a lock. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 18:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4823) Creating Kafka Producer on application running on Java older version - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 18:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5766) Very high CPU-load of consumer when broker is down - posted by "Sebastian Bernauer (JIRA)" <ji...@apache.org> on 2017/08/22 19:00:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5732) Kafka 0.11 Consumer.Poll() hangs for consumer.subscribe() - posted by "Ramkumar (JIRA)" <ji...@apache.org> on 2017/08/22 19:12:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5749) Refactor SessionStore hierarchy - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/08/22 19:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5763) Refactor NetworkClient to use LogContext - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/08/22 19:19:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-3927) kafka broker config docs issue - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 19:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3800) java client can`t poll msg - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 19:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3653) expose the queue size in ControllerChannelManager - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 19:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3473) Add controller channel manager request queue time metric. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 19:47:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3139) JMX metric ProducerRequestPurgatory doesn't exist, docs seem wrong. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/22 20:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5156) Options for handling exceptions in streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/22 22:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/08/22 23:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/22 23:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5603) Streams should not abort transaction when closing zombie task - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/23 00:12:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5768) Upgrade ducktape version to 0.7.0, and use new kill_java_processes - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/23 00:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5768) Upgrade ducktape version to 0.7.0, and use new kill_java_processes - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/23 00:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/23 00:39:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4113) Allow KTable bootstrap - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/23 00:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/23 00:41:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2590) KIP-28: Kafka Streams Checklist - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/23 00:41:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2590) KIP-28: Kafka Streams Checklist - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/23 00:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3705) Support non-key joining in KTable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/23 00:45:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5768) Upgrade ducktape version to 0.7.0, and use new kill_java_processes - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/23 00:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5327) Console Consumer should only poll for up to max messages - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/08/23 07:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5769) Transient test failure org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/23 08:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5770) AdminClient.deleteTopics future complete but topic is still here - posted by "Vincent Maurin (JIRA)" <ji...@apache.org> on 2017/08/23 09:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5770) AdminClient.deleteTopics future complete but topic is still here - posted by "Vincent Maurin (JIRA)" <ji...@apache.org> on 2017/08/23 09:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5590) Delete Kafka Topic Complete Failed After Enable Ranger Kafka Plugin - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/23 11:56:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5590) Delete Kafka Topic Complete Failed After Enable Ranger Kafka Plugin - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/23 11:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5769) Transient test failure org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/23 13:23:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5771) org.apache.kafka.streams.state.internals.Segments#segments method returns incorrect results when segments were added out of order - posted by "Alexander Radzishevsky (JIRA)" <ji...@apache.org> on 2017/08/23 14:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5772) Improve Util classes - posted by "Matthias Weßendorf (JIRA)" <ji...@apache.org> on 2017/08/23 15:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5772) Improve Util classes - posted by "Matthias Weßendorf (JIRA)" <ji...@apache.org> on 2017/08/23 15:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5773) ConnectRecord.equals() doesn't properly handle array keys/values - posted by "Ryan Kennedy (JIRA)" <ji...@apache.org> on 2017/08/23 18:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5771) org.apache.kafka.streams.state.internals.Segments#segments method returns incorrect results when segments were added out of order - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/23 20:25:00 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-5644) Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/23 21:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5774) WorkerSinkTask failure exception should include cause - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/23 23:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5775) Implement Fault Injection testing for Kafka - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/23 23:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5776) Add the Trogdor fault injection daemon - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/24 00:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5776) Add the Trogdor fault injection daemon - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/24 00:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5777) Add ducktape integration for the Trogdor Fault injection daemon - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/24 00:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5777) Add ducktape integration for the Trogdor Fault injection daemon - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/24 00:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5776) Add the Trogdor fault injection daemon - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/24 00:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5777) Add ducktape integration for the Trogdor Fault injection daemon - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/24 00:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4799) session timeout during event processing shuts down stream - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/24 01:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5778) Kafka cluster is not responding when one broker hangs and resulted in too many connections in close_wait in other brokers - posted by "saichand (JIRA)" <ji...@apache.org> on 2017/08/24 06:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5779) Single message may exploit application based on KStream - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/24 07:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5754) Refactor Streams to use LogContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/24 09:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1324) Debian packaging - posted by "Martin Schröder (JIRA)" <ji...@apache.org> on 2017/08/24 11:46:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4869) 0.10.2.0 release notes incorrectly include KIP-115 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/24 11:49:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-4425) Topic created with CreateTopic command, does not list partitions in metadata - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 12:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5634) Replica fetcher thread crashes due to OffsetOutOfRangeException - posted by "Murad M (JIRA)" <ji...@apache.org> on 2017/08/24 12:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1497) Change producer load-balancing algorithm in MirrorMaker - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 14:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5780) Long shutdown time when updated to 0.11.0 - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/08/24 14:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1339) Time based offset retrieval seems broken - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 14:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-962) Add list topics to ClientUtils - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 14:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5780) Long shutdown time when updated to 0.11.0 - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/08/24 14:36:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5780) Long shutdown time when updated to 0.11.0 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/24 14:54:00 UTC, 12 replies.
- [jira] [Comment Edited] (KAFKA-5780) Long shutdown time when updated to 0.11.0 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/24 14:57:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-958) Please compile list of key metrics on the broker and client side and put it on a wiki - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 14:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3332) Consumer can't consume messages from zookeeper chroot - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 15:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-627) Make UnknownTopicOrPartitionException a WARN in broker - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 15:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2966) 0.9.0 docs missing upgrade notes regarding replica lag - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 15:44:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2829) Inconsistent naming in {Producer,Consumer} Callback interfaces - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 15:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2565) Offset Commit is not working if multiple consumers try to commit the offset - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 15:52:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2560) Fatal error during KafkaServer startup because of Map failed error. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 15:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2577) one node of Kafka cluster cannot process produce request - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 15:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2451) Exception logged but not managed - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 15:59:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate. - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/08/24 16:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will get WARN Error in I/O. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 16:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate. - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/08/24 16:02:02 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/24 16:28:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-5779) Single message may exploit application based on KStream - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/24 16:41:00 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-3885) Kafka new producer cannot failover - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 16:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4109) kafka client send msg exception - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 17:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4350) Can't mirror from Kafka 0.9 to Kafka 0.10.1 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/24 17:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5780) Long shutdown time when updated to 0.11.0 - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/24 17:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5774) WorkerSinkTask failure exception should include cause - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/24 17:50:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5782) Avoid unnecessary PID reset when expire batches. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/08/24 19:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/08/24 20:25:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-5634) Replica fetcher thread crashes due to OffsetOutOfRangeException - posted by "Murad M (JIRA)" <ji...@apache.org> on 2017/08/24 21:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5783) Implement KafkaPrincipalBuilder interface with support for SASL (KIP-189) - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/24 22:04:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5771) org.apache.kafka.streams.state.internals.Segments#segments method returns incorrect results when segments were added out of order - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/24 22:30:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5784) Add a sensor for dropped records in window stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/24 22:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5342) Distinguish abortable failures in transactional producer - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/24 23:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5720) In Jenkins, kafka.api.SaslSslAdminClientIntegrationTest failed with org.apache.kafka.common.errors.TimeoutException - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/24 23:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/08/25 02:42:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5779) Single message may exploit application based on KStream - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/25 06:23:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-5595) Illegal state in SocketServer; attempt to send with another send in progress - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/25 08:26:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-5595) Illegal state in SocketServer; attempt to send with another send in progress - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/25 08:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5785) Always close connection if KafkaChannel.setSend throws exception - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/25 08:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5785) Always close connection if KafkaChannel.setSend throws exception - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/25 08:40:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5786) Yet another exception is causing that streamming app is zombie - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/25 08:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5785) Always close connection if KafkaChannel.setSend throws exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/25 09:08:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5787) StoreChangeLogReader needs to restore partitions that were added post initialization - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/25 09:15:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5787) StoreChangeLogReader needs to restore partitions that were added post initialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/25 09:39:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5788) "IllegalArgumentException: long is not a value type" when running ReassignPartitionsCommand - posted by "Ansel Zandegran (JIRA)" <ji...@apache.org> on 2017/08/25 09:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5789) Deleted topic is recreated when consumer subscribe the deleted one - posted by "Takafumi Saito (JIRA)" <ji...@apache.org> on 2017/08/25 10:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5506) bin/kafka-consumer-groups.sh failing to query offsets - posted by "Pengcheng Huang (JIRA)" <ji...@apache.org> on 2017/08/25 10:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5789) Deleted topic is recreated when consumer subscribe the deleted one - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/25 10:31:02 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4869) 0.10.2.0 release notes incorrectly include KIP-115 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/25 10:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5788) "IllegalArgumentException: long is not a value type" when running ReassignPartitionsCommand - posted by "Ansel Zandegran (JIRA)" <ji...@apache.org> on 2017/08/25 10:51:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-5771) org.apache.kafka.streams.state.internals.Segments#segments method returns incorrect results when segments were added out of order - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/25 13:00:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5295) Allow Kafka Connect source connectors to specify topic-specific settings for new topics - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/25 13:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5790) SocketServer.processNewResponses should not skip a response if exception is thrown - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/25 13:28:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5762) Refactor AdminClient to use LogContext - posted by "Kamal Chandraprakash (JIRA)" <ji...@apache.org> on 2017/08/25 14:42:01 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-1944) Rename LogCleaner and related classes to LogCompactor - posted by "Pranav Maniar (JIRA)" <ji...@apache.org> on 2017/08/25 16:55:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3826) Sampling on throughput / latency metrics recording in Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/25 17:02:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/25 17:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5771) org.apache.kafka.streams.state.internals.Segments#segments method returns incorrect results when segments were added out of order - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/25 17:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4787) KafkaStreams close() is not reentrant - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/25 17:47:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4787) KafkaStreams close() is not reentrant - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/25 17:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4713) Processors cannot call public methods on ProcessorContext from the init method - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/25 17:54:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5788) "IllegalArgumentException: long is not a value type" when running ReassignPartitionsCommand - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/25 18:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4380) Remove CleanShutdownFile as 0.8.2 has been released - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/25 18:08:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4380) Update the usage description of clean shutdown file. - posted by "holdenk (JIRA)" <ji...@apache.org> on 2017/08/25 18:09:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5791) Add HTTPS support to the fault injector - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/25 18:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5790) SocketServer.processNewResponses should not skip a response if exception is thrown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/25 18:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5786) Yet another exception is causing that streamming app is zombie - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/25 18:32:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-5776) Add the Trogdor fault injection daemon - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/08/25 19:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5776) Add the Trogdor fault injection daemon - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/08/25 19:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5494) Idempotent producer should not require max.in.flight.requests.per.connection=1 and acks=all - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/25 19:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4793) Kafka Connect: POST /connectors/(string: name)/restart doesn't start failed tasks - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/25 20:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5452) Aggressive log compaction ratio appears to have no negative effect on log-compacted topics - posted by "Jeff Chao (JIRA)" <ji...@apache.org> on 2017/08/25 20:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/25 21:00:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/25 21:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5649) Producer is being closed generating ssl exception - posted by "Tomasz Sosiński (JIRA)" <ji...@apache.org> on 2017/08/25 21:49:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-5649) Producer is being closed generating ssl exception - posted by "Tomasz Sosiński (JIRA)" <ji...@apache.org> on 2017/08/25 21:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5764) KafkaShortnamer should allow for case inensitive matches - posted by "Ruslan Dautkhanov (JIRA)" <ji...@apache.org> on 2017/08/25 22:24:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5793) Tighten up situations where OutOfOrderSequence may be returned - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 02:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5794) Introduce new idempotence mode to gracefully deal with topics on the older message format - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5795) Make the idempotent producer the default producer setting - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5494) Idempotent producer should not require max.in.flight.requests.per.connection=1 and acks=all - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:07:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5793) Tighten up situations where OutOfOrderSequence may be returned - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5794) Introduce new idempotence mode to gracefully deal with topics on the older message format - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5494) Idempotent producer should not require max.in.flight.requests.per.connection=1 - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5796) Understand performance implications of acks=all and potential ways to reduce it - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5795) Make the idempotent producer the default producer setting - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:12:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5640) Look into making acks=all the default setting - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5796) Understand performance implications of acks=all and potential ways to reduce it - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/26 03:14:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/08/26 06:11:02 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5759) Allow user to specify relative path as log directory - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/08/26 06:11:02 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/08/26 17:55:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/08/26 17:57:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-4906) Support 0.9 brokers with a newer Producer or Consumer version - posted by "Grant Henke (JIRA)" <ji...@apache.org> on 2017/08/26 18:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3916) Connection from controller to broker disconnects - posted by "Aman Choudhary (JIRA)" <ji...@apache.org> on 2017/08/26 20:31:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3916) Connection from controller to broker disconnects - posted by "Aman Choudhary (JIRA)" <ji...@apache.org> on 2017/08/26 20:31:02 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5460) Documentation on website uses word-breaks resulting in confusion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/26 22:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5620) SerializationException in doSend() masks class cast exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/26 23:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5620) SerializationException in doSend() masks class cast exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/26 23:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5797) StoreChangelogReader should be resilient to broker-side metadata not available - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/27 00:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5798) Couldnt connect to mysql using mysql.jdbc driver - posted by "Bubesh Shankar Govindarajan (JIRA)" <ji...@apache.org> on 2017/08/27 01:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4380) Update the usage description of clean shutdown file. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/27 08:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4380) Update the usage description of clean shutdown file. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/27 08:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/27 17:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5797) StoreChangelogReader should be resilient to broker-side metadata not available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/27 18:17:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4793) Kafka Connect: POST /connectors/(string: name)/restart doesn't start failed tasks - posted by "holdenk (JIRA)" <ji...@apache.org> on 2017/08/27 20:51:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down - posted by "holdenk (JIRA)" <ji...@apache.org> on 2017/08/28 00:10:00 UTC, 8 replies.
- [jira] [Created] (KAFKA-5799) New KafkaSpoutConfig(Scheme - posted by "Juhong NamGung (JIRA)" <ji...@apache.org> on 2017/08/28 07:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5799) New KafkaSpoutConfig(Scheme) - posted by "Juhong NamGung (JIRA)" <ji...@apache.org> on 2017/08/28 07:19:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme - posted by "Juhong NamGung (JIRA)" <ji...@apache.org> on 2017/08/28 07:21:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5800) FileAreadyExist when writing tmp Shutdown Server Suddenly - posted by "Ahmed Mohsen (JIRA)" <ji...@apache.org> on 2017/08/28 11:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5800) FileAreadyExist when writing tmp Shutdown Server Suddenly - posted by "Ahmed Mohsen (JIRA)" <ji...@apache.org> on 2017/08/28 11:37:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5788) "IllegalArgumentException: long is not a value type" when running ReassignPartitionsCommand - posted by "Ansel Zandegran (JIRA)" <ji...@apache.org> on 2017/08/28 12:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5801) Use hadoop.security.auth_to_local if available - posted by "Ruslan Dautkhanov (JIRA)" <ji...@apache.org> on 2017/08/28 16:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5764) KafkaShortnamer should allow for case inensitive matches - posted by "Ruslan Dautkhanov (JIRA)" <ji...@apache.org> on 2017/08/28 16:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/28 18:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4915) Don't include "error" in log messages at non-error levels - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/28 19:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5768) Upgrade ducktape version to 0.7.1, and use new kill_java_processes - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/28 22:25:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5803) KafkaProducer should ignore invalid record from ProducerInterceptors - posted by "Yingji Zhang (JIRA)" <ji...@apache.org> on 2017/08/28 23:09:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip - posted by "Yogesh BG (JIRA)" <ji...@apache.org> on 2017/08/29 05:01:13 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5786) Yet another exception is causing that streamming app is zombie - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/29 06:38:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-5790) SocketServer.processNewResponses should not skip a response if exception is thrown - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/29 09:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 09:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 09:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4695) Can't start Kafka server after Blue Screen - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 11:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5804) ChangeLoggingWindowBytesStore needs to retain duplicates when writing to the log - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/29 15:11:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5804) ChangeLoggingWindowBytesStore needs to retain duplicates when writing to the log - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/29 15:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5804) ChangeLoggingWindowBytesStore needs to retain duplicates when writing to the log - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/29 15:21:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "Peter Davis (JIRA)" <ji...@apache.org> on 2017/08/29 16:49:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5805) The console consumer crushes broker on Windows - posted by "Aleksandar (JIRA)" <ji...@apache.org> on 2017/08/29 16:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers - posted by "Peter Davis (JIRA)" <ji...@apache.org> on 2017/08/29 17:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4634) Issue of one kafka brokers not listed in zookeeper - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 19:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4391) On Windows, Kafka server stops with uncaught exception after coming back from sleep - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 19:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5806) Fix transient unit test failure in trogdor coordinator shutdown - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/29 19:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5806) Fix transient unit test failure in trogdor coordinator shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/29 19:34:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5807) NPE on Connector.validate - posted by "Jeremy Custenborder (JIRA)" <ji...@apache.org> on 2017/08/29 19:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1636) High CPU in very active environment - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 19:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2173) Kafka died after throw more error - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 19:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5379) ProcessorContext.appConfigs() should return parsed/validated values - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/29 20:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5379) ProcessorContext.appConfigs() should return parsed/validated values - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/29 20:04:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-1675) bootstrapping tidy-up - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 20:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5786) Yet another exception is causing that streamming app is zombie - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/29 20:27:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5261) Performance improvement of SimpleAclAuthorizer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/29 20:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 20:42:02 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3570) It'd be nice to line up display output in columns in ConsumerGroupCommand - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/29 20:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5779) Single message may exploit application based on KStream - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/29 20:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5769) Transient test failure org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/29 22:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2017/08/29 23:32:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-5768) Upgrade ducktape version to 0.7.1, and use new kill_java_processes - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/29 23:44:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5808) The Preferred Replica should be global and dynamic - posted by "Canes Kelly (JIRA)" <ji...@apache.org> on 2017/08/30 05:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5809) when zookeeper set acl on path /. then kafka can't connect zookeeper - posted by "heping (JIRA)" <ji...@apache.org> on 2017/08/30 06:00:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5809) when zookeeper set acl on path /. then kafka can't connect zookeeper - posted by "heping (JIRA)" <ji...@apache.org> on 2017/08/30 06:30:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions. - posted by "Fredrik Vraalsen (JIRA)" <ji...@apache.org> on 2017/08/30 09:49:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-3514) Stream timestamp computation needs some further thoughts - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/30 09:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5301) Improve exception handling on consumer path - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/30 09:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5499) Double check how we handle exceptions when commits fail - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/30 09:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5302) Improve exception handling on streams client (communication with brokers) - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/30 09:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5569) Document any changes from this task - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/30 10:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5499) Double check how we handle exceptions when commits fail - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/30 10:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5313) Improve exception handling on coordinator interactions - posted by "Eno Thereska (JIRA)" <ji...@apache.org> on 2017/08/30 10:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4297) Cannot Stop Kafka with Shell Script - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 10:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4389) kafka-server.stop.sh not work - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 10:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3039) Temporary loss of leader resulted in log being completely truncated - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2017/08/30 11:07:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5762) Refactor AdminClient to use LogContext - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/30 11:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5762) Refactor AdminClient to use LogContext - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/30 11:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3131) Inappropriate logging level for SSL Problem - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/30 12:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5060) Offset not found while broker is rebuilding its index after an index corruption - posted by "Spiros Ioannou (JIRA)" <ji...@apache.org> on 2017/08/30 12:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5804) ChangeLoggingWindowBytesStore needs to retain duplicates when writing to the log - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/30 12:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3131) Inappropriate logging level for SSL Problem - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/30 12:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5060) Offset not found while broker is rebuilding its index after an index corruption - posted by "Romaric Parmentier (JIRA)" <ji...@apache.org> on 2017/08/30 13:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5810) Improve authentication logging on the broker-side - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/08/30 14:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5797) StoreChangelogReader should be resilient to broker-side metadata not available - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/30 15:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4835) Allow users control over repartitioning - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/30 16:28:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-4835) Allow users control over repartitioning - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/30 16:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5769) Transient test failure org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/30 16:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3894) LogCleaner thread crashes if not even one segment can fit in the offset map - posted by "Nishant Jain (JIRA)" <ji...@apache.org> on 2017/08/30 16:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5763) Refactor NetworkClient to use LogContext - posted by "Kamal Chandraprakash (JIRA)" <ji...@apache.org> on 2017/08/30 17:01:01 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-5763) Refactor NetworkClient to use LogContext - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/30 17:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5787) StoreChangeLogReader needs to restore partitions that were added post initialization - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/30 17:26:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-1980) Console consumer throws OutOfMemoryError with large max-messages - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 17:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-888) problems when shutting down the java consumer . - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 17:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1463) producer fails with scala.tuple error - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 18:12:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1632) No such method error on KafkaStream.head - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 18:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1492) Getting error when sending producer request at the broker end with a single broker - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 18:16:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-270) sync producer / consumer test producing lot of kafka server exceptions & not getting the throughput mentioned here http://incubator.apache.org/kafka/performance.html - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 18:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5786) Yet another exception is causing that streamming app is zombie - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/30 18:57:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4520) Kafka broker fails with not so user-friendly error msg when log.dirs is not set - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/30 19:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/08/30 20:11:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing - posted by "Panos Skianis (JIRA)" <ji...@apache.org> on 2017/08/30 20:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5807) NPE on Connector.validate, - posted by "Jeremy Custenborder (JIRA)" <ji...@apache.org> on 2017/08/30 20:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef - posted by "Jeremy Custenborder (JIRA)" <ji...@apache.org> on 2017/08/30 21:00:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/30 21:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5476) Implement a system test that creates network partitions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/30 21:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5811) Trogdor should handle injecting disk faults - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/08/30 21:30:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5812) Represent logDir with case class where absolute path is required - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/08/30 21:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5812) Represent logDir with case class where absolute path is required - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/30 22:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5494) Idempotent producer should not require max.in.flight.requests.per.connection=1 - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/08/30 22:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5813) Unexpected unclean leader election due to leader/controller's unusual event handling order - posted by "Allen Wang (JIRA)" <ji...@apache.org> on 2017/08/31 01:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5808) The Preferred Replica should be global and dynamic - posted by "Canes Kelly (JIRA)" <ji...@apache.org> on 2017/08/31 02:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11 - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2017/08/31 04:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/31 04:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics - posted by "Jean-Baptiste (JIRA)" <ji...@apache.org> on 2017/08/31 04:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1347) Create a system test for network partitions - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 06:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5642) Use async ZookeeperClient in Controller - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/31 07:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory - posted by "Alexander Petrovsky (JIRA)" <ji...@apache.org> on 2017/08/31 08:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory - posted by "Alexander Petrovsky (JIRA)" <ji...@apache.org> on 2017/08/31 08:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5778) Kafka cluster is not responding when one broker hangs and resulted in too many connections in close_wait in other brokers - posted by "Jungbae Jun (JIRA)" <ji...@apache.org> on 2017/08/31 08:55:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-5779) Single message may exploit application based on KStream - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/31 09:32:01 UTC, 0 replies.
- [jira] [Closed] (KAFKA-5786) Yet another exception is causing that streamming app is zombie - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/08/31 09:32:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5650) Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/31 14:04:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5766) Very high CPU-load of consumer when broker is down - posted by "Sebastian Bernauer (JIRA)" <ji...@apache.org> on 2017/08/31 14:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Anna Shevchenko (JIRA)" <ji...@apache.org> on 2017/08/31 15:07:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Anna Shevchenko (JIRA)" <ji...@apache.org> on 2017/08/31 15:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2105) NullPointerException in client on MetadataRequest - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/08/31 15:46:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-818) Request failure metrics on the Kafka brokers is not instrumented for all requests - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 15:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/08/31 16:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 17:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5815) Add Printed class and KStream#print(Printed) - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/31 17:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5816) Add Produced class and new to and through overloads to KStream - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/31 17:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5816) Add Produced class and new to and through overloads to KStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/31 17:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/31 17:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/08/31 17:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1402) Create unit test helper that stops and starts a cluster - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 17:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1920) Add a metric to count client side errors in BrokerTopicMetrics - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 17:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/31 18:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1138) Remote producer uses the hostname defined in broker - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 18:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-908) Write duplicate messages during broker failure - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 18:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2028) Unable to start the ZK instance after myid file was missing and had to recreate it. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 18:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2343) Clarify KafkaConsumer.poll rebalance behavior - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 19:12:21 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2750) Sender.java: handleProduceResponse does not check protocol version - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 19:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _ - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 19:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2897) Class NIOServerCnxn$Factory not found due to mismatch in dependencies - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 19:32:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2986) Consumer group doesn't lend itself well for slow consumers with varying message size - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 19:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3079) org.apache.kafka.common.KafkaException: java.lang.SecurityException: Configuration Error: - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 19:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3647) Unable to set a ssl provider - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/08/31 20:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/31 20:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5806) Fix transient unit test failure in trogdor coordinator shutdown - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/08/31 20:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/31 20:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5818) Kafka Stream state transitions not correct - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/31 22:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5818) Kafka Stream state transitions not correct - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/31 22:25:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5818) KafkaStreams state transitions not correct - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/08/31 22:40:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5818) KafkaStreams state transitions not correct - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/31 22:46:00 UTC, 1 replies.