You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Commented] (KAFKA-6282) exactly_once semantics breaks demo application - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/01 01:53:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6288) Broken symlink interrupts scanning the plugin path - posted by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2017/12/01 02:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6288) Broken symlink interrupts scanning the plugin path - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2017/12/01 02:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6288) Broken symlink interrupts scanning the plugin path - posted by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2017/12/01 02:31:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-6288) Broken symlink interrupts scanning the plugin path - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/01 03:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6289) NetworkClient should not return internal failed api version responses from poll - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/01 04:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6289) NetworkClient should not return internal failed api version responses from poll - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 05:11:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6290) Kafka Connect fails when using cast transformation - posted by "Sudhir Pradhan (JIRA)" <ji...@apache.org> on 2017/12/01 07:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6290) Kafka Connect fails when using cast transformation - posted by "Sudhir Pradhan (JIRA)" <ji...@apache.org> on 2017/12/01 07:18:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows - posted by "Viliam Durina (JIRA)" <ji...@apache.org> on 2017/12/01 07:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows - posted by "Viliam Durina (JIRA)" <ji...@apache.org> on 2017/12/01 07:58:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6292) ReplicaManager not respect the rolled log - posted by "Terence Yi (JIRA)" <ji...@apache.org> on 2017/12/01 08:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6292) ReplicaManager not respect the rolled log - posted by "Terence Yi (JIRA)" <ji...@apache.org> on 2017/12/01 08:23:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6292) ReplicaManager not respect the rolled log - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/01 08:41:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-6292) ReplicaManager not respect the rolled log - posted by "Terence Yi (JIRA)" <ji...@apache.org> on 2017/12/01 09:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 10:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6272) SASL PLAIN and SCRAM do not apply SASLPrep - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/12/01 10:52:04 UTC, 0 replies.
- [jira] [Created] (KAFKA-6293) Support for Avro formatter in ConsoleConsumer With Confluent Schema Registry - posted by "Eric Thiebaut-George (JIRA)" <ji...@apache.org> on 2017/12/01 12:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6293) Support for Avro formatter in ConsoleConsumer With Confluent Schema Registry - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 13:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6293) Support for Avro formatter in ConsoleConsumer With Confluent Schema Registry - posted by "Eric Thiebaut-George (JIRA)" <ji...@apache.org> on 2017/12/01 13:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6193) ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopics fails sometimes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 15:27:01 UTC, 1 replies.
- [jira] [Created] (KAFKA-6294) ZkClient is not joining it's event thread during an interrupt - posted by "Zeynep Arikoglu (JIRA)" <ji...@apache.org> on 2017/12/01 16:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6290) Kafka Connect cast transformation should support logical types - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/01 17:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6252) A metric named 'XX' already exists, can't register another one. - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/01 17:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6295) Add 'Coordinator Id' to consumer metrics - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2017/12/01 18:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6295) Add 'Coordinator Id' to consumer metrics - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/01 18:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6296) Transient failure in NetworkClientTest.testConnectionDelayDisconnected - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/01 18:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6296) Transient failure in NetworkClientTest.testConnectionDelayDisconnected - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/01 18:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6296) Transient failure in NetworkClientTest.testConnectionDelayDisconnected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 19:13:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6297) Consumer fetcher should handle UnsupportedVersionException more diligently - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/01 19:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/01 19:31:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-6297) Consumer fetcher should handle UnsupportedVersionException more diligently - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/01 19:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6296) Transient failure in NetworkClientTest.testConnectionDelayDisconnected - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/01 21:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6294) ZkClient is not joining it's event thread during an interrupt - posted by "Buğra Gedik (JIRA)" <ji...@apache.org> on 2017/12/01 21:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3508) Transient failure in kafka.security.auth.SimpleAclAuthorizerTest.testHighConcurrencyModificationOfResourceAcls - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/01 22:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3508) Transient failure in kafka.security.auth.SimpleAclAuthorizerTest.testHighConcurrencyModificationOfResourceAcls - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/01 22:37:01 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-3508) Transient failure in kafka.security.auth.SimpleAclAuthorizerTest.testHighConcurrencyModificationOfResourceAcls - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/01 22:37:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6118) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/01 22:48:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6136) Transient test failure: SaslPlainSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/01 22:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6158) CONSUMER-ID and HOST values are concatenated if the CONSUMER-ID is > 50 chars - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/12/01 22:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6136) Transient test failure: SaslPlainSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/01 23:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6298) Line numbers on log messages are incorrect - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/12/02 00:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6297) Consumer fetcher should handle UnsupportedVersionException more diligently - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/12/02 00:48:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6298) Line numbers on log messages are incorrect - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/02 00:53:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-6262) KIP-232: Detect outdated metadata by adding ControllerMetadataEpoch field - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/12/02 02:29:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6118) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/02 05:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6118) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/02 07:55:01 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/02 08:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/02 08:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible - posted by "Steven Aerts (JIRA)" <ji...@apache.org> on 2017/12/02 09:51:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6221) ReplicaFetcherThread throws UnknownTopicOrPartitionException on topic creation - posted by "Michael Golovanov (JIRA)" <ji...@apache.org> on 2017/12/02 14:09:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/02 17:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2081) testUncleanLeaderElectionEnabledByTopicOverride transient failure - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/02 17:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/02 17:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/02 17:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6299) Fix AdminClient error handling when metadata changes - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/12/02 22:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6199) Single broker with fast growing heap usage - posted by "Robin Tweedie (JIRA)" <ji...@apache.org> on 2017/12/02 23:05:01 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-6199) Single broker with fast growing heap usage - posted by "Robin Tweedie (JIRA)" <ji...@apache.org> on 2017/12/02 23:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6300) SelectorTest may fail with ConcurrentModificationException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/03 00:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6300) SelectorTest may fail with ConcurrentModificationException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/03 00:16:06 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/03 04:34:00 UTC, 10 replies.
- [jira] [Created] (KAFKA-6301) Incorrect Java Regex example '*' for mirroring all topics - posted by "Waleed Fateem (JIRA)" <ji...@apache.org> on 2017/12/03 15:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6193) Only delete reassign_partitions znode after reassignment is complete - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/03 16:04:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6193) Only delete reassign_partitions znode after reassignment is complete - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/03 16:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6302) Topic can not be recreated after it is deleted - posted by "kic (JIRA)" <ji...@apache.org> on 2017/12/03 17:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6302) Topic can not be recreated after it is deleted - posted by "kic (JIRA)" <ji...@apache.org> on 2017/12/03 17:04:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6301) Incorrect Java Regex example '*' for mirroring all topics - posted by "Waleed Fateem (JIRA)" <ji...@apache.org> on 2017/12/03 17:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6301) Incorrect Java Regex example '*' for mirroring all topics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/03 19:52:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6302) Topic can not be recreated after it is deleted - posted by "Waleed Fateem (JIRA)" <ji...@apache.org> on 2017/12/03 20:00:06 UTC, 6 replies.
- [jira] [Commented] (KAFKA-5632) Message headers not supported by Kafka Streams - posted by "Narendra Kumar (JIRA)" <ji...@apache.org> on 2017/12/03 22:06:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/04 00:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6304) The controller should allow update the partition reassignment for the partitions being reassigned - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/12/04 00:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6304) The controller should allow update the partition reassignment for the partitions being reassigned - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/12/04 00:50:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6304) The controller should allow updating the partition reassignment for the partitions being reassigned - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/12/04 00:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6305) log.retention.hours, retention.ms not working in segments deletion for kafka topic - posted by "VinayKumar (JIRA)" <ji...@apache.org> on 2017/12/04 03:16:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/04 03:19:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6221) ReplicaFetcherThread throws UnknownTopicOrPartitionException on topic creation - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2017/12/04 07:44:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6221) ReplicaFetcherThread throws UnknownTopicOrPartitionException on topic creation - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/04 07:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6306) Auto-commit of offsets fail, and not recover forever... - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2017/12/04 09:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6306) Auto-commit of offsets fail, and not recover forever... - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2017/12/04 09:16:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-6306) Auto-commit of offsets fail, and not recover forever... - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/04 09:43:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/04 14:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak - posted by "Joseph Aliase (JIRA)" <ji...@apache.org> on 2017/12/04 15:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute() - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2017/12/04 16:54:00 UTC, 8 replies.
- [jira] [Created] (KAFKA-6308) Connect: Struct#equals should use Arrays#deepEquals - posted by "Tobias Gies (JIRA)" <ji...@apache.org> on 2017/12/04 16:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6308) Connect: Struct#equals should use Arrays#deepEquals - posted by "Tobias Gies (JIRA)" <ji...@apache.org> on 2017/12/04 16:55:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2017/12/04 17:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute() - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2017/12/04 17:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6309) add support for getting topic defaults from AdminClient - posted by "dan norwood (JIRA)" <ji...@apache.org> on 2017/12/04 17:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6308) Connect: Struct equals/hashCode method should use Arrays#deep* methods - posted by "Tobias Gies (JIRA)" <ji...@apache.org> on 2017/12/04 17:26:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-1120) Controller could miss a broker state change - posted by "Ramnatthan Alagappan (JIRA)" <ji...@apache.org> on 2017/12/04 17:46:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-1120) Controller could miss a broker state change - posted by "Ramnatthan Alagappan (JIRA)" <ji...@apache.org> on 2017/12/04 17:47:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6150) Make Repartition Topics Transient - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/04 18:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6150) Make Repartition Topics Transient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/04 18:24:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-2188) JBOD Support - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/04 19:06:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6306) Auto-commit of offsets fail, and not recover forever... - posted by "zhaojianbo (JIRA)" <ji...@apache.org> on 2017/12/05 05:42:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6308) Connect: Struct equals/hashCode method should use Arrays#deep* methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/05 10:44:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6310) ConcurrentModificationException when reporting requests-in-flight in producer - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2017/12/05 11:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore - posted by "Panuwat Anawatmongkhon (JIRA)" <ji...@apache.org> on 2017/12/05 18:56:01 UTC, 1 replies.
- [jira] [Created] (KAFKA-6311) Expose Kafka cluster ID in Connect REST API - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2017/12/05 19:02:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/05 19:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6302) Topic can not be recreated after it is deleted - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/05 19:23:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6219) Inconsistent behavior for kafka-consumer-groups - posted by "Wenjie Zhang (JIRA)" <ji...@apache.org> on 2017/12/05 19:33:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6219) Inconsistent behavior for kafka-consumer-groups - posted by "Wenjie Zhang (JIRA)" <ji...@apache.org> on 2017/12/05 19:33:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/12/05 21:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/12/05 21:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6299) Fix AdminClient error handling when metadata changes - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/12/06 00:35:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6299) Fix AdminClient error handling when metadata changes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 00:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6285) OffsetCommitRequest should have read-after-write logic - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/12/06 00:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5878) Add sensor for queue size of the controller-event-thread - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/12/06 00:51:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-5878) Add sensor for queue size of the controller-event-thread - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/12/06 00:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6075) Kafka cannot recover after an unclean shutdown on Windows - posted by "Peter Carpenter (JIRA)" <ji...@apache.org> on 2017/12/06 02:40:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/06 02:42:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6075) Kafka cannot recover after an unclean shutdown on Windows - posted by "Peter Carpenter (JIRA)" <ji...@apache.org> on 2017/12/06 02:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully - posted by "Pablo Panero (JIRA)" <ji...@apache.org> on 2017/12/06 07:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/06 07:58:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/06 08:02:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/06 08:02:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-6314) Add a tool to delete consumer offsets for a given group - posted by "Tom Scott (JIRA)" <ji...@apache.org> on 2017/12/06 11:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6315) kafka-console-consumer.sh terminating consumer process only for one partition with java.lang.IllegalArgumentException: Unknown compression type id: 5 - posted by "VinayKumar (JIRA)" <ji...@apache.org> on 2017/12/06 13:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6316) Kafka Rebalancing issues when I kill one consumer - posted by "Krishan (JIRA)" <ji...@apache.org> on 2017/12/06 13:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6174) Add methods in Options classes to keep binary compatibility with 0.11 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 14:00:05 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6174) Add methods in Options classes to keep binary compatibility with 0.11 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/06 14:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/06 14:51:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/12/06 15:40:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6311) Expose Kafka cluster ID in Connect REST API - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/06 15:49:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6317) Maven artifact for kafka should not depend on log4j - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/06 16:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6317) Maven artifact for kafka should not depend on log4j - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 17:01:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6318) StreamsResetter should return non-zero return code on error - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/06 19:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/06 19:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/06 19:40:00 UTC, 0 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/12/06 19:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6300) SelectorTest may fail with ConcurrentModificationException - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/12/06 19:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/06 19:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6269) KTable state restore fails after rebalance - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/06 19:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6059) Kafka cant delete old log files on windows - posted by "Rainer Guessner (JIRA)" <ji...@apache.org> on 2017/12/06 19:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/06 21:11:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well) - posted by "Jordan Mcmillan (JIRA)" <ji...@apache.org> on 2017/12/06 21:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6065) Add zookeeper metrics to ZookeeperClient as in KIP-188 - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/12/06 21:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well) - posted by "Jordan Mcmillan (JIRA)" <ji...@apache.org> on 2017/12/06 21:51:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6320) move ZK metrics in KafkaHealthCheck to ZookeeperClient - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/12/06 21:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6269) KTable state restore fails after rebalance - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 22:00:02 UTC, 5 replies.
- [jira] [Created] (KAFKA-6321) ConsumerGroupCommand should use the new consumer to query the log end offsets. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2017/12/06 22:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6321) ConsumerGroupCommand should use the new consumer to query the log end offsets. - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/12/06 22:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6322) Error deleting log for topic, all log dirs failed. - posted by "dongyan li (JIRA)" <ji...@apache.org> on 2017/12/06 22:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6322) Error deleting log for topic, all log dirs failed. - posted by "dongyan li (JIRA)" <ji...@apache.org> on 2017/12/06 22:48:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6200) 00000000000000000015.timeindex: The process cannot access the file because it is being used by another process. - posted by "Peter Carpenter (JIRA)" <ji...@apache.org> on 2017/12/06 22:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6065) Add zookeeper metrics to ZookeeperClient as in KIP-188 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/06 23:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6065) Add ZooKeeperRequestLatencyMs to KafkaZkClient - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/06 23:23:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6065) Add ZooKeeperRequestLatencyMs to KafkaZkClient - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/06 23:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5382) Log recovery can fail if topic names contain one of the index suffixes - posted by "Robert P. Thille (JIRA)" <ji...@apache.org> on 2017/12/06 23:51:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5027) Kafka Controller Redesign - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 00:36:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6298) Line numbers on log messages are incorrect - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/07 01:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3473) KIP-237: More Controller Health Metrics - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/12/07 02:18:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6322) Error deleting log for topic, all log dirs failed. - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/07 03:07:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-6316) Kafka Rebalancing issues when I kill one consumer - posted by "Krishan (JIRA)" <ji...@apache.org> on 2017/12/07 03:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately - posted by "Frederic Arno (JIRA)" <ji...@apache.org> on 2017/12/07 06:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2017/12/07 08:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 08:38:00 UTC, 22 replies.
- [jira] [Updated] (KAFKA-6313) Kafka Core should have explicit SLF4J API dependency - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 08:40:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6313) Kafka Core should have explicit SLF4J API dependency - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 08:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well) - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/12/07 09:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4637) Update system test(s) to use multiple listeners for the same security protocol - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 09:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4680) min.insync.replicas can be set higher than replication factor - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 09:16:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 09:17:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133) - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 09:18:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5272) Improve validation for Alter Configs (KIP-133) - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 09:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6324) Change LogSegment.delete to deleteIfExists and harden log recovery - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 11:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1996) Scaladoc error: unknown tag parameter - posted by "Andy Doddington (JIRA)" <ji...@apache.org> on 2017/12/07 12:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3240) Replication issues - posted by "Sergey AKhmatov (JIRA)" <ji...@apache.org> on 2017/12/07 12:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6325) Producer.flush() doesn't throw exception on timeout - posted by "Erik Scheuter (JIRA)" <ji...@apache.org> on 2017/12/07 13:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6326) when broker is unavailable(such as broker's machine is down), controller will wait 30 sec timeout - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2017/12/07 14:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6326) when broker is unavailable(such as broker's machine is down), controller will wait 30 sec timeout - posted by "wei liu (JIRA)" <ji...@apache.org> on 2017/12/07 15:18:00 UTC, 7 replies.
- [jira] [Comment Edited] (KAFKA-6326) when broker is unavailable(such as broker's machine is down), controller will wait 30 sec timeout - posted by "wei liu (JIRA)" <ji...@apache.org> on 2017/12/07 15:19:00 UTC, 5 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6326) when broker is unavailable(such as broker's machine is down), controller will wait 30 sec timeout - posted by "wei liu (JIRA)" <ji...@apache.org> on 2017/12/07 15:38:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6325) Producer.flush() doesn't throw exception on timeout - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/07 15:48:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6324) Change LogSegment.delete to deleteIfExists and harden log recovery - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 16:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6324) Change LogSegment.delete to deleteIfExists and harden log recovery - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/07 16:31:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6322) Error deleting log for topic, all log dirs failed. - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/07 17:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/07 18:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6327) IllegalArgumentException in RocksDB when RocksDBException being generated - posted by "Anthony May (JIRA)" <ji...@apache.org> on 2017/12/07 20:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/07 20:31:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6327) IllegalArgumentException in RocksDB when RocksDBException being generated - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/07 21:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/07 22:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/08 00:04:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4857) Replace StreamsKafkaClient with AdminClient in Kafka Streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/08 00:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6126) Reduce rebalance time by not checking if created topics are available - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/08 01:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6329) Load trust store as a resource - posted by "Allen Wang (JIRA)" <ji...@apache.org> on 2017/12/08 01:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6318) StreamsResetter should return non-zero return code on error - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2017/12/08 02:09:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6326) when broker is unavailable(such as broker's machine is down), controller will wait 30 sec timeout - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2017/12/08 04:49:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6314) Add a tool to delete consumer offsets for a given group - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/12/08 09:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6314) Add a tool to delete kafka based consumer offsets for a given group - posted by "Tom Scott (JIRA)" <ji...@apache.org> on 2017/12/08 09:50:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6314) Add a tool to delete kafka based consumer offsets for a given group - posted by "Tom Scott (JIRA)" <ji...@apache.org> on 2017/12/08 09:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is invalid. (kafka.log.LogCleanerManager$) - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/08 10:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6289) NetworkClient should not return internal failed api version responses from poll - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/12/08 11:00:06 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5200) If a replicated topic is deleted with one broker down, it can't be recreated - posted by "Matthias Rampke (JIRA)" <ji...@apache.org> on 2017/12/08 15:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6330) KafkaZkClient request queue time metric - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/08 15:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6320) move ZK metrics in KafkaHealthCheck to ZookeeperClient - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/08 15:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6330) KafkaZkClient request queue time metric - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/08 16:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6331) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/08 16:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6332) Kafka system tests should use nc instead of log grep to detect start-up - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/08 16:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6331) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/08 16:20:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-4706) Unify StreamsKafkaClient instances - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/08 16:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/08 16:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6237) stream stopped working after exception: Cannot execute transactional method because we are in an error state - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/08 17:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5868) Kafka Consumer Rebalancing takes too long - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/08 17:12:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5002) Stream does't seem to consider partitions for processing which are being consumed - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/08 17:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/08 17:16:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6318) StreamsResetter should return non-zero return code on error - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/08 19:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6333) java.awt.headless should not be on commandline - posted by "Fabrice Bacchella (JIRA)" <ji...@apache.org> on 2017/12/08 20:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6334) Minor documentation typo - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/12/08 20:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/08 23:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers - posted by "Neerja Khattar (JIRA)" <ji...@apache.org> on 2017/12/08 23:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6334) Minor documentation typo - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/09 00:50:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-4218) Enable access to key in ValueTransformer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/09 01:01:38 UTC, 1 replies.
- [jira] [Created] (KAFKA-6337) Error for partition [__consumer_offsets,15] to broker - posted by "Abhi (JIRA)" <ji...@apache.org> on 2017/12/09 04:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6338) java.lang.NoClassDefFoundError: org/apache/kafka/common/network/LoginType - posted by "Ronald van de Kuil (JIRA)" <ji...@apache.org> on 2017/12/09 07:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6338) java.lang.NoClassDefFoundError: org/apache/kafka/common/network/LoginType - posted by "Ronald van de Kuil (JIRA)" <ji...@apache.org> on 2017/12/09 07:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6337) Error for partition [__consumer_offsets,15] to broker - posted by "Abhi (JIRA)" <ji...@apache.org> on 2017/12/09 08:56:02 UTC, 5 replies.
- [jira] [Created] (KAFKA-6339) Integration test with embedded kafka. - posted by "DHRUV BANSAL (JIRA)" <ji...@apache.org> on 2017/12/09 16:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6339) Integration test with embedded kafka. - posted by "Narendra Kumar (JIRA)" <ji...@apache.org> on 2017/12/09 17:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/09 17:54:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-6339) Integration test with embedded kafka not working - posted by "DHRUV BANSAL (JIRA)" <ji...@apache.org> on 2017/12/09 18:37:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-6339) Integration test with embedded kafka not working - posted by "DHRUV BANSAL (JIRA)" <ji...@apache.org> on 2017/12/09 18:40:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6340) Support of transactions in KafkaConnect - posted by "Oleg Kuznetsov (JIRA)" <ji...@apache.org> on 2017/12/09 21:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/12/10 08:20:00 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/10 09:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/10 09:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5398) Joins on GlobalKTable don't work properly when combined with Avro and the Confluent Schema Registry - posted by "Gavrie Philipson (JIRA)" <ji...@apache.org> on 2017/12/10 15:22:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-5398) Joins on GlobalKTable don't work properly when combined with Avro and the Confluent Schema Registry - posted by "Gavrie Philipson (JIRA)" <ji...@apache.org> on 2017/12/10 21:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/11 03:19:00 UTC, 8 replies.
- [jira] [Assigned] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 05:39:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5551) StreamThread should not expose methods for testing - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 05:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5318) Streams state may be misleading - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 05:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5318) Streams state may be misleading - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 05:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5318) Streams state may be misleading - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 05:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 05:53:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3907) Better support for user-specific committing in the Streams DSL - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 05:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6341) 'networkThreadTimeNanos' in KafkaChannel is not thread safe - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/11 09:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6337) Error for partition [__consumer_offsets,15] to broker - posted by "Abhi (JIRA)" <ji...@apache.org> on 2017/12/11 09:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6337) Error for partition [__consumer_offsets,15] to broker - posted by "Abhi (JIRA)" <ji...@apache.org> on 2017/12/11 10:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6342) Remove workaround for JSON parsing of non-escaped strings - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/12/11 10:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/12/11 10:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6341) 'networkThreadTimeNanos' in KafkaChannel is not thread safe - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/11 11:15:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6343) OOM as the result of creation of 5k topics - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2017/12/11 11:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6343) OOM as the result of creation of 5k topics - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2017/12/11 11:35:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/11 11:39:00 UTC, 11 replies.
- [jira] [Comment Edited] (KAFKA-6343) OOM as the result of creation of 5k topics - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2017/12/11 12:23:00 UTC, 11 replies.
- [jira] [Commented] (KAFKA-6283) Configuration of custom SCRAM SaslServer implementations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/11 14:12:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6283) Configuration of custom SCRAM SaslServer implementations - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/12/11 14:15:09 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/12/11 14:20:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/12/11 14:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6121) Restore and global consumer should not use auto.offset.reset - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/11 14:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/11 15:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/11 15:08:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6344) 0.8.2 clients will store invalid configuration in ZK for Kafka 1.0 brokers - posted by "Vincent Bernat (JIRA)" <ji...@apache.org> on 2017/12/11 15:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3940) Log should check the return value of dir.mkdirs() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/11 16:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6298) Line numbers on log messages are incorrect - posted by "Narendra Kumar (JIRA)" <ji...@apache.org> on 2017/12/11 16:06:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5037) Infinite loop if all input topics are unknown at startup - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/11 18:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4437) Incremental Batch Processing for Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/11 18:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6124) Revisit default config for internal client with regard to resilience - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/11 18:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5524) Streams systems tests should be with EoS - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/11 18:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5660) Don't throw TopologyBuilderException during runtime - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/11 18:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5397) streams are not recovering from LockException during rebalancing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/11 18:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5551) StreamThread should not expose methods for testing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/11 18:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5551) StreamThread should not expose methods for testing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/11 18:59:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1530) howto update continuously - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:00:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:02:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-1561) Data Loss for Incremented Replica Factor and Leader Election - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:02:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1561) Data Loss for Incremented Replica Factor and Leader Election - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5719) Create a quickstart archetype project for Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1704) Add PartitionConfig besides LogConfig - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:05:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-1704) Add PartitionConfig besides LogConfig - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:05:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-967) Use key range in ProducerPerformance - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1181) Consolidate brokerList and topicPartitionInfo in BrokerPartitionInfo - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-1056) Evenly Distribute Intervals in OffsetIndex - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 19:07:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6345) NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read - posted by "radai rosenblatt (JIRA)" <ji...@apache.org> on 2017/12/11 19:33:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6334) Minor documentation typo - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2017/12/11 21:36:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6346) Consolidate multiple background async log operations - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/11 23:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6311) Expose Kafka cluster ID in Connect REST API - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/12/11 23:44:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6347) Starting offset breach based log segment deletion never considers active segment - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 00:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6341) 'networkThreadTimeNanos' in KafkaChannel is not thread safe - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/12 00:27:03 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 00:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 00:52:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-2319) After controlled shutdown: IllegalStateException: Kafka scheduler has not been started - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 01:15:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6334) Minor documentation typo - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 02:57:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-6334) Minor documentation typo - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 02:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3900) High CPU util on broker - posted by "Vikas Lalwani (JIRA)" <ji...@apache.org> on 2017/12/12 05:48:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6348) Kafka consumer can't restore from coordinator failure - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2017/12/12 07:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6265) GlobalKTable missing #queryableStoreName() - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 07:43:00 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-6322) Error deleting log for topic, all log dirs failed. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/12 08:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6075) Kafka cannot recover after an unclean shutdown on Windows - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/12 08:07:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6194) Server crash while deleting segments - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/12 08:08:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well) - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/12 10:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6349) ConcurrentModificationException during streams state restoration - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/12/12 10:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6349) ConcurrentModificationException during streams state restoration - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/12/12 11:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6349) ConcurrentModificationException during streams state restoration - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/12/12 11:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6350) File descriptors leak with persistent KeyValueStore - posted by "Alin Gheorghe (JIRA)" <ji...@apache.org> on 2017/12/12 12:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6350) File descriptors leak with persistent KeyValueStore - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/12/12 12:49:06 UTC, 2 replies.
- [jira] [Created] (KAFKA-6351) libs directory has duplicate javassist jars - posted by "pre sto (JIRA)" <ji...@apache.org> on 2017/12/12 14:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6349) ConcurrentModificationException during streams state restoration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 14:30:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5631) Use Jackson for serialising to JSON - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/12 16:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5631) Use Jackson for serialising to JSON - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/12 16:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/12 17:01:01 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3508) Transient failure in kafka.security.auth.SimpleAclAuthorizerTest.testHighConcurrencyModificationOfResourceAcls - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/12 17:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/12/12 17:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3625) Move kafka-streams test fixtures into a published package - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/12 18:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3625) Move kafka-streams test fixtures into a published package - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/12 18: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/12/12 19:30:01 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2017/12/12 19:31:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5876) IQ should throw different exceptions for different errors - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 19:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5158) Options for handling exceptions during processing - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 20:00:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5660) Don't throw TopologyBuilderException during runtime - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 20:00:04 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5397) streams are not recovering from LockException during rebalancing - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 20:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5397) streams are not recovering from LockException during rebalancing - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 20:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5156) Options for handling exceptions in streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/12 20:01:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5397) streams are not recovering from LockException during rebalancing - posted by "Jozef Koval (JIRA)" <ji...@apache.org> on 2017/12/12 20:45:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6352) Delay message down-conversion until response is ready to be sent - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/12 21:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6352) Delay message down-conversion until response is ready to be sent - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/12 21:48:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6353) Connector status shows FAILED but actually task is in RUNNING status - posted by "Chen He (JIRA)" <ji...@apache.org> on 2017/12/12 21:54:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6353) Connector status shows FAILED but actually task is in RUNNING status - posted by "Chen He (JIRA)" <ji...@apache.org> on 2017/12/12 21:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/12 22:19: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/12/12 23:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5142) KIP-145 - Expose Record Headers in Kafka Connect - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/13 01:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings - posted by "Umesh Chaudhary (JIRA)" <ji...@apache.org> on 2017/12/13 03:22:02 UTC, 4 replies.
- [jira] [Created] (KAFKA-6355) transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/13 06:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/13 06:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6356) UnknownTopicOrPartitionException & NotLeaderForPartitionException and log deletion happening with retention bytes kept at -1. - posted by "kaushik srinivas (JIRA)" <ji...@apache.org> on 2017/12/13 08:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6357) Return nonzero code in kafka-consumer-groups.sh tool in case of error - posted by "Rinat Shigapov (JIRA)" <ji...@apache.org> on 2017/12/13 09:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6358) Per topic producer/fetch_consumer/fetch_follower metrics - posted by "Ricardo Bartolome (JIRA)" <ji...@apache.org> on 2017/12/13 09:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6359) Work for KIP-236 - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/12/13 11:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/12/13 11:46:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2017/12/13 13:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5581) Avoid creating changelog topics for state stores that are materialized from a source topic - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2017/12/13 13:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2017/12/13 13:21:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2017/12/13 13:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6086) Provide for custom error handling when Kafka Streams fails to produce - posted by "Matt Farmer (JIRA)" <ji...@apache.org> on 2017/12/13 15:13:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6086) Provide for custom error handling when Kafka Streams fails to produce - posted by "Matt Farmer (JIRA)" <ji...@apache.org> on 2017/12/13 15:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6355) transient failure in org.apache.kafka.streams.integration.EosIntegrationTest.shouldBeAbleToRunWithTwoSubtopologies - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/13 18:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/13 19:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6126) Reduce rebalance time by not checking if created topics are available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/13 21:23:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6352) Delay message down-conversion until response is ready to be sent - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/13 21:34:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6339) Integration test with embedded kafka not working - posted by "Narendra Kumar (JIRA)" <ji...@apache.org> on 2017/12/13 22:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6252) A metric named 'XX' already exists, can't register another one. - posted by "William Austin (JIRA)" <ji...@apache.org> on 2017/12/13 23:57:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6345) NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/14 00:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6361) Fast leader fail over can lead to log divergence between replica and follower - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/14 00:46:20 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6361) Fast leader fail over can lead to log divergence between leader and follower - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/14 00:50:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5849) Add process stop faults, round trip workload, partitioned produce-consume test - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/12/14 01:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5849) Add process stop faults, round trip workload, partitioned produce-consume test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/14 01:33:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce - posted by "Jed Wesley-Smith (JIRA)" <ji...@apache.org> on 2017/12/14 02:41:03 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6361) Fast leader fail over can lead to log divergence between leader and follower - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/12/14 02:47:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/14 05:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/14 10:19:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5123) Refactor ZkUtils readData* methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/14 10:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5123) Refactor ZkUtils readData* methods - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2017/12/14 10:50:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true. - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2017/12/14 12:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true. - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2017/12/14 12:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6350) File descriptors leak with persistent KeyValueStore - posted by "Alin Gheorghe (JIRA)" <ji...@apache.org> on 2017/12/14 13:12:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/14 17:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/14 18:28:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/14 18:29:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/14 18:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6364) Add Second Check for End Offset During Restore - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/12/14 18:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Victor Chicu (JIRA)" <ji...@apache.org> on 2017/12/14 19:42:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Victor Chicu (JIRA)" <ji...@apache.org> on 2017/12/14 19:43:00 UTC, 3 replies.
- [jira] [Issue Comment Deleted] (KAFKA-5696) SourceConnector does not commit offset on rebalance - posted by "Victor Chicu (JIRA)" <ji...@apache.org> on 2017/12/14 19:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6365) How to add a client to list of available clients? - posted by "Lev Gorodinski (JIRA)" <ji...@apache.org> on 2017/12/14 20:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6365) How to add a client to list of available clients? - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/14 20:09:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Joerg Heinicke (JIRA)" <ji...@apache.org> on 2017/12/14 20:48:00 UTC, 18 replies.
- [jira] [Created] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Joerg Heinicke (JIRA)" <ji...@apache.org> on 2017/12/14 20:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/14 20:52:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-6365) How to add a client to list of available clients? - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/14 21:15:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/12/14 22:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/12/14 22:40:03 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/12/14 22:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6102) Consolidate MockTime implementations between connect and clients - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/14 22:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6102) Consolidate MockTime implementations between connect and clients - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/14 22:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/14 22:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6368) AdminClient should contact multiple nodes before timing out a call - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/12/14 23:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6368) AdminClient should contact multiple nodes before timing out a call - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/12/14 23:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6308) Connect: Struct equals/hashCode method should use Arrays#deep* methods - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/14 23:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6369) General wildcard support for ACL's in kafka - posted by "Antony Stubbs (JIRA)" <ji...@apache.org> on 2017/12/15 00:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 02:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5285) optimize upper / lower byte range for key range scan on windowed stores - posted by "Peter Davis (JIRA)" <ji...@apache.org> on 2017/12/15 02:59:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5285) optimize upper / lower byte range for key range scan on windowed stores - posted by "Peter Davis (JIRA)" <ji...@apache.org> on 2017/12/15 03:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/15 03:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/15 05:37:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/15 08:08:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 08:08:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-6371) FetchMetadata creates unneeded Strings on instantiation - posted by "Maytee Chinavanichkit (JIRA)" <ji...@apache.org> on 2017/12/15 09:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6371) FetchMetadata creates unneeded Strings on instantiation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 09:34:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6359) Work for KIP-236 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 18:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5526) KIP-175: ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 18:32:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6372) Trogdor should use LogContext for log messages - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2017/12/15 18:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6373) Log end offset of input table changing during restore - posted by "Charles Crain (JIRA)" <ji...@apache.org> on 2017/12/15 19:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6374) Constant Consumer Errors after replacing a broker - posted by "Aravind Velamur Srinivasan (JIRA)" <ji...@apache.org> on 2017/12/15 21:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6374) Constant Consumer Errors after replacing a broker - posted by "Aravind Velamur Srinivasan (JIRA)" <ji...@apache.org> on 2017/12/15 21:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed" - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/12/15 21:44:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2017/12/15 21:46:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6265) GlobalKTable missing #queryableStoreName() - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/12/15 22:00:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-6375) Follower replicas can never catch up to be ISR due to creating ReplicaFetcherThread failed. - posted by "Rong Tang (JIRA)" <ji...@apache.org> on 2017/12/15 22:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6375) Follower replicas can never catch up to be ISR due to creating ReplicaFetcherThread failed. - posted by "Rong Tang (JIRA)" <ji...@apache.org> on 2017/12/15 22:09:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/15 22:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6302) Topic can not be recreated after it is deleted - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/15 23:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4999) Add convenience overload for seek* methods - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/16 00:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6265) GlobalKTable missing #queryableStoreName() - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/16 00:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6375) Follower replicas can never catch up to be ISR due to creating ReplicaFetcherThread failed. - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/16 02:28:02 UTC, 5 replies.
- [jira] [Created] (KAFKA-6376) Improve Streams metrics for skipped recrods - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/16 18:12:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6376) Improve Streams metrics for skipped recrods - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/16 18:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6376) Improve Streams metrics for skipped records - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/16 18:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/17 00:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6377) Flaky test BufferPoolTest.testBlockTimeout - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/17 05:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6084) ReassignPartitionsCommand should propagate JSON parsing failures - posted by "Nick Travers (JIRA)" <ji...@apache.org> on 2017/12/17 19:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6287) Inconsistent protocol type for empty consumer groups - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/17 19:23:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6287) Inconsistent protocol type for empty consumer groups - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/17 19:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6373) Log end offset of input table changing during restore - posted by "Charles Crain (JIRA)" <ji...@apache.org> on 2017/12/17 21:57:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6082) consider fencing zookeeper updates with controller epoch zkVersion - posted by "Prasanna Gautam (JIRA)" <ji...@apache.org> on 2017/12/17 22:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null - posted by "Andy Bryant (JIRA)" <ji...@apache.org> on 2017/12/18 02:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4767) KafkaProducer is not joining its IO thread properly - posted by "huxihx (JIRA)" <ji...@apache.org> on 2017/12/18 03:00:03 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/18 03:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6379) Work for KIP-240 - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2017/12/18 10:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6380) transient failure in MetricsTest.testMetrics - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/12/18 10:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6373) Log end offset of input table changing during restore - posted by "Charles Crain (JIRA)" <ji...@apache.org> on 2017/12/18 12:40:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6373) Log end offset of input table changing during restore - posted by "Charles Crain (JIRA)" <ji...@apache.org> on 2017/12/18 12:41:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/18 18:43:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-6373) Log end offset of input table changing during restore - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/12/18 18:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6376) Improve Streams metrics for skipped records - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/18 19:08:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6258) SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 19:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6331) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/12/18 19:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6258) SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/18 19:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2359) New consumer - partitions auto assigned only on poll - posted by "Stu (JIRA)" <ji...@apache.org> on 2017/12/18 21:04:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2359) New consumer - partitions auto assigned only on poll - posted by "Stu (JIRA)" <ji...@apache.org> on 2017/12/18 21:06:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/12/18 22:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6381) Improve KafkaStreamsTest for localThreadMetadata - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/18 22:14:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/18 22:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/18 22:35:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/18 22:41:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Joerg Heinicke (JIRA)" <ji...@apache.org> on 2017/12/18 23:04:00 UTC, 7 replies.
- [jira] [Reopened] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/18 23:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called beforeStreamThread.start - posted by "Rohan Desai (JIRA)" <ji...@apache.org> on 2017/12/19 00:05:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start - posted by "Rohan Desai (JIRA)" <ji...@apache.org> on 2017/12/19 00:05:05 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6375) Follower replicas can never catch up to be ISR due to creating ReplicaFetcherThread failed. - posted by "Rong Tang (JIRA)" <ji...@apache.org> on 2017/12/19 02:46:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6384) TransactionsTest#testFencingOnSendOffsets sometimes fails with ProducerFencedException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/19 02:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 07:58:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6385) Rack awareness ignored by kafka-reassign-partitions - posted by "Gal Barak (JIRA)" <ji...@apache.org> on 2017/12/19 12:12:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-6365) How to add a client to list of available clients? - posted by "Lev Gorodinski (JIRA)" <ji...@apache.org> on 2017/12/19 13:56:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6320) move ZK metrics in KafkaHealthCheck to ZookeeperClient - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/19 17:17:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2017/12/19 18:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6386) Deprecate KafkaStreams constructor talking StreamsConfig parameter - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/19 18:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6386) Deprecate KafkaStreams constructor taking StreamsConfig parameter - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/19 18:24:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 18:50:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6321) ConsumerGroupCommand should use the new consumer to query the log end offsets. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/19 21:06:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6387) Worker's producer and consumer configs should inherit from worker configs - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/19 22:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/19 23:06:00 UTC, 4 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Joerg Heinicke (JIRA)" <ji...@apache.org> on 2017/12/19 23:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6388) Error while trying to roll a segment that already exists - posted by "David Hay (JIRA)" <ji...@apache.org> on 2017/12/19 23:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6388) Error while trying to roll a segment that already exists - posted by "David Hay (JIRA)" <ji...@apache.org> on 2017/12/19 23:44:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6388) Error while trying to roll a segment that already exists - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/19 23:53:00 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/20 00:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6388) Error while trying to roll a segment that already exists - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/20 00:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/12/20 07:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic - posted by "Balint Molnar (JIRA)" <ji...@apache.org> on 2017/12/20 07:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6389) Expose transaction metrics via JMX - posted by "Florent Ramière (JIRA)" <ji...@apache.org> on 2017/12/20 09:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed - posted by "David Cheung (JIRA)" <ji...@apache.org> on 2017/12/20 09:52:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed - posted by "David Cheung (JIRA)" <ji...@apache.org> on 2017/12/20 09:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6390) Update ZooKeeper to 3.4.11 and other minor updates - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/20 10:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6390) Update ZooKeeper to 3.4.11 and other minor updates - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/20 10:23:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/20 10:32:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6390) Update ZooKeeper to 3.4.11 and other minor updates - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/20 10:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6331) Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/20 12:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5460) Documentation on website uses word-breaks resulting in confusion - posted by "Yuri Khan (JIRA)" <ji...@apache.org> on 2017/12/20 13:15: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/12/20 13:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6391) output from ensure copartitioning is not used for Cluster metadata - posted by "Clemens Valiente (JIRA)" <ji...@apache.org> on 2017/12/20 15:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6391) output from ensure copartitioning is not used for Cluster metadata - posted by "Clemens Valiente (JIRA)" <ji...@apache.org> on 2017/12/20 15:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6391) output from ensure copartitioning is not used for Cluster metadata, resulting in partitions without tasks working on them - posted by "Clemens Valiente (JIRA)" <ji...@apache.org> on 2017/12/20 15:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6391) output from ensure copartitioning is not used for Cluster metadata, resulting in partitions without tasks working on them - posted by "Clemens Valiente (JIRA)" <ji...@apache.org> on 2017/12/20 15:48:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6392) Do not permit message down-conversion for replicas - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/20 18:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6393) Add tool to view active brokers - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/20 19:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5647) Use async ZookeeperClient for Admin operations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/20 20:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6394) Prevent misconfiguration of advertised listeners - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/20 20:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5849) Add process stop faults, round trip workload, partitioned produce-consume test - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2017/12/20 21:34:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/20 21:41:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4263) QueryableStateIntegrationTest.concurrentAccess is failing occasionally in jenkins builds - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/20 23:23:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/21 00:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/21 01:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams - posted by "Jorge Quilcate (JIRA)" <ji...@apache.org> on 2017/12/21 14:01:09 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6142) Connect worker configurations and connector configurations should accept environment variables - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/21 15:50:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6396) Possibly kafka-connect converter should be able to stop processing chain - posted by "Alexander Koval (JIRA)" <ji...@apache.org> on 2017/12/21 16:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6142) Connect worker configurations and connector configurations should accept environment variables - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2017/12/21 16:17:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3184) Add Checkpoint for In-memory State Store - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/21 18:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6397) Consumer should not block setting initial positions of unavailable partitions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/21 18:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/21 19:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4436) Provide builder pattern for StreamsConfig - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/21 19:18:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/21 20:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6398) Stream-Table join fails, if table is not materialized - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/21 22:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6320) move ZK metrics in KafkaHealthCheck to ZookeeperClient - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2017/12/21 22:50:00 UTC, 19 replies.
- [jira] [Commented] (KAFKA-3174) Re-evaluate the CRC32 class performance. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:36:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3266) Implement KIP-140 RPCs and APIs for creating, altering, and listing ACLs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:36:04 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:36:04 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3400) Topic stop working / can't describe topic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:38:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3436) Speed up controlled shutdown. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:39:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3496) Add reconnect attemps policies for client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:39:02 UTC, 1 replies.
- [jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:40:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5895) Gradle 3.0+ is needed on the build - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/22 01:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5895) Gradle 3.0+ is needed on the build - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 01:53: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/12/22 01:55:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6332) Kafka system tests should use nc instead of log grep to detect start-up - posted by "Ankush Puri (JIRA)" <ji...@apache.org> on 2017/12/22 01:58:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3496) Add reconnect attemps policies for client - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/22 02:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 03:05:03 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-6380) transient failure in MetricsTest.testMetrics - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2017/12/22 08:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6320) move ZK metrics in KafkaHealthCheck to ZookeeperClient - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/22 10:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5772) Improve Util classes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 10:37:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6386) Deprecate KafkaStreams constructor taking StreamsConfig parameter - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2017/12/22 15:25:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/12/22 18:35:03 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6386) Deprecate KafkaStreams constructor taking StreamsConfig parameter - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2017/12/22 19:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5772) Improve Util classes - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/22 19:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2289) KafkaProducer logs erroneous warning on startup - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:10:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1566) Kafka environment configuration (kafka-env.sh) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:23:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2462) allow modifying soft limit for open files in Kafka startup script - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:23:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2617) Move protocol field default values to Protocol - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:24:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2794) Add group support for authorizer acls - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:24:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3923) MetricReporter interface depends on final class KafkaMetric instead of Metric interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:26:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4322) StateRestoreCallback begin and end indication - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:27:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1548) Refactor the "replica_id" in requests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/22 20:27:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/22 21:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/22 22:02:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-4333) Report consumer group coordinator id when '--list' option is used - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/12/22 22:57:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6141) Errors logs when running integration/kafka/tools/MirrorMakerIntegrationTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/23 08:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2620) Introduce Scalariform - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/23 09:00:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6400) Consider setting default cache size to zero in Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/23 20:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/23 20:37:02 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null - posted by "Andy Bryant (JIRA)" <ji...@apache.org> on 2017/12/23 22:53:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/24 02:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/24 02:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4335) FileStreamSource Connector not working for large files (~ 1GB) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/25 08:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6401) InvalidStateStoreException immediately after starting streams - posted by "Mostafa Asgari (JIRA)" <ji...@apache.org> on 2017/12/26 10:42:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6381) Improve KafkaStreamsTest for localThreadMetadata - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2017/12/26 10:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6381) Improve KafkaStreamsTest for localThreadMetadata - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2017/12/26 10:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6402) KStream Ktable join integration test fails randomly - posted by "Narendra Kumar (JIRA)" <ji...@apache.org> on 2017/12/26 17:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6401) InvalidStateStoreException immediately after starting streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/26 18:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6401) InvalidStateStoreException immediately after starting streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/26 18:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6402) KStream Ktable join integration test fails randomly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/26 18:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5946) Give connector method parameter better name - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/27 01:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6403) Why kafka sync send message with 10 seconds delay - posted by "change (JIRA)" <ji...@apache.org> on 2017/12/27 03:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6403) Why kafka sync send message with 10 seconds delay - posted by "change (JIRA)" <ji...@apache.org> on 2017/12/27 03:12:05 UTC, 4 replies.
- [jira] [Created] (KAFKA-6404) OldConsumer FetchRequest apiVersion not match resulting in broker RequestHandler socket leak - posted by "Yu Gan (JIRA)" <ji...@apache.org> on 2017/12/27 06:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6404) OldConsumer FetchRequest apiVersion not match resulting in broker RequestHandler socket leak - posted by "Yu Gan (JIRA)" <ji...@apache.org> on 2017/12/27 06:30:00 UTC, 21 replies.
- [jira] [Updated] (KAFKA-6292) KafkaConsumer ran into Unknown error fetching data for topic-partition caused by integer overflow in FileLogInputStream - posted by "Terence Yi (JIRA)" <ji...@apache.org> on 2017/12/27 07:38:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6405) Fix incorrect comment in MetadataUpdater - posted by "guangxian.liao (JIRA)" <ji...@apache.org> on 2017/12/27 07:49:02 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6292) KafkaConsumer ran into Unknown error fetching data for topic-partition caused by integer overflow in FileLogInputStream - posted by "Terence Yi (JIRA)" <ji...@apache.org> on 2017/12/27 07:49:02 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6292) KafkaConsumer ran into Unknown error fetching data for topic-partition caused by integer overflow in FileLogInputStream - posted by "Terence Yi (JIRA)" <ji...@apache.org> on 2017/12/27 07:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6405) Fix incorrect comment in MetadataUpdater - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/27 07:53:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6405) Fix incorrect comment in MetadataUpdater - posted by "guangxian.liao (JIRA)" <ji...@apache.org> on 2017/12/27 07:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6256) Flaky Unit test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache - posted by "Narendra Kumar (JIRA)" <ji...@apache.org> on 2017/12/27 16:07:02 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6397) Consumer should not block setting initial positions of unavailable partitions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2017/12/27 22:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/27 23:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6074) Use ZookeeperClient in ReplicaManager and Partition - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/28 14:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6406) Topic deletion fails and kafka shuts down (on windows only) - posted by "pre sto (JIRA)" <ji...@apache.org> on 2017/12/28 19:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6407) Sink task metrics are the same for all connectors - posted by "Alexander Koval (JIRA)" <ji...@apache.org> on 2017/12/28 20:25:04 UTC, 0 replies.
- [jira] [Created] (KAFKA-6408) Kafka MirrorMaker doesn't replicate messages when .* regex is used - posted by "Waleed Fateem (JIRA)" <ji...@apache.org> on 2017/12/28 20:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5912) Trogdor AgentTest.testAgentActivatesFaults is flaky - posted by "Wladimir Schmidt (JIRA)" <ji...@apache.org> on 2017/12/28 22:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6409) LogRecoveryTest (testHWCheckpointWithFailuresSingleLogSegment) is flaky - posted by "Wladimir Schmidt (JIRA)" <ji...@apache.org> on 2017/12/28 22:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6410) Scala ReassignPartitionsClusterTest (shouldExecuteThrottledReassignment) - posted by "Wladimir Schmidt (JIRA)" <ji...@apache.org> on 2017/12/28 22:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6410) Scala ReassignPartitionsClusterTest (shouldExecuteThrottledReassignment) - posted by "Wladimir Schmidt (JIRA)" <ji...@apache.org> on 2017/12/28 22:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6409) LogRecoveryTest (testHWCheckpointWithFailuresSingleLogSegment) is flaky - posted by "Wladimir Schmidt (JIRA)" <ji...@apache.org> on 2017/12/28 22:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6256) Flaky Unit test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/29 01:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5368) Kafka Streams skipped-records-rate sensor produces nonzero values when the timestamps are valid - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/29 02:55: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 "Per Steffensen (JIRA)" <ji...@apache.org> on 2017/12/29 11:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5686) Documentation inconsistency on the "Compression" - posted by "Sven Ludwig (JIRA)" <ji...@apache.org> on 2017/12/29 14:20:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-6411) Update KStream javadoc examples to use new StateStore API - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2017/12/29 19:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6411) Update KStream javadoc examples to use new StateStore API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/12/30 00:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets - posted by "Prasanna Subburaj (JIRA)" <ji...@apache.org> on 2017/12/30 06:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/30 08:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/30 08:20:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/30 13:42:03 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5223) Add Python support to Kafka Streams - posted by "D'yangelo Grullon (JIRA)" <ji...@apache.org> on 2017/12/30 20:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/31 17:26:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/31 17:28:03 UTC, 0 replies.