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

---

- [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/09/01 00:21:03 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/09/01 00:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/01 02:25:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-4217) KStream.transform equivalent of flatMap - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/01 02:27:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112) - posted by "Genmao Yu (JIRA)" <ji...@apache.org> on 2017/09/01 02:34:00 UTC, 9 replies.
- [jira] [Comment Edited] (KAFKA-4763) Handle disk failure for JBOD (KIP-112) - posted by "Genmao Yu (JIRA)" <ji...@apache.org> on 2017/09/01 02:35:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5818) KafkaStreams state transitions not correct - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/01 03:16:01 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-4188) compilation issues with org.apache.kafka.clients.consumer.internals.Fetcher.java - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/01 05:27: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/09/01 06:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate. - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/09/01 06:10:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4411) broker don't have access to kafka zookeeper nodes - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/01 06:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4337) Create topic in multiple zookeepers with Kafka AdminUtils.CreateTopic JAVA API in Kafka 0.9.0.1 gives Error (Topic gets created in only one of the specified zookeeper) - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/01 07:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4337) Create topic in multiple zookeepers with Kafka AdminUtils.CreateTopic JAVA API in Kafka 0.9.0.1 gives Error (Topic gets created in only one of the specified zookeeper) - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/01 07:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down - posted by "Sebastian Bernauer (JIRA)" <ji...@apache.org> on 2017/09/01 07:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4264) kafka-server-stop.sh fails is Kafka launched via kafka-server-start.sh - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/01 07:36: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/09/01 08:30:00 UTC, 2 replies.
- [jira] [Comment Edited] (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/09/01 08:32:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams - posted by "Jorge Quilcate (JIRA)" <ji...@apache.org> on 2017/09/01 09:13:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5819) Add Joined class and relevant KStream join overloads - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/01 09:46:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5819) Add Joined class and relevant KStream join overloads - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 09:48:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5659) AdminClient#describeConfigs makes an extra empty request when only broker info is requested - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/01 12:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5659) AdminClient#describeConfigs should handle broker future failures correctly - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/01 12:36:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5726) KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener - posted by "Attila Kreiner (JIRA)" <ji...@apache.org> on 2017/09/01 15:20:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5820) Remove unneeded synchronized keyword in StreamThread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/01 15:26:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5820) Remove unneeded synchronized keyword in StreamThread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/01 15:31:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-5785) Always close connection if KafkaChannel.setSend throws exception - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/01 15:36:01 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/09/01 15:36:01 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/09/01 16:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5821) Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/01 16:55:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4860) Kafka batch files does not support path with spaces - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/09/01 18:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5815) Add Printed class and KStream#print(Printed) - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/01 19:22:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5822) Consistent logging of topic partitions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/01 19:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5659) Fix error handling, efficiency issue in AdminClient#describeConfigs - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/09/01 20:54:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5822) Consistent logging of topic partitions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/01 22:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5822) Consistent logging of topic partitions - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/01 23:08:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5823) Update Docs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/02 00:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5824) Cannot write to key value store provided by ProcessorTopologyTestDriver - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2017/09/02 01:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5659) Fix error handling, efficiency issue in AdminClient#describeConfigs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/02 07:57:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5825) Streams not processing when exactly once is set - posted by "Ryan Worsley (JIRA)" <ji...@apache.org> on 2017/09/02 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5825) Streams not processing when exactly once is set - posted by "Ryan Worsley (JIRA)" <ji...@apache.org> on 2017/09/02 16:57:00 UTC, 8 replies.
- [jira] [Commented] (KAFKA-2984) KTable should send old values along with new values to downstreams - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2017/09/03 00:08:03 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5694) Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/03 06:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5694) Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113) - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/09/03 06:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/03 08:03:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/03 08:03:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5826) Transactional Producer needs another way to control transactional expiration - posted by "Canes Kelly (JIRA)" <ji...@apache.org> on 2017/09/03 11:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5826) Transactional Producer needs another way to control transactional expiration - posted by "Canes Kelly (JIRA)" <ji...@apache.org> on 2017/09/03 11:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5827) Allow configuring Kafka sink connectors to start processing records from the end of topics - posted by "Behrang Saeedzadeh (JIRA)" <ji...@apache.org> on 2017/09/03 14:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5828) Allow explicitly setting polling interval for Kafka connectors - posted by "Behrang Saeedzadeh (JIRA)" <ji...@apache.org> on 2017/09/03 14:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5827) Allow configuring Kafka sink connectors to start processing records from the end of topics - posted by "Behrang Saeedzadeh (JIRA)" <ji...@apache.org> on 2017/09/03 14:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/03 16:13:00 UTC, 15 replies.
- [jira] [Comment Edited] (KAFKA-5825) Streams not processing when exactly once is set - posted by "Ryan Worsley (JIRA)" <ji...@apache.org> on 2017/09/03 16:20:02 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5828) Allow explicitly setting polling interval for Kafka connectors - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/03 21:00:02 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5828) Allow explicitly setting polling interval for Kafka connectors - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/03 21:01:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/04 08:29:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/04 08:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/04 08:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 08:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory - posted by "Alexander Petrovsky (JIRA)" <ji...@apache.org> on 2017/09/04 09:53:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-1505) Broker failed to start because of corrupted replication-offset-checkpoint file - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/04 11:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5830) kafka-configs.sh allow to delete all configs for an entity - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2017/09/04 11:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5830) kafka-configs.sh should allow deletion of all configs for an entity - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2017/09/04 11:33:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5831) MemoryRecordsBuilder uses small compression buffer leading to snappy low compression ratio - posted by "fengchaoli (JIRA)" <ji...@apache.org> on 2017/09/04 11:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1962) Restore delayed request metrics - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/04 11:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1946) Fix various broker metrics - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/04 11:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5831) MemoryRecordsBuilder uses small compression buffer leading to snappy low compression ratio - posted by "fengchaoli (JIRA)" <ji...@apache.org> on 2017/09/04 11:47:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5831) MemoryRecordsBuilder uses small compression buffer leading to snappy low compression ratio - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/04 12:11:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3704) Improve mechanism for compression stream block size selection in KafkaProducer - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/04 12:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5515) Consider removing date formatting from Segments class - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/04 12:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5790) SocketServer.processNewResponses should not skip a response if exception is thrown - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/04 12:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5808) The Preferred Replica should be global and dynamic - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/04 12:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5515) Consider removing date formatting from Segments class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 13:17:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory - posted by "Alexander Petrovsky (JIRA)" <ji...@apache.org> on 2017/09/04 13:28:02 UTC, 0 replies.
- [jira] [Closed] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory - posted by "Alexander Petrovsky (JIRA)" <ji...@apache.org> on 2017/09/04 13:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5818) KafkaStreams state transitions not correct - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/04 15:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5832) Add Consumed class and overloads to StreamBuilder - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/04 16:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5832) Add Consumed class and overloads to StreamBuilder - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 16:04:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5830) kafka-configs.sh should allow deletion of all configs for an entity - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/04 16:36:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3532) add principal.builder.class that can extract user from a field - posted by "Daniel Pardo Ligorred (JIRA)" <ji...@apache.org> on 2017/09/04 17:35:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-3532) add principal.builder.class that can extract user from a field - posted by "Daniel Pardo Ligorred (JIRA)" <ji...@apache.org> on 2017/09/04 18:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/04 20:11:01 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5823) Update Docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 00:50:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/05 02:04:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/05 02:25:02 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/05 02:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/05 03:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3532) add principal.builder.class that can extract user from a field - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2017/09/05 04:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5834) AbstractConfig.logUnused() may log confusing warning information. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/09/05 05:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-805) log.append() may fail with a compressed messageset containing no uncompressed messages - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/05 06:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/05 08:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/05 08:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5835) CommitFailedException message is misleading and cause is swallowed - posted by "Stevo Slavic (JIRA)" <ji...@apache.org> on 2017/09/05 08:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/05 09:46:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join - posted by "Lovro Pandžić (JIRA)" <ji...@apache.org> on 2017/09/05 09:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5837) ReassignPartitionsCommand fails if default throttle/timeout used - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/05 15:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5837) ReassignPartitionsCommand fails if default throttle/timeout used - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 16:00:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/05 16:25:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup - posted by "Michael Noll (JIRA)" <ji...@apache.org> on 2017/09/05 16:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5838) Speed up running system tests in docker a bit - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/09/05 18:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5838) Speed up running system tests in docker a bit - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 18:15:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress - posted by "Geoffrey Stewart (JIRA)" <ji...@apache.org> on 2017/09/05 18:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5559) Metrics should throw if two client registers with same ID - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 20:02:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5559) Metrics should throw if two client registers with same ID - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/05 20:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4819) Expose states of active tasks to public API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 21:14:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/05 21:14:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5783) Implement KafkaPrincipalBuilder interface with support for SASL (KIP-189) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 21:28:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing task fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/05 21:35:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/05 22:37:00 UTC, 3 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/09/05 22:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5603) Streams should not abort transaction when closing zombie task - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/05 23:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4860) Kafka batch files does not support path with spaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/05 23:30:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5837) ReassignPartitionsCommand fails if default throttle/timeout used - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/05 23:34:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5839) Upgrade Guide doc changes for KIP-130 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/05 23:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/05 23:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/05 23:52:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions sometimes hangs - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/05 23:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5841) Open old index files with read-only permission - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/06 00:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3856) Cleanup Kafka Streams builder API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/06 00:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5597) Autogenerate Producer sender metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 00:41:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/06 01:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5358) Consumer perf tool should count rebalance time separately - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 02:45:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/06 05:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 05:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4116) Specifying 0.0.0.0 in "listeners" doesn't work - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/06 06:39:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5841) Open old index files with read-only permission - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/06 06:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5841) Open old index files with read-only permission - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 06:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 07:37:00 UTC, 1 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/09/06 09:45:02 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted. - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/09/06 10:29:01 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the new AdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/09/06 12:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the new AdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2017/09/06 13:00:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5844) Add groupBy(KeyValueMapper, Serialized) to KTable - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/06 13:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5844) Add groupBy(KeyValueMapper, Serialized) to KTable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 13:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5545) Kafka Streams not able to successfully restart over new broker ip - posted by "Michael Noll (JIRA)" <ji...@apache.org> on 2017/09/06 16:50:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to brokers which starts very soon after shutdown - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/06 16:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to broker which starts very soon after shutdown - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/06 16:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to brokers which starts very soon after shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 16:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5756) Synchronization issue on flush - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/06 18:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5774) WorkerSinkTask failure exception should include cause - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/06 18:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5756) Synchronization issue on flush - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/06 18:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5741) Prioritize threads in Connect distributed worker process - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/06 18:38:01 UTC, 1 replies.
- [jira] [Created] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/06 20:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5847) Plugin option to filter consumer and producer messages on the broker - posted by "Brian Hawkins (JIRA)" <ji...@apache.org> on 2017/09/06 20:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5848) KafkaConsumer should validate topics/TopicPartitions on subscribe/assign - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/06 21:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/09/06 22:26:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5849) Add partitioned produce consume test - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/09/06 23:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5849) Add partitioned produce consume test - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/09/06 23:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5027) Kafka Controller Redesign - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/06 23:58:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/07 00:35:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5027) Kafka Controller Redesign - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/09/07 01:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5606) Review consumer's RequestFuture usage pattern - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 03:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5848) KafkaConsumer should validate topics/TopicPartitions on subscribe/assign - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/07 03:06:00 UTC, 2 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/09/07 06:38:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5850) Py4JJavaError: An error occurred while calling o40.loadClass. : java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper - posted by "Saurabh Bidwai (JIRA)" <ji...@apache.org> on 2017/09/07 06:50:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5851) CPU overhead to having partitions (even inactive) - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2017/09/07 07:29: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/09/07 07:56:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to broker which starts very soon after shutdown - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/09/07 08:13:01 UTC, 3 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/09/07 08:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5561) Refactor TopicCommand using the new Admin client - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/07 10:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5844) Add groupBy(KeyValueMapper, Serialized) to KTable - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/07 11:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5777) Add ducktape integration for the Trogdor Fault injection daemon - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/07 12:24: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/09/07 12:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5777) Add ducktape integration for the Trogdor Fault injection daemon - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/07 12:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5852) Add filter, filterNot, mapValues and Materialized to KTable - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/07 12:28:01 UTC, 0 replies.
- [jira] [Commented] (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/09/07 12:31:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5852) Add filter, filterNot, mapValues and Materialized to KTable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 12:38:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/07 12:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/07 12:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5561) Refactor TopicCommand to use the Admin client - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/07 12:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/09/07 12:57:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/09/07 12:57:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-5853) Add WindowedKStream interface and implemenation - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/07 14:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5853) Add WindowedKStream interface and implemenation - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/07 14:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5853) Add WindowedKStream interface and implemenation - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/07 14:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4764) Improve diagnostics for SASL authentication failures - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/07 15:00:05 UTC, 2 replies.
- [jira] [Created] (KAFKA-5854) Handle SASL authentication failures as non-retriable exceptions in clients - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/07 15:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3039) Temporary loss of leader resulted in log being completely truncated - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/09/07 15:26:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5855) records-lag is always zero - posted by "Mohsen Zainalpour (JIRA)" <ji...@apache.org> on 2017/09/07 15:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5855) records-lag is always zero - posted by "Mohsen Zainalpour (JIRA)" <ji...@apache.org> on 2017/09/07 16:15:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-5855) records-lag is always zero - posted by "Mohsen Zainalpour (JIRA)" <ji...@apache.org> on 2017/09/07 16:15:01 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5855) records-lag is always zero - posted by "Mohsen Zainalpour (JIRA)" <ji...@apache.org> on 2017/09/07 16:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5853) Add WindowedKStream interface and implemenation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 16:28:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5856) AdminClient should be able to increase number of partitions - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/07 17:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5839) Upgrade Guide doc changes for KIP-130 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/07 17:28:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-1197) Count of bytes or messages of a topic stored in kafka - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 17:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1093) Log.getOffsetsBefore(t, …) does not return the last confirmed offset before t - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 17:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-986) Topic Consumption Across multiple instances of consumer groups - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 17:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-980) Crash during log recovery can cause full recovery to never run - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 18:00:04 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-252) Generalize getOffsetsBefore API to a new more general API getLeaderMetadata - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 18:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-641) ConsumerOffsetChecker breaks when using dns names x.b.com as opposed to raw public IP for broker. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 18:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-47) Create topic support and new ZK data structures for intra-cluster replication - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 18:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 18:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate. - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/09/07 18:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1563) High packet rate between brokers in kafka cluster. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 18:32:01 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/09/07 18:43:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2166) Recreation breaks topic-list - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 18:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only - posted by "Arup Malakar (JIRA)" <ji...@apache.org> on 2017/09/07 18:52:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 19:02:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-2623) Kakfa broker not deleting logs after configured retention time properly - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 19:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2595) Processor thread dies due to an uncaught NoSuchElementException - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 19:33:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2022) simpleconsumer.fetch(req) throws a java.nio.channels.ClosedChannelException: null exception when the original leader fails instead of being trapped in the fetchResponse api while consuming messages - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 19:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2376) Add Kafka Connect metrics - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/07 20:01:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-3113) Kafka simple consumer inconsistent result - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 20:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1993) Enable topic deletion as default - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 20:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4020) Kafka consumer stop taking messages from kafka server - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 20:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4119) Get topic offset with Kafka SSL&ACL - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 20:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4190) kafka-reassign-partitions does not report syntax problem in json - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 20:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4138) Producer data write network traffic to kafka brokers is increased for 50% - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 20:53:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/07 20:57:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3033) Reassigning partition stuck in progress - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/07 21:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3033) Reassigning partition stuck in progress - posted by "Leo Xuzhang Lin (JIRA)" <ji...@apache.org> on 2017/09/07 21:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5657) Connect REST API should include the connector type when describing a connector - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/07 21:32:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5698) Sort processor node based on name suffix in TopologyDescription.toString() - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/07 21:38: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/09/07 22:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5857) Excessive heap usage on controller node during reassignment - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/09/07 22:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5857) Excessive heap usage on controller node during reassignment - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/09/07 22:37:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5657) Connect REST API should include the connector type when describing a connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/07 23:07:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-2376) Add Kafka Connect metrics - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/08 00:08:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5820) Remove unneeded synchronized keyword in StreamThread - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/08 00:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5858) consumer.poll() shouldn't throw exception due to deserialization error - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/09/08 00:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5858) consumer.poll() shouldn't throw exception due to deserialization error - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/09/08 00:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5857) Excessive heap usage on controller node during reassignment - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/08 01:36:00 UTC, 8 replies.
- [jira] [Comment Edited] (KAFKA-5858) consumer.poll() shouldn't throw exception due to deserialization error - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/08 02:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5858) consumer.poll() shouldn't throw exception due to deserialization error - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/08 02:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5499) Double check how we handle exceptions when commits fail - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/08 02:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5239) Producer buffer pool allocates memory inside a lock. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/08 02:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/08 03:08:02 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5832) Add Consumed class and overloads to StreamBuilder - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/08 07:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/08 07:24:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/08 08:24:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4504) Details of retention.bytes property at Topic level are not clear on how they impact partition size - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 08:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1037) switching to gzip compression no error message for missing snappy jar on classpath - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 09:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5850) Py4JJavaError: An error occurred while calling o40.loadClass. : java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 09:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4638) Outdated and misleading link in section "End-to-end Batch Compression" - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 11:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5592) Connection with plain client to SSL-secured broker causes OOM - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 11:15:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2700) delete topic should remove the corresponding ACL and configs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 11:35:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4260) Improve documentation of configuration listeners=PLAINTEXT://0.0.0.0:9092 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 12:13:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified - posted by "Kamal Chandraprakash (JIRA)" <ji...@apache.org> on 2017/09/08 12:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 12:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5656) Support bulk attributes request on KafkaMbean where some attributes do not exist - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 12:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5656) Support bulk attributes request on KafkaMbean where some attributes do not exist - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/08 12:40:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1044) change log4j to slf4j - posted by "Gary Russell (JIRA)" <ji...@apache.org> on 2017/09/08 13:25:01 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5708) Update Jackson dependencies (from 2.8.5 to 2.9.x) - posted by "Dejan Stojadinović (JIRA)" <ji...@apache.org> on 2017/09/08 15:18:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-251) The ConsumerStats MBean's PartOwnerStats attribute is a string - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 15:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5853) Add WindowedKStream interface and implemenation - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/08 15:50:02 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1608) Windows: Error: Could not find or load main class org.apache.zookeeper.server.quorum.QuorumPeerMain - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 16:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1817) AdminUtils.createTopic vs kafka-topics.sh --create with partitions - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 16:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 16:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5860) Prevent non-consecutive partition ids - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/08 16:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2392) Kafka Server does not accept 0 as a port - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/08 17:24: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/09/08 17:41:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5861) KStream stop( withTimeout ) - does not work under load conditions in the multithreaded KStream application - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/08 17:44:01 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/09/08 17:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5708) Update Jackson dependencies (from 2.8.5 to 2.9.x) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 18:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5862) Remove ZK dependency from Streams reset tool - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/08 20:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5862) Remove ZK dependency from Streams reset tool - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/08 20:11:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/08 20:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multithreaded KStream application - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/08 20:50:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multithreaded KStream application - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/08 20:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5852) Add filter, filterNot, mapValues and Materialized to KTable - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/08 21:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5576) Support Power platform by updating rocksdb - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 21:10:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5864) ReplicaFetcherThread.processPartitionData() should throw KafkaStorageException if replica is offline - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/08 21:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5864) ReplicaFetcherThread.processPartitionData() should throw KafkaStorageException if replica is offline - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/08 21:32: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/09/08 22:33:00 UTC, 8 replies.
- [jira] [Comment Edited] (KAFKA-4107) Support offset reset capability in Kafka Connect - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/08 22:33:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5864) ReplicaFetcherThread should not die if there is offline log directory - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/08 23:20:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5864) ReplicaFetcherThread should not die due to replica in offline log directory - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/08 23:20:02 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to broker which starts very soon after shutdown - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/09 00:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5865) Expiring batches with idempotence enabled could cause data loss. - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/09 00:48:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/09 00:56:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4169) Calculation of message size is too conservative for compressed messages - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2017/09/09 01:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/09 07:50:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4793) Kafka Connect: POST /connectors/(string: name)/restart doesn't start failed tasks - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/09 14:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5798) Couldnt connect to mysql using mysql.jdbc driver - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/09 14:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5757) Scheduled or Delayed connector start - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/09 14:33:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/09 14:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/09 16:29:00 UTC, 16 replies.
- [jira] [Commented] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/10 04:08:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5600) Group loading regression causing stale metadata/offsets cache - posted by "Vamsi Subhash Achanta (JIRA)" <ji...@apache.org> on 2017/09/10 12:36:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5866) Let source/sink task to finish their job before exit - posted by "Oleg Kuznetsov (JIRA)" <ji...@apache.org> on 2017/09/10 17:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4113) Allow KTable bootstrap - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/10 18:47:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5301) Improve exception handling on consumer path - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/10 20:19:00 UTC, 7 replies.
- [jira] [Comment Edited] (KAFKA-5301) Improve exception handling on consumer path - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/10 20:20:00 UTC, 9 replies.
- [jira] [Created] (KAFKA-5867) Kafka Connect applications should log info message when starting up - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/10 22:07:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4113) Allow KTable bootstrap - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/11 00:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5301) Improve exception handling on consumer path - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/11 03:01:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/11 07:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5868) Kafka Consumer Rebalancing takes too long - posted by "Nandish Kotadia (JIRA)" <ji...@apache.org> on 2017/09/11 07:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5868) Kafka Consumer Rebalancing takes too long - posted by "Nandish Kotadia (JIRA)" <ji...@apache.org> on 2017/09/11 07:23:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5860) Prevent non-consecutive partition ids - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/11 07:46:01 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (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/09/11 07:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5531) Check exception handling in all streams tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/11 08:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5600) Group loading regression causing stale metadata/offsets cache - posted by "Jan Burkhardt (JIRA)" <ji...@apache.org> on 2017/09/11 08:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5855) records-lag is always zero - posted by "Mohsen Zainalpour (JIRA)" <ji...@apache.org> on 2017/09/11 09:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX - posted by "pranay kumar (JIRA)" <ji...@apache.org> on 2017/09/11 11:08:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4741) Memory leak in RecordAccumulator.append - posted by "Scott Pettyjohn (JIRA)" <ji...@apache.org> on 2017/09/11 13:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5654) Add new API methods to KGroupedStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/11 14:24:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5763) Refactor NetworkClient to use LogContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/11 14:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5763) Refactor NetworkClient to use LogContext - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/11 14:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/11 15:01:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/11 15:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5384) KIP-162: Enable topic deletion by default - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/11 16:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5655) Add new API methods to KGroupedTable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/11 16:32:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/11 18:00:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-4366) KafkaStreams.close() blocks indefinitely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/11 18:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4747) add metrics for KafkaConsumer.poll - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/11 18:16:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5857) Excessive heap usage on controller node during reassignment - posted by "Raoufeh Hashemian (JIRA)" <ji...@apache.org> on 2017/09/11 18:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4747) add metrics for KafkaConsumer.poll - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/09/11 19:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5869) SMT to select Kafka topic based on field in message key or value - posted by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2017/09/11 21:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/11 21:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/11 21:08:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5869) SMT to select Kafka topic based on field in message key or value - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/11 21:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5621) The producer should retry expired batches when retries are enabled - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/11 22:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5797) StoreChangelogReader should be resilient to broker-side metadata not available - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/11 22:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/11 23:08:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/11 23:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5854) Handle SASL authentication failures as non-retriable exceptions in clients - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/12 00:09:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5871) bound the throttle time in byte rate quota - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/09/12 01:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3268) Refactor existing CLI scripts to use KafkaAdminClient - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/12 06:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4928) Add integration test for DumpLogSegments - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/12 07:17:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/12 07:17:04 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4928) Add integration test for DumpLogSegments - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/09/12 07:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2 - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/09/12 07:18:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/12 08:21:00 UTC, 8 replies.
- [jira] [Commented] (KAFKA-5397) streams are not recovering from LockException during rebalancing - posted by "johnchou (JIRA)" <ji...@apache.org> on 2017/09/12 08:58:02 UTC, 2 replies.
- [jira] [Created] (KAFKA-5872) Transient failure in SslSelectorTest.testMuteOnOOM - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/12 09:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5873) Add Materialized overloads to StreamBuilder - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/12 09:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5872) Transient failure in SslSelectorTest.testMuteOnOOM - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/12 10:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5874) Incorrect command line handling - posted by "Viliam Durina (JIRA)" <ji...@apache.org> on 2017/09/12 10:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5874) Incorrect command line handling - posted by "Viliam Durina (JIRA)" <ji...@apache.org> on 2017/09/12 10:37:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1921) Delete offsets for a group with kafka offset storage - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/12 11:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped - posted by "Nandish Kotadia (JIRA)" <ji...@apache.org> on 2017/09/12 12:01:13 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped - posted by "Nandish Kotadia (JIRA)" <ji...@apache.org> on 2017/09/12 12:01:13 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5868) Kafka Consumer Rebalancing takes too long - posted by "Nandish Kotadia (JIRA)" <ji...@apache.org> on 2017/09/12 12:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/12 12:20:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5545) Kafka Streams not able to successfully restart over new broker ip - posted by "Yogesh BG (JIRA)" <ji...@apache.org> on 2017/09/12 13:12:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-1630) ConsumerFetcherThread locked in Tomcat - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/12 13:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1834) No Response when handle LeaderAndIsrRequest some case - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/12 13:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/12 13:52:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5649) Producer is being closed generating ssl exception - posted by "Elliot (JIRA)" <ji...@apache.org> on 2017/09/12 14:04:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5649) Producer is being closed generating ssl exception - posted by "Elliot (JIRA)" <ji...@apache.org> on 2017/09/12 14:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5875) Consumer group repeatedly fails to join, even across JVM restarts: BufferUnderFlowException reading the {{version}} field in the consumer protocol header - posted by "Evan Pollan (JIRA)" <ji...@apache.org> on 2017/09/12 15:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5875) Consumer group repeatedly fails to join, even across JVM restarts: BufferUnderFlowException reading the {{version}} field in the consumer protocol header - posted by "Evan Pollan (JIRA)" <ji...@apache.org> on 2017/09/12 15:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5655) Add new API methods to KGroupedTable - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/12 16:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5873) Add Materialized overloads to StreamBuilder - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/12 16:32:01 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5872) Transient failure in SslSelectorTest.testMuteOnOOM - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/12 16:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5872) Transient failure in SslSelectorTest.testMuteOnOOM - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/12 16:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/12 17:04:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5876) IQ should throw different exceptions for different errors - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/12 17:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5621) The producer should retry expired batches when retries are enabled - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/12 19:09:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/12 21:17:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/12 21:23:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/12 21:26:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-5878) Add sensor for queue size of the controller-event-thread - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/12 22:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/13 00:28:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/13 00:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/13 00:30:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/13 01:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/13 02:18:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck - posted by "Lae (JIRA)" <ji...@apache.org> on 2017/09/13 04:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/13 04:49:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck - posted by "Lae (JIRA)" <ji...@apache.org> on 2017/09/13 05:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5881) Consuming from added partitions without restarting the consumer - posted by "Viliam Durina (JIRA)" <ji...@apache.org> on 2017/09/13 06:02:48 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5881) Consuming from added partitions without restarting the consumer - posted by "Viliam Durina (JIRA)" <ji...@apache.org> on 2017/09/13 06:06:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5882) NullPointerException in ConsumerCoordinator - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/13 06:17:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5882) NullPointerException in ConsumerCoordinator - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/13 06:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5881) Consuming from added partitions without restarting the consumer - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/13 06:38:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-5296) Unable to write to some partitions of newly created topic in 10.2 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/13 10:46:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5177) Automatic creation of topic prompts warnings into console - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/13 12:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4501) Support Java 9 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/13 12:18:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-1354) Failed to load class "org.slf4j.impl.StaticLoggerBinder" - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/13 12:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3124) Update protocol wiki page to reflect latest request/response formats - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/13 12:47:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-5883) Run tests on Java 9 with –illegal-access=deny - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 13:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5076) Remove usage of java.xml.bind.* classes hidden by default in JDK9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 13:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5076) Remove usage of java.xml.bind.* classes hidden by default in JDK9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 13:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5076) Remove usage of java.xml.bind.* classes hidden by default in JDK9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 13:15:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5883) Run tests on Java 9 with –illegal-access=deny - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 13:20:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5884) Enable PowerMock tests when running on Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 13:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4501) Support Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 13:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5884) Enable PowerMock tests when running on Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 13:23:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5885) NPE in ZKClient - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2017/09/13 13:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/13 15:57:01 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/13 16:00:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-5886) Implement KIP-91 - posted by "Sumant Tambe (JIRA)" <ji...@apache.org> on 2017/09/13 17:31:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5887) Enable findBugs (or equivalent) when building with Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 17:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5887) Enable findBugs (or equivalent) when building with Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/13 17:45:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5882) NullPointerException in ConsumerCoordinator - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/13 18:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5885) NPE in ZKClient - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2017/09/13 19:34:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck - posted by "Lae (JIRA)" <ji...@apache.org> on 2017/09/13 20:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5888) Transactions system test should check for message order - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/13 21:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5888) Transactions system test should check for message order - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/13 21:25:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-5882) NullPointerException in StreamTask - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/13 22:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5889) MetricsTest is flaky - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/14 03:02: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/09/14 09:28:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name. - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2017/09/14 13:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5750) Elevate log messages for denials to INFO in SimpleAclAuthorizer class - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/14 14:03:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field - posted by "Artem Plotnikov (JIRA)" <ji...@apache.org> on 2017/09/14 14:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field - posted by "Artem Plotnikov (JIRA)" <ji...@apache.org> on 2017/09/14 14:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/14 14:36:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5892) Connector property override does not work unless setting ALL converter properties - posted by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2017/09/14 15:05:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5892) Connector property override does not work unless setting ALL converter properties - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 15:20:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5892) Connector property override does not work unless setting ALL converter properties - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 15:30:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5893) ResetIntegrationTest fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 17:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5893) ResetIntegrationTest fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 17:13:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-5893) ResetIntegrationTest fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 17:22:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5894) add the notion of max inflight requests to async ZookeeperClient - posted by "Onur Karaman (JIRA)" <ji...@apache.org> on 2017/09/14 17:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5894) add the notion of max inflight requests to async ZookeeperClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 17:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5301) Improve exception handling on consumer path - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 17:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5302) Improve exception handling on streams client (communication with brokers) - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 17:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5313) Improve exception handling on coordinator interactions - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 17:51:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5569) Document any changes from this task - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 17:51:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 18:06:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5895) Update readme to reflect that Gradle 2 is no longer good enough - posted by "Matthias Weßendorf (JIRA)" <ji...@apache.org> on 2017/09/14 18:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5895) Update readme to reflect that Gradle 2 is no longer good enough - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 18:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5895) Gradle 3.0+ is needed on the build - posted by "Matthias Weßendorf (JIRA)" <ji...@apache.org> on 2017/09/14 18:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5896) Kafka Connect task threads never interrupted - posted by "Nick Pillitteri (JIRA)" <ji...@apache.org> on 2017/09/14 18:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5897) The producerId can be reset unnecessarily - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/14 18:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5876) IQ should throw different exceptions for different errors - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 20:04:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5784) Add a sensor for dropped records in window stores - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 20:05:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5660) Don't throw TopologyBuilderException during runtime - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 20:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5660) Don't throw TopologyBuilderException during runtime - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 20:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/14 20:07:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 20:09:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-5158) Options for handling exceptions during processing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 20:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5158) Options for handling exceptions during processing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 20:12:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4932) Add UUID Serde - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 20:14:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade - posted by "Fernando Vega (JIRA)" <ji...@apache.org> on 2017/09/14 20:39:02 UTC, 7 replies.
- [jira] [Updated] (KAFKA-5407) Mirrormaker dont start after upgrade - posted by "Fernando Vega (JIRA)" <ji...@apache.org> on 2017/09/14 20:41:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5407) Mirrormaker dont start after upgrade - posted by "Fernando Vega (JIRA)" <ji...@apache.org> on 2017/09/14 20:43:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/14 21:07:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5898) Client consume more than one time a message - posted by "Cyril WIRTH (JIRA)" <ji...@apache.org> on 2017/09/14 22:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2376) Add Kafka Connect metrics - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 22:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5899) Create Connect metrics for connectors - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 22:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5902) Create Connect metrics for sink tasks - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 22:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5904) Create Connect metrics for worker rebalances - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 22:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5900) Create Connect metrics common to source and sink tasks - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 22:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5901) Create Connect metrics for source tasks - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 22:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5903) Create Connect metrics for workers - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/14 22:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5899) Create Connect metrics for connectors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 22:46: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/09/14 23:10:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5494) Idempotent producer should not require max.in.flight.requests.per.connection=1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/14 23:14:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5905) Remove PrincipalBuilder and DefaultPrincipalBuilder - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/14 23:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5898) Client consume more than one time a message - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/14 23:53:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/15 00:20:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5822) Consistent logging of topic partitions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/15 00:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5793) Tighten up situations where OutOfOrderSequence may be returned - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 01:06:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-5874) Incorrect command line handling - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/15 02:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5874) Incorrect command line handling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 02:17:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5805) The console consumer crushes broker on Windows - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/15 02:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/15 02:59:00 UTC, 14 replies.
- [jira] [Created] (KAFKA-5906) Change metric.reporters configuration key to metrics.reporters to be consistent - posted by "Kevin Lu (JIRA)" <ji...@apache.org> on 2017/09/15 05:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5906) Change metric.reporters configuration key to metrics.reporters to be consistent - posted by "Kevin Lu (JIRA)" <ji...@apache.org> on 2017/09/15 05:51:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5907) Support aggregatedJavadoc in Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/15 07:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5907) Support aggregatedJavadoc in Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/15 07:11:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field - posted by "Artem Plotnikov (JIRA)" <ji...@apache.org> on 2017/09/15 07:59: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/09/15 08:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5908) CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/15 08:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5908) CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 09:06:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5908) CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/15 10:37:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5856) Add AdminClient.createPartitions() - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/15 10:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4454) Authorizer should also include the Principal generated by the PrincipalBuilder. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/15 10:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5856) Add AdminClient.createPartitions() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 11:07:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-3722) PlaintextChannelBuilder should not use ChannelBuilders.createPrincipalBuilder(configs) for creating instance of PrincipalBuilder - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/15 11:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5909) Remove source jars from classpath while executing CLI tools - posted by "Kamal Chandraprakash (JIRA)" <ji...@apache.org> on 2017/09/15 11:17:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5909) Remove source jars from classpath while executing CLI tools - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 11:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5910) Kafka 0.11.0.1 Kafka consumer/producers retries in infinite loop when wrong SASL creds are passed - posted by "Ramkumar (JIRA)" <ji...@apache.org> on 2017/09/15 14:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4190) kafka-reassign-partitions does not report syntax problem in json - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 16:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5910) Kafka 0.11.0.1 Kafka consumer/producers retries in infinite loop when wrong SASL creds are passed - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2017/09/15 16:30:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5854) Handle SASL authentication failures as non-retriable exceptions in clients - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/15 16:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5163) Support replicas movement between log directories (KIP-113) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/15 16:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5911) Avoid creation of extra Map for futures in KafkaAdminClient - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/15 19:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5911) Avoid creation of extra Map for futures in KafkaAdminClient - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/15 19:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5912) Trogdor AgentTest.testAgentActivatesFaults is flaky - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/15 19:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5913) Add RecordMetadataNotAvailableException to indicate that ProduceResponse did not contain offset and timestamp information - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/16 00:53: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/09/16 00:54:00 UTC, 0 replies.
- [jira] [Commented] (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/09/16 00:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5914) Return MessageFormatVersion and MessageMaxBytes in MetadataResponse - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/16 00:59: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/09/16 00:59:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5913) Add RecordMetadataNotAvailableException to indicate that ProduceResponse did not contain offset and timestamp information - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/16 01:18:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5906) Change metric.reporters configuration key to metrics.reporters to be consistent - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/09/16 01:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2376) Add Kafka Connect metrics - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/09/16 01:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name. - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/09/16 01:33:01 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5883) Run tests on Java 9 with –illegal-access=deny - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/16 01:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5915) Support unmapping of mapped/direct buffers in Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/16 01:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5915) Support unmapping of mapped/direct buffers in Java 9 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/16 02:09:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91) - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/16 08:37:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-4801) Transient test failure (part 2): ConsumerBounceTest.testConsumptionWithBrokerFailures - posted by "Armin Braun (JIRA)" <ji...@apache.org> on 2017/09/16 08:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/16 15:38:00 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/16 16:33:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5916) Upgrade rocksdb dependency to 5.7.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/16 16:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5916) Upgrade rocksdb dependency to 5.7.3 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/16 21:32:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5917) Kafka not starting - posted by "Balu (JIRA)" <ji...@apache.org> on 2017/09/17 02:31:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5884) Enable PowerMock tests when running on Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/17 15:14:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5918) Fix minor typos and errors in the Kafka Streams turotial - posted by "Jakub Scholz (JIRA)" <ji...@apache.org> on 2017/09/17 21:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5918) Fix minor typos and errors in the Kafka Streams turotial - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/17 21:28:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5156) Options for handling exceptions in streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/18 00:16:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup - posted by "Julius Žaromskis (JIRA)" <ji...@apache.org> on 2017/09/18 07:22:02 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup - posted by "Julius Žaromskis (JIRA)" <ji...@apache.org> on 2017/09/18 07:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5917) Kafka not starting - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/18 07:35:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-5917) Kafka not starting - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/18 07:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5754) Refactor Streams to use LogContext - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/18 08:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5754) Refactor Streams to use LogContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 08:56:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-5881) Consuming from added partitions without restarting the consumer - posted by "Viliam Durina (JIRA)" <ji...@apache.org> on 2017/09/18 09:00:02 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5881) Consuming from added partitions without restarting the consumer - posted by "Viliam Durina (JIRA)" <ji...@apache.org> on 2017/09/18 09:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5919) Delete records command "version" parameter ignored - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/18 09:43:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5920) Handle SSL authentication failures as non-retriable exceptions in clients - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/18 09:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5919) Delete records command "version" parameter ignored - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 09:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5757) Scheduled or Delayed connector start - posted by "Dhananjay Patkar (JIRA)" <ji...@apache.org> on 2017/09/18 10:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5921) Add Materialized overloads to WindowedKStream - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/18 11:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5921) Add Materialized overloads to WindowedKStream - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/18 11:15:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5921) Add Materialized overloads to WindowedKStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/18 11:28:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4714) Implement remaining KIP-66 SMTs - posted by "Dhananjay Patkar (JIRA)" <ji...@apache.org> on 2017/09/18 11:29:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-4714) Implement remaining KIP-66 SMTs - posted by "Dhananjay Patkar (JIRA)" <ji...@apache.org> on 2017/09/18 11:54:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5922) Add SessionWindowedKStream - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/18 12:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5884) Enable PowerMock tests when running on Java 9 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/18 12:49:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/18 12:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5923) Output generated by kafka_acls, kafka_topics. kafka_topics should be easily usable in a pipe - posted by "Holger Rauch (JIRA)" <ji...@apache.org> on 2017/09/18 14:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5924) Add the compose method to the Kafka Stream API - posted by "Laurent T (JIRA)" <ji...@apache.org> on 2017/09/18 14:34:09 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5873) Add Materialized overloads to StreamBuilder - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/18 14:54:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5925) Adding records deletion operation to the new Admin Client API - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/18 16:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5924) Add the compose method to the Kafka Stream API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/18 17:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5825) Streams not processing when exactly once is set - posted by "Ryan Worsley (JIRA)" <ji...@apache.org> on 2017/09/18 20:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5926) --force option is ginored by kafka-configs and kafka-topics tools - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2017/09/18 20:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level - posted by "Shrijeet Paliwal (JIRA)" <ji...@apache.org> on 2017/09/18 22:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5195) Endless NotLeaderForPartitionException for ReplicaFetcherThread - posted by "Alexey Pervushin (JIRA)" <ji...@apache.org> on 2017/09/18 22:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5195) Endless NotLeaderForPartitionException for ReplicaFetcherThread - posted by "Alexey Pervushin (JIRA)" <ji...@apache.org> on 2017/09/18 22:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5927) Capitalise topicPurgatory Name - posted by "Chetna Chaudhari (JIRA)" <ji...@apache.org> on 2017/09/18 23:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5927) Capitalise topicPurgatory Name - posted by "Chetna Chaudhari (JIRA)" <ji...@apache.org> on 2017/09/18 23:45:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-5918) Fix minor typos and errors in the Kafka Streams turotial - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/18 23:59:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5918) Fix minor typos and errors in the Kafka Streams turotial - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/19 00:01:37 UTC, 0 replies.
- [jira] [Created] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition - posted by "Genmao Yu (JIRA)" <ji...@apache.org> on 2017/09/19 03:01:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5928) Avoid redundant requests to zookeeper when reassign topic partition - posted by "Genmao Yu (JIRA)" <ji...@apache.org> on 2017/09/19 03:05:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5926) --force option is ginored by kafka-configs and kafka-topics tools - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/19 03:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5917) Kafka not starting - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/19 05:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5914) Return MessageFormatVersion and MessageMaxBytes in MetadataResponse - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 06:10:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5867) Kafka Connect applications should log info message when starting up - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2017/09/19 07:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5929) Save pre-assignment to file to avoid too long text to display when do topic partition reassign - posted by "Genmao Yu (JIRA)" <ji...@apache.org> on 2017/09/19 07:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5929) Save pre-assignment to file to avoid too long text to display when do topic partition reassign - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 07:42:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-4932) Add UUID Serde - posted by "Jakub Scholz (JIRA)" <ji...@apache.org> on 2017/09/19 07:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4320) Log compaction docs update - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 09:37:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-3700) CRL support - posted by "Antony Stubbs (JIRA)" <ji...@apache.org> on 2017/09/19 10:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5930) Decide on consistent method for determining elapsed time. - posted by "Koen De Groote (JIRA)" <ji...@apache.org> on 2017/09/19 10:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5922) Add SessionWindowedKStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 11:05:02 UTC, 1 replies.
- [jira] [Created] (KAFKA-5931) Deprecate KTable#to and KTable#through - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/19 11:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5931) Deprecate KTable#to and KTable#through - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 11:38:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5932) Avoid call fetchPrevious in FlushListeners - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/19 13:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 16:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5163) Support replicas movement between log directories (KIP-113) - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/19 17:12:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/19 17:15:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/19 17:25:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 17:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 17:32:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5397) streams are not recovering from LockException during rebalancing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 17:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5397) streams are not recovering from LockException during rebalancing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 17:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5735) Client-ids are not handled consistently by clients and broker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 18:01:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5862) Remove ZK dependency from Streams reset tool - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 18:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5932) Avoid call fetchPrevious in FlushListeners - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/09/19 18:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5784) Add a sensor for dropped records in window stores - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/09/19 18:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 18:26:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/19 18:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5933) Move timeout and validate_only protocol fields into CommonFields class - posted by "Jakub Scholz (JIRA)" <ji...@apache.org> on 2017/09/19 19:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5933) Move timeout and validate_only protocol fields into CommonFields class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 19:15:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5934) Cross build for scala 2.12 - posted by "Srdan Srepfler (JIRA)" <ji...@apache.org> on 2017/09/19 19:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5935) Kafka connect should provide configurable CONNECTOR_EXCLUDES - posted by "Chen He (JIRA)" <ji...@apache.org> on 2017/09/19 20:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5935) Kafka connect should provide configurable CONNECTOR_EXCLUDES - posted by "Chen He (JIRA)" <ji...@apache.org> on 2017/09/19 20:36:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 22:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/19 22:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5937) Improve ProcessorStateManager exception handling - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 23:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5937) Improve ProcessorStateManager exception handling - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/19 23:26:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5914) Return MessageFormatVersion and MessageMaxBytes in MetadataResponse - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/19 23:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5937) Improve ProcessorStateManager exception handling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 00:04:00 UTC, 1 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/09/20 01:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/20 01:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-242) Subsequent calls of ConsumerConnector.createMessageStreams cause Consumer offset to be incorrect - posted by "ylzhang (JIRA)" <ji...@apache.org> on 2017/09/20 06:51:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5920) Handle SSL authentication failures as non-retriable exceptions in clients - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 08:34:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5938) Oracle jdbc-source-connector with kafka-connect distributed mode will result in http 500 error - posted by "Wolfgang Clemens (JIRA)" <ji...@apache.org> on 2017/09/20 08:52: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/09/20 09:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5939) Add a dryrun option to release.py - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/20 09:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5939) Add a dryrun option to release.py - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/20 09:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5940) kafka-delete-records.sh doesn't give any feedback when the JSON offset configuration file is invalid - posted by "Jakub Scholz (JIRA)" <ji...@apache.org> on 2017/09/20 11:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3726) Enable cold storage option - posted by "Satya (JIRA)" <ji...@apache.org> on 2017/09/20 11:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5931) Deprecate KTable#to and KTable#through - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/20 11:06:00 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/09/20 11:14:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5941) Handle authentication failures in connect - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/20 12:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5942) Handle authentication failures in streams - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/20 12:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5941) Handle authentication failures in connect - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/20 12:58:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5942) Handle authentication failures in streams - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/20 12:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5943) Reduce dependency on mock in connector tests - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/20 15:09:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5358) Consumer perf tool should count rebalance time separately - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/20 16:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5547) Return topic authorization failed if no topic describe access - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 17:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5944) Add unit tests for handling of authentication failures in clients - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/20 18:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5945) Improve handling of authentication failures when credentials are removed - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/20 18:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5945) Improve handling of authentication failures when credentials are removed - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/20 18:47:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5945) Improve handling of authentication failures when credentials are removed - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/20 18:51:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-5946) Give connector method parameter better name - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/20 19:08:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5489) Failing test: InternalTopicIntegrationTest.shouldCompactTopicsForStateChangelogs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/20 19:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5939) Add a dryrun option to release.py - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/09/20 20:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5926) --force option is ignored by kafka-configs and kafka-topics tools - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/09/20 20:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5657) Connect REST API should include the connector type when describing a connector - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/20 21:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5911) Avoid creation of extra Map for futures in KafkaAdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 21:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5934) Cross build for scala 2.12 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 21:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5947) Handle authentication failures from transactional producer and KafkaAdminClient - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/20 21:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5948) EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/20 22:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5862) Remove ZK dependency from Streams reset tool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 22:10:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5947) Handle authentication failures from transactional producer and KafkaAdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/20 23:18:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/20 23:23:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5949) User Callback Exceptions need to be handled properly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/20 23:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5950) AdminClient should retry based on returned error codes - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/20 23:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5950) AdminClient should retry based on returned error codes - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/20 23:54:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/09/21 06:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/09/21 06:44:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/09/21 06:54:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5952) Refactor Consumer Fetcher metrics - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/09/21 06:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5922) Add SessionWindowedKStream - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/21 08:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers - posted by "Jiri Pechanec (JIRA)" <ji...@apache.org> on 2017/09/21 08:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers - posted by "Jiri Pechanec (JIRA)" <ji...@apache.org> on 2017/09/21 09:19:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers - posted by "Jiri Pechanec (JIRA)" <ji...@apache.org> on 2017/09/21 09:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5867) Kafka Connect applications should log info message when starting up - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 11:48:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91) - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/21 12:52:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-5947) Handle authentication failures from transactional producer and KafkaAdminClient - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/21 13:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5954) Failure in Connect system test: ConnectRestApiTest - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/21 13:47:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5954) Failure in Connect system test: ConnectRestApiTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 14:40:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/21 16:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/21 16:27:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/21 18:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5956) StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/21 18:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5956) StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 18:28:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2167) ZkUtils updateEphemeralPath JavaDoc (spelling and correctness) - posted by "Andy Chambers (JIRA)" <ji...@apache.org> on 2017/09/21 20:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion() - posted by "Andy Chambers (JIRA)" <ji...@apache.org> on 2017/09/21 20:32:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5949) User Callback Exceptions need to be handled properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 21:19:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-5949) User Callback Exceptions need to be handled properly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/21 21:19:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/21 23:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/21 23:40:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-3999) Consumer bytes-fetched metric uses decompressed message size - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/21 23:58:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 00:20:03 UTC, 1 replies.
- [jira] [Created] (KAFKA-5958) User StoreListener not available for global stores - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/22 00:38:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-5959) NPE in NetworkClient - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2017/09/22 00:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/22 02:16:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/22 02:22:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/22 02:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5821) Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/22 02:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5330) Use per-task converters in Connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/22 03:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5330) Use per-task converters in Connect - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 03:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset) - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/22 03:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5657) Connect REST API should include the connector type when describing a connector - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/22 04:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5061) client.id should be set for Connect producers/consumers - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2017/09/22 05:21:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 07:15:02 UTC, 3 replies.
- [jira] [Created] (KAFKA-5961) NullPointerException when restore messages with null key. - posted by "Andres Gomez Ferrer (JIRA)" <ji...@apache.org> on 2017/09/22 07:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5961) NullPointerException when consumer restore read messages with null key. - posted by "Andres Gomez Ferrer (JIRA)" <ji...@apache.org> on 2017/09/22 07:18:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5962) java.io.IOException: Map failed - posted by "Mehmet Soner (JIRA)" <ji...@apache.org> on 2017/09/22 07:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5962) java.io.IOException: Map failed - posted by "Mehmet Soner (JIRA)" <ji...@apache.org> on 2017/09/22 07:33:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 10:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5910) Kafka 0.11.0.1 Kafka consumer/producers retries in infinite loop when wrong SASL creds are passed - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/22 11:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5015) SASL/SCRAM authentication failures are hidden - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/22 11:37:04 UTC, 0 replies.
- [jira] [Created] (KAFKA-5963) Null Pointer Exception on server - posted by "Mudit Garg (JIRA)" <ji...@apache.org> on 2017/09/22 12:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5963) Null Pointer Exception on server - posted by "Mudit Garg (JIRA)" <ji...@apache.org> on 2017/09/22 12:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5956) StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/22 12:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5926) --force option is ignored by kafka-configs and kafka-topics tools - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2017/09/22 13:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5954) Failure in Connect system test: ConnectRestApiTest - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/22 13:41:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5964) Add more unit tests for SslTransportLayer - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/22 16:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5938) Oracle jdbc-source-connector with kafka-connect distributed mode will result in http 500 error - posted by "Robin Moffatt (JIRA)" <ji...@apache.org> on 2017/09/22 16:59:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-5840) TransactionsTest#testBasicTransactions sometimes hangs - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/22 17:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5959) NPE in NetworkClient - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/22 18:12:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5959) NPE in NetworkClient - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/22 18:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5959) NPE in NetworkClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 19:02:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/09/22 19:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5896) Kafka Connect task threads never interrupted - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/22 20:00:06 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/22 20:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5518) General Kafka connector performanc workload - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/22 20:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5959) NPE in NetworkClient - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/09/22 20:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5889) MetricsTest is flaky - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/22 20:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/22 20:14:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5966) Support ByteBuffer serialization in Kafka Streams - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2017/09/22 20:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5920) Handle SSL authentication failures as non-retriable exceptions in clients - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/22 21:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5961) NullPointerException when consumer restore read messages with null key. - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/22 22:10:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5944) Add unit tests for handling of authentication failures in clients - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/09/23 01:29:02 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5862) Remove ZK dependency from Streams reset tool - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:20:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4423) Drop support for Java 7 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:09 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5944) Add unit tests for handling of authentication failures in clients - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5902) Create Connect metrics for sink tasks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:12 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5682) Consumer should include partition in exceptions raised during record parsing/validation - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5661) Develop and understanding of how to tune transactions for optimal performance - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4641) Improve test coverage of StreamsThread - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4640) Improve Streams unit test coverage - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5900) Create Connect metrics common to source and sink tasks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5720) In Jenkins, kafka.api.SaslSslAdminClientIntegrationTest failed with org.apache.kafka.common.errors.TimeoutException - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5327) Console Consumer should only poll for up to max messages - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5204) Connect needs to validate Connector type during instantiation - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1894) Avoid long or infinite blocking in the consumer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5509) add gradle option for building tarball with test jars - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:14 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:14 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:14 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:14 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4696) Streams standby task assignment should be state-store aware - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:14 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5748) Fix console producer to set timestamp and partition - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:14 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5606) Review consumer's RequestFuture usage pattern - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4345) Run ducktape test for each pull request - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5547) Return topic authorization failed if no topic describe access - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5964) Add more unit tests for SslTransportLayer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5524) Streams systems tests should be with EoS - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5219) Move transaction expiration logic and scheduling to the Transaction Manager - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1326) New consumer checklist - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5356) Producer with transactionalId should be able to send outside of a transaction - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4730) Streams does not have an in-memory windowed store - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5795) Make the idempotent producer the default producer setting - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3986) completedReceives can contain closed channels - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4875) Kafka Streams: topic groups and builder.stream API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5865) Expiring batches with idempotence enabled could cause data loss. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5284) Add tools and metrics to diagnose problems with the idempotent producer and transactions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5025) FetchRequestTest should use batches with more than one message - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion() - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4487) Tests should be run in Jenkins with INFO or DEBUG level - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5234) GetOffsetShell: retrieve offsets for multiple topics with single request - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5729) Consumer should verify offset commits are from assigned partitions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:17 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5527) Idempotent/transactional Producer part 2 (KIP-98) - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:18 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/09/23 04:28:18 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 "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5030) Suggested clean-ups from message format V2 review - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5022) Improve CRC tests so that we verify which fields are included in the CRC - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4934) Add streams test with RocksDb failures - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5286) Producer should await transaction completion in close - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:18 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4904) Performance of RocksDb with state record cache - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3135) Unexpected delay before fetch response transmission - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5533) Timestamp-based log compaction - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5451) Kafka Connect should scan classpath asynchronously - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5383) Additional Test Cases for ReplicaManager - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1120) Controller could miss a broker state change - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2334) Prevent HW from going back during leader failover - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4628) Support KTable/GlobalKTable Joins - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5023) Remove cyclic dependency between record and protocol packages - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5782) Avoid unnecessary PID reset when expire batches. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4651) Improve test coverage of Stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5270) TransactionManager should send and `AddOffsetsToTxn` request only once per group per transaction - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5493) Optimize calls to flush for tasks and standby tasks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1548) Refactor the "replica_id" in requests - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 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/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5347) OutOfSequence error should be fatal - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4693) Consumer subscription change during rebalance causes exception - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5834) AbstractConfig.logUnused() may log confusing warning information. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5631) Use Jackson for serialising to JSON - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5478) TransactionsTest.testFencingOnAddPartitions Timeout - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5901) Create Connect metrics for source tasks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:19 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5255) Auto generate request/response classes - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:20 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:20 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5903) Create Connect metrics for workers - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:20 UTC, 2 replies.
- [jira] [Updated] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3143) inconsistent state in ZK when all replicas are dead - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5480) Partition Leader may not be elected although there is one live replica in ISR - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5904) Create Connect metrics for worker rebalances - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:21 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5780) Long shutdown time when updated to 0.11.0 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5482) A CONCURRENT_TRANASCTIONS error for the first AddPartitionsToTxn request slows down transactions significantly - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5041) Kafka TestKit library - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:28:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3186) KIP-50: Move Authorizer and related classes to separate package. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:42:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3514) Stream timestamp computation needs some further thoughts - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4218) Enable access to key in ValueTransformer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5228) Revisit Streams DSL JavaDocs - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4416) Add a '--group' option to the console consumer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5403) Transactions system test should dedup consumed messages by offset - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send() - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3247) kafka-topic tool can use an option to see just "unbalanced partitions" - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5576) Support Power platform by updating rocksdb - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3252) compression type for a topic should be used during log compaction - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3436) Speed up controlled shutdown. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:04 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:05 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5217) Improve Streams internal exception handling - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3999) Consumer bytes-fetched metric uses decompressed message size - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4850) RocksDb cannot use Bloom Filters - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3331) Refactor TopicCommand to make it testable and add unit tests - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5214) Re-add KafkaAdminClient#apiVersions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3186) KIP-50: Move Authorizer and related classes to separate package. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer) - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4126) No relevant log when the topic is non-existent - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3733) Avoid long command lines by setting CLASSPATH in environment - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5185) Adding the RecordMetadata that is returned by the producer to the commitRecord method for SourceTask - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3300) Calculate the initial/max size of offset index files and reduce the memory footprint for memory mapped index files. - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:06 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5746) Add new metrics to support health checks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5499) Double check how we handle exceptions when commits fail - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5123) Refactor ZkUtils readData* methods - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3465) kafka.tools.ConsumerOffsetChecker won't align with kafka New Consumer mode - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4201) Add an --assignment-strategy option to new-consumer-based Mirror Maker - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5637) Document compatibility and release policies - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4440) Make producer RecordMetadata non-final - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5313) Improve exception handling on coordinator interactions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-2435) More optimally balanced partition assignment strategy - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133) - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:07 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5679) Add logging to distinguish between internally and externally initiated shutdown of Kafka - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4108) Improve DumpLogSegments offsets-decoder output format - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5272) Improve validation for Alter Configs (KIP-133) - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5302) Improve exception handling on streams client (communication with brokers) - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5569) Document any changes from this task - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4307) Inconsistent parameters between console producer and consumer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3096) Leader is not set to -1 when it is shutdown if followers are down - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4928) Add integration test for DumpLogSegments - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:49:08 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5359) Exceptions from RequestFuture lack parts of the stack trace - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:50:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4333) Report consumer group coordinator id when '--list' option is used - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:50:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:50:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5495) Replace the deprecated 'ConsumerOffsetChecker' in documentation - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5156) Options for handling exceptions in streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:50:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5759) Allow user to specify relative path as log directory - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/23 04:50:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time - posted by "Pengwei (JIRA)" <ji...@apache.org> on 2017/09/23 05:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper - posted by "Nick Travers (JIRA)" <ji...@apache.org> on 2017/09/23 17:15:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5966) Support ByteBuffer serialization in Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/24 01:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/09/24 02:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/24 08:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5758) Reassigning a topic's partitions can adversely impact other topics - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/24 08:11:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup - posted by "fangjinuo (JIRA)" <ji...@apache.org> on 2017/09/24 09:59:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/24 17:46:01 UTC, 6 replies.
- [jira] [Commented] (KAFKA-5581) Streams can be smarter in deciding when to create changelog topics for state stores - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2017/09/24 20:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5958) User StoreListener not available for global stores - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/24 22:26:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/24 23:06:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5958) User StoreListener not available for global stores - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/24 23:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5217) Improve Streams internal exception handling - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/25 01:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5499) Double check how we handle exceptions when commits fail - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/25 01:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/25 01:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 01:30:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/09/25 02:13:00 UTC, 11 replies.
- [jira] [Created] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/25 03:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/25 05:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/25 05:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5919) Delete records command "version" parameter ignored - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/25 05:42:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/25 07:01:15 UTC, 0 replies.
- [jira] [Closed] (KAFKA-5686) Documentation inconsistency on the "Compression" - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/09/25 07:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5445) Document exceptions thrown by AdminClient methods - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/09/25 07:47:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5445) Document exceptions thrown by AdminClient methods - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2017/09/25 07:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4440) Make producer RecordMetadata non-final - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 08:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5517) Support linking to particular configuration parameters - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/25 08:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4931) stop script fails due 4096 ps output limit - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/25 08:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4249) Document how to customize GC logging options for broker - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/25 08:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5933) Move timeout and validate_only protocol fields into CommonFields class - posted by "Jakub Scholz (JIRA)" <ji...@apache.org> on 2017/09/25 08:41:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5968) Remove all broker metrics during shutdown - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/25 08:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3575) Use console consumer access topic that does not exist, can not use "Control + C" to exit process - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/25 08:57:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5601) Refactor ReassignPartitionsCommand to use AdminClient - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/25 08:58:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-5969) bin/kafka-preferred-replica-election.sh gives misleading error when invalid JSON file is passed as parameter - posted by "Jakub Scholz (JIRA)" <ji...@apache.org> on 2017/09/25 09:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5969) bin/kafka-preferred-replica-election.sh gives misleading error when invalid JSON file is passed as parameter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 09:14:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/09/25 10:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/25 10:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2017/09/25 11:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 11:50:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-2544) Replication tools wiki page needs to be updated - posted by "Jakub Scholz (JIRA)" <ji...@apache.org> on 2017/09/25 12:05:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-2544) Replication tools wiki page needs to be updated - posted by "Jakub Scholz (JIRA)" <ji...@apache.org> on 2017/09/25 12:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5958) User StoreListener not available for global stores - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/09/25 14:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3465) kafka.tools.ConsumerOffsetChecker won't align with kafka New Consumer mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 15:10:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group - posted by "Peter Davis (JIRA)" <ji...@apache.org> on 2017/09/25 15:10:02 UTC, 0 replies.
- [jira] [Closed] (KAFKA-3465) kafka.tools.ConsumerOffsetChecker won't align with kafka New Consumer mode - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/09/25 15:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5489) Failing test: InternalTopicIntegrationTest.shouldCompactTopicsForStateChangelogs - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/25 15:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5297) Broker can take a long time to shut down if there are many active log segments - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/25 16:22:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5971) Broker keeps running even though not registered in ZK - posted by "Igor Canadi (JIRA)" <ji...@apache.org> on 2017/09/25 18:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5888) Transactions system test should check for message order - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/25 18:35:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries() - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/25 18:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5972) Flatten SMT does not work with null values - posted by "Tomas Zuklys (JIRA)" <ji...@apache.org> on 2017/09/25 19:29:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5972) Flatten SMT does not work with null values - posted by "Tomas Zuklys (JIRA)" <ji...@apache.org> on 2017/09/25 19:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5901) Create Connect metrics for source tasks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/25 19:39:01 UTC, 1 replies.
- [jira] [Created] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure - posted by "Tom Crayford (JIRA)" <ji...@apache.org> on 2017/09/25 20:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/25 20:18:00 UTC, 11 replies.
- [jira] [Updated] (KAFKA-5968) Remove all broker metrics during shutdown - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/25 20:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5900) Create Connect metrics common to source and sink tasks - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/25 22:01:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/25 23:26:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-5974) Removed unused parameter in public interface - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/25 23:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/25 23:39:02 UTC, 2 replies.
- [jira] [Updated] (KAFKA-5974) Removed unused parameter ProcessorContext - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/25 23:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5865) Expiring batches with idempotence enabled could cause data loss. - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/26 00:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false - posted by "Mario Molina (JIRA)" <ji...@apache.org> on 2017/09/26 02:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 02:13:00 UTC, 2 replies.
- [jira] [Reopened] (KAFKA-5588) ConsoleConsumer : uselss --new-consumer option - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/26 07:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5588) ConsoleConsumer : Remove deprecated new-consumer option for tools - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/26 07:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 07:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5588) Remove deprecated new-consumer option for tools - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/26 07:11:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/26 07:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5765) Move merge() from StreamsBuilder to KStream - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/26 08:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/26 09:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 09:13:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version - posted by "Stevo Slavic (JIRA)" <ji...@apache.org> on 2017/09/26 09:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable one - posted by "Stevo Slavic (JIRA)" <ji...@apache.org> on 2017/09/26 09:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/09/26 09:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version - posted by "Stevo Slavic (JIRA)" <ji...@apache.org> on 2017/09/26 09:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5978) Transient failure in SslTransportLayerTest.testNetworkThreadTimeRecorded - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/26 13:16:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5968) Remove all broker metrics during shutdown - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/26 13:19:00 UTC, 3 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/09/26 14:13:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5944) Add unit tests for handling of authentication failures in clients - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/26 20:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5979) kip-120 changed internal streams topic naming - posted by "dan norwood (JIRA)" <ji...@apache.org> on 2017/09/26 21:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5979) kip-120 changed internal streams topic naming - posted by "dan norwood (JIRA)" <ji...@apache.org> on 2017/09/26 21:06:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-5980) FailOnInvalidTimestamp does not log error - posted by "Michael Rylander (JIRA)" <ji...@apache.org> on 2017/09/27 00:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5980) FailOnInvalidTimestamp does not log error - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/27 00:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5980) FailOnInvalidTimestamp does not log error - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/27 00:38:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5980) FailOnInvalidTimestamp does not log error - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 00:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5979) kip-120 changed internal streams topic naming - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/27 00:41:04 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5952) Refactor Consumer Fetcher metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 02:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5900) Create Connect metrics common to source and sink tasks - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/27 05:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/27 06:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5981) Update the affected versions on bug KAFKA-1194 - posted by "Amund Gjersøe (JIRA)" <ji...@apache.org> on 2017/09/27 08:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir - posted by "Marc Cortinas (JIRA)" <ji...@apache.org> on 2017/09/27 09:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir - posted by "Marc Cortinas (JIRA)" <ji...@apache.org> on 2017/09/27 09:25:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5983) Cannot mirror Avro-encoded data using the Apache Kafka MirrorMaker - posted by "Giulio Vito de Musso (JIRA)" <ji...@apache.org> on 2017/09/27 13:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5750) Elevate log messages for denials to INFO in SimpleAclAuthorizer class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 15:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5950) AdminClient should retry based on returned error codes - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/27 15:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5445) Document exceptions thrown by AdminClient methods - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/27 15:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4632) Kafka Connect WorkerSinkTask.closePartitions doesn't handle WakeupException - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/27 15:54:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/27 16:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5902) Create Connect metrics for sink tasks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 17:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/27 17:41:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/27 17:50:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-5369) Producer hangs on metadata fetch from broker in security authorization related failures and no meaningful exception is thrown - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/27 18:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5932) Avoid call fetchPrevious in FlushListeners - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/27 20:29:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/27 23:26:00 UTC, 7 replies.
- [jira] [Updated] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/27 23:27:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5979) kip-120 changed internal streams topic naming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 00:22:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5913) Add `hasOffset` and `hasTimestamp` methods to RecordMetadata to indicate whether metadata is available - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/28 00:32:00 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-903) [0.8.0 - windows] FATAL - [highwatermark-checkpoint-thread1] (Logging.scala:109) - Attempt to swap the new high watermark file with the old one failed - posted by "Sean Glover (JIRA)" <ji...@apache.org> on 2017/09/28 01:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5984) API changes review for Kafka - posted by "Andrey Ponomarenko (JIRA)" <ji...@apache.org> on 2017/09/28 05:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5985) Mention the need to close store iterators - posted by "Stanislav Chizhov (JIRA)" <ji...@apache.org> on 2017/09/28 09:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5985) Mention the need to close store iterators - posted by "Stanislav Chizhov (JIRA)" <ji...@apache.org> on 2017/09/28 09:19:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-5961) NullPointerException when consumer restore read messages with null key. - posted by "Andres Gomez Ferrer (JIRA)" <ji...@apache.org> on 2017/09/28 09:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/28 10:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/28 10:52:03 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5153) KAFKA Cluster : 0.10.2.0 : Servers Getting disconnected : Service Impacting - posted by "Sandeep Kale (JIRA)" <ji...@apache.org> on 2017/09/28 10:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3986) completedReceives can contain closed channels - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/28 11:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3986) completedReceives can contain closed channels - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/28 11:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5347) OutOfSequence error should be fatal - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/28 11:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5986) Streams State Restoration never completes when logging is disabled - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/09/28 11:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5986) Streams State Restoration never completes when logging is disabled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 12:15:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request - posted by "Sean Glover (JIRA)" <ji...@apache.org> on 2017/09/28 16:34:02 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5901) Create Connect metrics for source tasks - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/09/28 16:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries() - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2017/09/28 18:28:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-5987) Kafka metrics templates used in document generation should maintain order of tags - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/28 19:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5987) Kafka metrics templates used in document generation should maintain order of tags - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 20:13:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5562) Do streams state directory cleanup on a single thread - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/28 20:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails - posted by "Apurva Mehta (JIRA)" <ji...@apache.org> on 2017/09/28 21:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5746) Add new metrics to support health checks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 21:02:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-5988) Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/28 21:14:05 UTC, 0 replies.
- [jira] [Created] (KAFKA-5989) disableLogging() causes an initialization loop - posted by "Tuan Nguyen (JIRA)" <ji...@apache.org> on 2017/09/28 21:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5990) Add generated documentation for Connect metrics - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/09/28 22:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name - posted by "Kevin Lu (JIRA)" <ji...@apache.org> on 2017/09/28 22:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name - posted by "Kevin Lu (JIRA)" <ji...@apache.org> on 2017/09/28 22:53:00 UTC, 11 replies.
- [jira] [Commented] (KAFKA-2359) New consumer - partitions auto assigned only on poll - posted by "Nick West (JIRA)" <ji...@apache.org> on 2017/09/28 23:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5990) Add generated documentation for Connect metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/28 23:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5989) disableLogging() causes an initialization loop - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/09/29 00:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5565) Add a broker metric specifying the number of consumer group rebalances in progress - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/29 03:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5992) Better Java Documentation for AdminClient Exceptions - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2017/09/29 04:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5993) Kafka AdminClient does not support standard security settings - posted by "Stephane Maarek (JIRA)" <ji...@apache.org> on 2017/09/29 04:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4883) invalid client sasl.jaas.config triggers NullPointerException - posted by "Jorge Machado (JIRA)" <ji...@apache.org> on 2017/09/29 07:00:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5993) Kafka AdminClient does not support standard security settings - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/29 07:14:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-5992) Better Java Documentation for AdminClient Exceptions - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/29 07:15:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5445) Document exceptions thrown by AdminClient methods - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/29 07:15:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5968) Remove all broker metrics during shutdown - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/09/29 09:00:37 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir - posted by "Marc Cortinas (JIRA)" <ji...@apache.org> on 2017/09/29 10:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4206) Improve handling of invalid credentials to mitigate DOS issue (especially on SSL listeners) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 10:42:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4206) Improve handling of invalid credentials to mitigate DOS issue (especially on SSL listeners) - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2017/09/29 10:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5919) Adding checks on "version" field for delete records command - posted by "Paolo Patierno (JIRA)" <ji...@apache.org> on 2017/09/29 10:44:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4712) kafka-reassign-partitions causes ISR to shrink - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/29 12:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2017/09/29 12:38:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5940) kafka-delete-records.sh doesn't give any feedback when the JSON offset configuration file is invalid - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 12:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5968) Remove all broker metrics during shutdown - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/09/29 14:22:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5989) disableLogging() causes an initialization loop - posted by "Tuan Nguyen (JIRA)" <ji...@apache.org> on 2017/09/29 15:07:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-5995) Rename AlterReplicaDir to AlterReplicaDirs - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/09/29 15:10:03 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5985) Mention the need to close store iterators - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/09/29 15:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5995) Rename AlterReplicaDir to AlterReplicaDirs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 15:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5985) Mention the need to close store iterators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/09/29 16:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5996) JsonConverter generates "Mismatching schema" DataException - posted by "Yuqi Li (JIRA)" <ji...@apache.org> on 2017/09/29 19:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5514) KafkaConsumer ignores default values in Properties object because of incorrect use of Properties object. - posted by "Mariusz Galus (JIRA)" <ji...@apache.org> on 2017/09/29 19:36:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91) - posted by "Tommy Becker (JIRA)" <ji...@apache.org> on 2017/09/29 19:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5989) disableLogging() causes an initialization loop - posted by "Tuan Nguyen (JIRA)" <ji...@apache.org> on 2017/09/29 21:01:01 UTC, 8 replies.
- [jira] [Reopened] (KAFKA-5989) disableLogging() causes an initialization loop - posted by "Tuan Nguyen (JIRA)" <ji...@apache.org> on 2017/09/29 21:09:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5989) disableLogging() causes an initialization loop - posted by "Tuan Nguyen (JIRA)" <ji...@apache.org> on 2017/09/29 21:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5997) acks=all does not seem to be honoured - posted by "Ronald van de Kuil (JIRA)" <ji...@apache.org> on 2017/09/30 07:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5997) acks=all does not seem to be honoured - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/09/30 08:07:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5997) acks=all does not seem to be honoured - posted by "Ronald van de Kuil (JIRA)" <ji...@apache.org> on 2017/09/30 09:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-5998) /.checkpoint.tmp Not found exception - posted by "Yogesh BG (JIRA)" <ji...@apache.org> on 2017/09/30 09:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception - posted by "Yogesh BG (JIRA)" <ji...@apache.org> on 2017/09/30 09:47:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5972) Flatten SMT does not work with null values - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2017/09/30 18:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries() - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2017/09/30 18:28:00 UTC, 0 replies.