jira@kafka.apache.org, 2018-01

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

- [jira] [Commented] (KAFKA-6408) Kafka MirrorMaker doesn't replicate messages when .* regex is used - posted by "Umesh Chaudhary (JIRA)" <ji...@apache.org> on 2018/01/01 07:13:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6408) Kafka MirrorMaker doesn't replicate messages when .* regex is used - posted by "Waleed Fateem (JIRA)" <ji...@apache.org> on 2018/01/01 10:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/01 10:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute() - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/01/01 10:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute() - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/01/01 10:22:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/01 12:58:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6413) ReassignPartitionsCommand#parsePartitionReassignmentData() should give better error message when JSON is malformed - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/01 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6413) ReassignPartitionsCommand#parsePartitionReassignmentData() should give better error message when JSON is malformed - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/01 15:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/01 15:13:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6414) Inverse replication for replicas that are far behind - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/02 02:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6414) Inverse replication for replicas that are far behind - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/02 02:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6414) Inverse replication for replicas that are far behind - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/02 06:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6415) KafkaLog4jAppender deadlocks when logging from producer network thread - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/02 12:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6415) KafkaLog4jAppender deadlocks when logging from producer network thread - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/02 14:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6415) KafkaLog4jAppender deadlocks when logging from producer network thread - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/02 15:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6415) KafkaLog4jAppender deadlocks when logging from producer network thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/02 15:16:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/02 16:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/02 16:59:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6416) Create an official Kafka Helm chart for running a Kafka cluster - posted by "Matthew T. Adams (JIRA)" <ji...@apache.org> on 2018/01/02 17:04:00 UTC, 0 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 2018/01/02 17:33:00 UTC, 2 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 2018/01/02 17:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6269) KTable state restore fails after rebalance - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/02 17:43:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException - posted by "Dustin Cote (JIRA)" <ji...@apache.org> on 2018/01/02 18:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/02 18:18:03 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 "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/02 18:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/02 18:24:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6269) KTable state restore fails after rebalance - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/02 18:25:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4706) Unify StreamsKafkaClient instances - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/02 18:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6318) StreamsResetter should return non-zero return code on error - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/02 18:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4706) Unify StreamsKafkaClient instances - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/02 18:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6418) adminclient throws timeoutexception when there is a SchemaException - posted by "dan norwood (JIRA)" <ji...@apache.org> on 2018/01/02 19:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6418) adminclient throws timeoutexception when there is a SchemaException - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/01/02 20:31:03 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-6383) StreamThread.shutdown doesn't clean up completely when called before StreamThread.start - posted by "Rohan Desai (JIRA)" <ji...@apache.org> on 2018/01/02 22:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/02 22:59:00 UTC, 7 replies.
- [jira] [Commented] (KAFKA-6393) Add tool to view active brokers - posted by "Gene Yi (JIRA)" <ji...@apache.org> on 2018/01/03 03:38:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6419) Menu order in Streams docs incorrect - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/03 06:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6419) Menu order in Streams docs incorrect - posted by "Mayank Tankhiwale (JIRA)" <ji...@apache.org> on 2018/01/03 06:59:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient - posted by "Filipe Agapito (JIRA)" <ji...@apache.org> on 2018/01/03 13:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6252) A metric named 'XX' already exists, can't register another one. - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/03 15:45:01 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-6252) A metric named 'XX' already exists, can't register another one. - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/03 16:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6420) Adding Msys support - posted by "Pas (JIRA)" <ji...@apache.org> on 2018/01/03 17:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6398) Stream-Table join fails, if table is not materialized - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/03 18:31:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6398) Stream-Table join fails, if table is not materialized - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/03 18:32:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-6252) A metric named 'XX' already exists, can't register another one. - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/03 19:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6256) Flaky Unit test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/03 19:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6398) Stream-Table join fails, if table is not materialized - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/03 20:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5185) Adding the RecordMetadata that is returned by the producer to the commitRecord method for SourceTask - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/03 21:39:05 UTC, 0 replies.
- [jira] [Commented] (KAFKA-960) Upgrade Metrics to 3.x - posted by "Dave Mangot (JIRA)" <ji...@apache.org> on 2018/01/03 23:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/04 00:20:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6421) consumer group can't show when use kafka-consumer-groups tool if the leader of __consumer_offsets partition for this group changed - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/01/04 03:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6421) consumer group can't show when use kafka-consumer-groups tool if the leader of __consumer_offsets partition for this group changed - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/01/04 03:53:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-6421) consumer group can't show when use kafka-consumer-groups tool if the leader of __consumer_offsets partition for this group changed - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/01/04 05:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4513) Support migration of old consumers to new consumers without downtime - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2018/01/04 14:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6254) Introduce Incremental FetchRequests to Increase Partition Scalability - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2018/01/04 14:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6298) Line numbers on log messages are incorrect - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/04 17:00:08 UTC, 0 replies.
- [jira] [Created] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown - posted by "Xin Li (JIRA)" <ji...@apache.org> on 2018/01/04 17:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown - posted by "Xin Li (JIRA)" <ji...@apache.org> on 2018/01/04 17:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3473) KIP-237: More Controller Health Metrics - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/01/04 18:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1694) KIP-4: Command line and centralized operations - posted by "Felix GV (JIRA)" <ji...@apache.org> on 2018/01/04 19:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3473) KIP-237: More Controller Health Metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/04 19:34:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6423) Slow shutdown with many open files - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/04 23:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/04 23:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6116) Major performance issue due to excessive logging during leader election - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/01/05 01:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5642) Use async ZookeeperClient in Controller - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/01/05 01:37:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should be accept raw text - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/05 02:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6423) Slow shutdown with many open files - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/05 03:08:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown - posted by "Prasanna Subburaj (JIRA)" <ji...@apache.org> on 2018/01/05 04:56:00 UTC, 6 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 2018/01/05 05:34:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5642) Use async ZookeeperClient in Controller - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2018/01/05 05:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/05 07:03:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/05 08:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6425) Calculating cleanBytes in LogToClean might not be correct - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/01/05 09:40:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4991) KerberosLogin#login should probably be synchronized - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/05 09:44:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6426) Kafka SASL/SCRAM authentication does not fail for incorrect username or password. - posted by "Menaka Madushanka (JIRA)" <ji...@apache.org> on 2018/01/05 09:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6426) Kafka SASL/SCRAM authentication does not fail for incorrect username or password. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/05 10:04:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6338) java.lang.NoClassDefFoundError: org/apache/kafka/common/network/LoginType - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/05 12:08:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6077) Let SimpleConsumer support Kerberos authentication - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/05 12:22:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6086) Provide for custom error handling when Kafka Streams fails to produce - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/05 15:07:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6311) Expose Kafka cluster ID in Connect REST API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/05 15:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6427) Inconsistent exception type from KafkaConsumer.position - posted by "Jay Kahrman (JIRA)" <ji...@apache.org> on 2018/01/05 17:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6314) Add a tool to delete kafka based consumer offsets for a given group - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/06 00:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4834) Kafka cannot delete topic with ReplicaStateMachine went wrong - posted by "Kiran Pillarisetty (JIRA)" <ji...@apache.org> on 2018/01/06 00:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4335) FileStreamSource Connector not working for large files (~ 1GB) - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/06 02:33: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 2018/01/06 02:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6428) Fail builds on findbugs warnings - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/06 03:25:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6428) Fail builds on findbugs warnings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/06 03:48:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6252) A metric named 'XX' already exists, can't register another one. - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/06 05:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6252) A metric named 'XX' already exists, can't register another one. - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/06 05:26:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6429) dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0 - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/01/07 03:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6429) dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/07 03:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6429) dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0 - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/01/07 03:50:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/07 06:37:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/07 17:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6430) Improve Kafka GZip compression performance - posted by "Ying Zheng (JIRA)" <ji...@apache.org> on 2018/01/07 22:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6430) Improve Kafka GZip compression performance - posted by "Ying Zheng (JIRA)" <ji...@apache.org> on 2018/01/07 22:23:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6430) Improve Kafka GZip compression performance - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/07 22:24:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6431) Lock contention in Purgatory - posted by "Ying Zheng (JIRA)" <ji...@apache.org> on 2018/01/08 00:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6431) Lock contention in Purgatory - posted by "Ying Zheng (JIRA)" <ji...@apache.org> on 2018/01/08 00:08:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6432) Lookup indices may cause unnecessary page fault - posted by "Ying Zheng (JIRA)" <ji...@apache.org> on 2018/01/08 00:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6432) Lookup indices may cause unnecessary page fault - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/08 01:00:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6030) Integer overflow in log cleaner cleanable ratio computation - posted by "Xin Li (JIRA)" <ji...@apache.org> on 2018/01/08 06:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6422) When enable trace level log in mirror maker, it will throw null pointer exception and the mirror maker will shutdown - posted by "Xin Li (JIRA)" <ji...@apache.org> on 2018/01/08 06:52:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/08 12:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4908) consumer.properties logging warnings - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/08 12:09:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4315) Kafka Connect documentation problems - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/08 12:11:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-4315) Kafka Connect documentation problems - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/08 12:11:03 UTC, 0 replies.
- [jira] [Closed] (KAFKA-4908) consumer.properties logging warnings - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/08 12:11:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3039) Temporary loss of leader resulted in log being completely truncated - posted by "Vincent Da (JIRA)" <ji...@apache.org> on 2018/01/08 13:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6369) General wildcard support for ACL's in kafka - posted by "Luiz Picanço (JIRA)" <ji...@apache.org> on 2018/01/08 17:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6387) Worker's producer and consumer configs should inherit from worker configs - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/08 19:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6387) Worker's producer and consumer configs should inherit from worker configs - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/08 19:21:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6387) Worker's producer and consumer configs should inherit from worker configs - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/08 19:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/08 19:33:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should be accept raw text - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/08 19:47:01 UTC, 1 replies.
- [jira] [Updated] (KAFKA-3625) Move kafka-streams test fixtures into a published package - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/08 21:05:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/08 21:22:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-6428) Fail builds on findbugs warnings - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/08 22:10:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/08 22:17:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/08 22:31:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Joerg Heinicke (JIRA)" <ji...@apache.org> on 2018/01/08 23:13:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6433) Connect distributed workers should fail if their config is "incompatible" with leader's - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/08 23:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6433) Connect distributed workers should fail if their config is "incompatible" with leader's - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/08 23:23:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6433) Connect distributed workers should fail if their config is "incompatible" with leader's - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/08 23:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/08 23:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6096) Add concurrent tests to exercise all paths in group/transaction managers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/09 00:16:17 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6384) TransactionsTest#testFencingOnSendOffsets sometimes fails with ProducerFencedException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/09 02:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/09 02:36:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6403) Why kafka sync send message with 10 seconds delay - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/09 04:02:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4686) Null Message payload is shutting down broker - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/09 04:05:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6396) Possibly kafka-connect converter should be able to stop processing chain - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/09 05:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4674) Frequent ISR shrinking and expanding and disconnects among brokers - posted by "Andrey Falko (JIRA)" <ji...@apache.org> on 2018/01/09 06:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group - posted by "George Smith (JIRA)" <ji...@apache.org> on 2018/01/09 08:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3893) Kafka Broker ID disappears from /brokers/ids - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/09 08:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/09 09:09:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-5850) Py4JJavaError: An error occurred while calling o40.loadClass. : java.lang.ClassNotFoundException: org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/09 09:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6171) [1.0.0] Logging is broken with Windows and Java 9 - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/09 10:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6180) Add a Validator for NonNull configurations and remove redundant null checks on lists - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/09 10:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group - posted by "George Smith (JIRA)" <ji...@apache.org> on 2018/01/09 12:23:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5624) Unsafe use of expired sensors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/09 17:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4247) kafka-run-class has potential to add a leading colon to classpath - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/09 18:25:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-2984) KTable should send old values along with new values to downstreams - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2018/01/09 18:54:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-2984) KTable should send old values along with new values to downstreams - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2018/01/09 18:57:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6287) Inconsistent protocol type for empty consumer groups - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/09 22:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6180) Add a Validator for NonNull configurations and remove redundant null checks on lists - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/09 23:13:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/09 23:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4029) SSL support for Connect REST API - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/10 00:20:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/10 01:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6436) Provide a metric indicating broker cluster membership state - posted by "Lukasz Mierzwa (JIRA)" <ji...@apache.org> on 2018/01/10 04:58:03 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5624) Unsafe use of expired sensors - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/10 08:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2018/01/10 10:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1229) Reload broker config without a restart - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/10 10:42:04 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5946) Give connector method parameter better name - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/10 11:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2025) In multi-consumer setup - explicit commit, commits on all partitions - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/10 14:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2329) Consumers balance fails when multiple consumers are started simultaneously. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/10 14:34:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2331) Kafka does not spread partitions in a topic among all consumers evenly - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/10 14:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6437) Streams does not warn about missing input topics, but hangs - posted by "Chris Schwarzfischer (JIRA)" <ji...@apache.org> on 2018/01/10 15:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6437) Streams does not warn about missing input topics, but hangs - posted by "Chris Schwarzfischer (JIRA)" <ji...@apache.org> on 2018/01/10 15:10:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6438) NSEE while concurrently creating and deleting a topic - posted by "Adam Kotwasinski (JIRA)" <ji...@apache.org> on 2018/01/10 15:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/10 15:57:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6439) We are using streamset to produce data into kafka topic (3 node cluster). We are facing following error frequently in production. - posted by "srithar durairaj (JIRA)" <ji...@apache.org> on 2018/01/10 16:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6439) "com.streamsets.pipeline.api.StageException: KAFKA_50 - Error writing data to the Kafka broker: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.NetworkException: The server disconnected before a response was received" - posted by "srithar durairaj (JIRA)" <ji...@apache.org> on 2018/01/10 16:09:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3625) Move kafka-streams test fixtures into a published package - posted by "Scott Davis (JIRA)" <ji...@apache.org> on 2018/01/10 16:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6438) NSEE while concurrently creating and deleting a topic - posted by "Adam Kotwasinski (JIRA)" <ji...@apache.org> on 2018/01/10 17:05:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6438) NSEE while concurrently creating and deleting a topic - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/10 17:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/10 19:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/10 19:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6440) Expose Connect leader via REST - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/10 20:20:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6440) Expose Connect leader via REST - posted by "Ryan P (JIRA)" <ji...@apache.org> on 2018/01/10 20:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6440) Expose Connect leader via REST - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/10 20:25:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4711) Change Default unclean.leader.election.enabled from True to False (KIP-106) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/10 21:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/10 22:02:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/10 22:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/10 22:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6265) GlobalKTable missing #queryableStoreName() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/11 01:51:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/11 05:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/11 05:16:02 UTC, 4 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/11 05:16:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately - posted by "Frederic Arno (JIRA)" <ji...@apache.org> on 2018/01/11 08:51:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5504) Kafka controller is not getting elected - posted by "Lakshmi G S (JIRA)" <ji...@apache.org> on 2018/01/11 10:40:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6442) Catch 22 with cluster rebalancing - posted by "Andreas (JIRA)" <ji...@apache.org> on 2018/01/11 17:05:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6442) Catch 22 with cluster rebalancing - posted by "Andreas (JIRA)" <ji...@apache.org> on 2018/01/11 17:06:00 UTC, 20 replies.
- [jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2018/01/11 19:06:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-5413) Log cleaner fails due to large offset in segment file - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2018/01/11 19:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6443) KTable involved in multiple joins could result in duplicate results - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/11 19:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6443) KTable involved in multiple joins could result in duplicate results - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/11 19:22:01 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6205) Have State Stores Restore Before Initializing Toplogy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/11 19:28:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6442) Catch 22 with cluster rebalancing - posted by "Jan Filipiak (JIRA)" <ji...@apache.org> on 2018/01/11 21:46:02 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters - posted by "Peter Davis (JIRA)" <ji...@apache.org> on 2018/01/11 23:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/11 23:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6250) Kafka Connect requires permission to create internal topics even if they exist - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/11 23:57:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6185) Selector memory leak with high likelihood of OOM in case of down conversion - posted by "Brett Rann (JIRA)" <ji...@apache.org> on 2018/01/12 01:56:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name. - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/12 10:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6310) ConcurrentModificationException when reporting requests-in-flight in producer - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/12 10:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6204) Interceptor and MetricsReporter should implement java.io.Closeable - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/12 10:23: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 2018/01/12 16:45:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5540) Deprecate and remove internal converter configs - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/12 18:32:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/01/12 20:01:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/12 22:28:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group - posted by "Satyajit varma (JIRA)" <ji...@apache.org> on 2018/01/13 00:00:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6309) add support for getting topic defaults from AdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/13 01:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/13 01:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/01/13 05:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6409) LogRecoveryTest (testHWCheckpointWithFailuresSingleLogSegment) is flaky - posted by "Wladimir Schmidt (JIRA)" <ji...@apache.org> on 2018/01/13 12:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6410) Scala ReassignPartitionsClusterTest (shouldExecuteThrottledReassignment) - posted by "Wladimir Schmidt (JIRA)" <ji...@apache.org> on 2018/01/13 12:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read - posted by "Filipe Agapito (JIRA)" <ji...@apache.org> on 2018/01/13 16:54:02 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read - posted by "Filipe Agapito (JIRA)" <ji...@apache.org> on 2018/01/13 16:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3347) Configure java to prefer ipv4 - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/13 19:26:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6444) Kafka consumers and producers get confused by dualstack A + AAAA DNS records - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/13 19:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS - posted by "Prasanna Gautam (JIRA)" <ji...@apache.org> on 2018/01/13 21:01:04 UTC, 0 replies.
- [jira] [Created] (KAFKA-6445) Remove deprecated metrics in 2.0 - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/15 09:48:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name. - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/15 09:50:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name. - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/15 09:54:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6445) Remove deprecated metrics in 2.0 - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/15 09:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down - posted by "Eduardo Sciullo (JIRA)" <ji...@apache.org> on 2018/01/15 10:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6447) Add Delegation Token Operations to KafkaAdminClient - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/15 11:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6447) Add Delegation Token Operations to KafkaAdminClient - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/15 11:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1704) Add PartitionConfig besides LogConfig - posted by "arpit (JIRA)" <ji...@apache.org> on 2018/01/15 12:31:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1704) Add PartitionConfig besides LogConfig - posted by "arpit (JIRA)" <ji...@apache.org> on 2018/01/15 12:31:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer - posted by "Claus Ibsen (JIRA)" <ji...@apache.org> on 2018/01/15 13:33:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6448) Mx4jLoader#props.getBoolean("kafka_mx4jenable", false) conflict with the annotation - posted by "Hongyuan Li (JIRA)" <ji...@apache.org> on 2018/01/16 02:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6448) Mx4jLoader#props.getBoolean("kafka_mx4jenable", false) conflict with the annotation - posted by "Hongyuan Li (JIRA)" <ji...@apache.org> on 2018/01/16 02:09:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-6448) Mx4jLoader#props.getBoolean("kafka_mx4jenable", false) conflict with the annotation - posted by "Hongyuan Li (JIRA)" <ji...@apache.org> on 2018/01/16 02:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2018/01/16 09:13:04 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2018/01/16 09:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6449) KafkaConsumer happen 40s timeOut when poll data after pollThread sleep more than request.timeout.ms - posted by "zhaoshijie (JIRA)" <ji...@apache.org> on 2018/01/16 10:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6449) KafkaConsumer happen 40s timeOut when poll data after pollThread sleep more than request.timeout.ms - posted by "zhaoshijie (JIRA)" <ji...@apache.org> on 2018/01/16 11:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down - posted by "Eduardo Sciullo (JIRA)" <ji...@apache.org> on 2018/01/16 13:03:03 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2018/01/16 13:03:03 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4934) Add streams test with RocksDb failures - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2018/01/16 13:03:03 UTC, 0 replies.
- [jira] [Created] (KAFKA-6450) Kafka Transaction with auto-commit=false, showing transaction log as a consumer lag - posted by "Mayur Patil (JIRA)" <ji...@apache.org> on 2018/01/16 15:16:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6269) KTable state restore fails after rebalance - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2018/01/16 15:44:00 UTC, 10 replies.
- [jira] [Created] (KAFKA-6451) Simplify KStreamReduce - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/16 17:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4542) Add authentication based on delegation token. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/16 18:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4542) Add authentication based on delegation token. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/16 18:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4543) Add capability to renew/expire delegation tokens. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/16 18:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3514) Stream timestamp computation needs some further thoughts - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/16 18:16:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6452) Add documentation for delegation token authentication mechanism - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/16 18:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6212) Kafka Streams - Incorrect partition rebalancing - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/16 18:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6453) Reconsider timestamp propagation semantics - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/16 18:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6454) Allow timestamp manipulation in Processor API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/16 18:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6455) Improve timestamp propagation at DSL level - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/16 18:29:07 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6447) Add Delegation Token Operations to KafkaAdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/16 18:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4686) Null Message payload is shutting down broker - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/16 18:51:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5445) Document exceptions thrown by AdminClient methods - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/16 18:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6384) TransactionsTest#testFencingOnSendOffsets sometimes fails with ProducerFencedException - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/16 19:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6451) Simplify KStreamReduce - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2018/01/16 20:22:01 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-6451) Simplify KStreamReduce - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2018/01/16 20:22:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6277) Make loadClass thread-safe for class loaders of Connect plugins - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/16 20:41:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6253) Improve sink connector topic regex validation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/16 22:44:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6386) Deprecate KafkaStreams constructor taking StreamsConfig parameter - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/17 00:45:17 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/17 00:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/17 02:09:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/17 02:15:03 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6449) KafkaConsumer happen 40s timeOut when poll data after pollThread sleep more than request.timeout.ms - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/01/17 05:45:04 UTC, 4 replies.
- [jira] [Created] (KAFKA-6456) Improve JavaDoc of SourceTask - posted by "Gunnar Morling (JIRA)" <ji...@apache.org> on 2018/01/17 09:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6456) Improve JavaDoc of SourceTask#poll() - posted by "Gunnar Morling (JIRA)" <ji...@apache.org> on 2018/01/17 09:25:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-2170) 10 LogTest cases failed for file.renameTo failed under windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/17 09:27:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6456) Improve JavaDoc of SourceTask#poll() to discourage indefinite blocking - posted by "Gunnar Morling (JIRA)" <ji...@apache.org> on 2018/01/17 09:31:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Georgij Cernysiov (JIRA)" <ji...@apache.org> on 2018/01/17 09:42:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6456) Improve JavaDoc of SourceTask#poll() to discourage indefinite blocking - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/17 10:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6457) Error: NOT_LEADER_FOR_PARTITION leads to NPE - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/17 14:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6458) ERROR Found invalid messages during fetch for partition [__consumer_offsets,20] offset 0 error Record is corrupt (stored crc = 73, computed crc = 2559213387) (kafka.server.ReplicaFetcherThread) - posted by "VinayKumar (JIRA)" <ji...@apache.org> on 2018/01/17 19:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6382) Make ProducerConfig and ConsumerConfig constructors public - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/17 19:26:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/17 19:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/17 19:34:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6302) Topic can not be recreated after it is deleted - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/17 22:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6277) Make loadClass thread-safe for class loaders of Connect plugins - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/01/17 22:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6287) Inconsistent protocol type for empty consumer groups - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/18 01:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/01/18 19:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1120) Controller could miss a broker state change - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2018/01/18 19:57:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-1120) Controller could miss a broker state change - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2018/01/18 19:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5083) always leave the last surviving member of the ISR in ZK - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2018/01/18 20:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6398) Non-aggregation KTable generation operator does not construct value getter correctly - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/18 21:17:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4932) Add UUID Serde - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/18 21:58:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/18 22:13:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3184) Add Checkpoint for In-memory State Store - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/18 22:30:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/18 22:55:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/18 22:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6185) Selector memory leak with high likelihood of OOM in case of down conversion - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2018/01/18 22:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6462) ResetIntegrationTest unstable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/19 00:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6462) ResetIntegrationTest unstable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/19 01:08:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/19 01:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3741) Allow setting of default topic configs via StreamsConfig - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2018/01/19 08:54:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6463) Review logging level for user errors in AdminManager - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/19 11:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer) - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2018/01/19 16:29:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/19 22:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5889) MetricsTest is flaky - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/20 15:29:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should accept raw text - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/20 16:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion() - posted by "Yu LIU (JIRA)" <ji...@apache.org> on 2018/01/20 21:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/20 21:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/01/21 06:26:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/01/21 06:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/01/21 07:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/01/21 07:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/01/21 07:07:02 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5085) Add test for rebalance exceptions - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/01/21 07:12: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 2018/01/21 18:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6464) Base64URL encoding under JRE 1.7 is broken due to incorrect padding assumption - posted by "Ron Dagostino (JIRA)" <ji...@apache.org> on 2018/01/21 22:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6464) Base64URL encoding under JRE 1.7 is broken due to incorrect padding assumption - posted by "Ron Dagostino (JIRA)" <ji...@apache.org> on 2018/01/21 22:41:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6464) Base64URL encoding under JRE 1.7 is broken due to incorrect padding assumption - posted by "Ron Dagostino (JIRA)" <ji...@apache.org> on 2018/01/21 22:44:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6465) Add a metrics for the number of records per log - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/01/22 01:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6277) Make loadClass thread-safe for class loaders of Connect plugins - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/22 03:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6466) Kafka connect task sometimes fails on start-up - posted by "Alexander Koval (JIRA)" <ji...@apache.org> on 2018/01/22 12:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "Martin Nowak (JIRA)" <ji...@apache.org> on 2018/01/22 13:49:01 UTC, 4 replies.
- [jira] [Commented] (KAFKA-3988) KafkaConfigBackingStore assumes configs will be stored as schemaless maps - posted by "Hon Chau (JIRA)" <ji...@apache.org> on 2018/01/22 19:38:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182 - posted by "Yu LIU (JIRA)" <ji...@apache.org> on 2018/01/22 21:27:02 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182 - posted by "Yu LIU (JIRA)" <ji...@apache.org> on 2018/01/22 21:27:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/22 22:16:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/22 22:17:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3988) KafkaConfigBackingStore assumes configs will be stored as schemaless maps - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/22 22:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3988) KafkaConfigBackingStore assumes configs will be stored as schemaless maps - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/22 22:21:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2018/01/22 22:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2018/01/22 22:33:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6467) Enforce layout of dependencies within a Connect plugin to be deterministic - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/01/23 00:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6467) Enforce layout of dependencies within a Connect plugin to be deterministic - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/01/23 00:09:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6466) Kafka connect task sometimes fails on start-up - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/23 01:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6466) Kafka connect task sometimes fails on start-up - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/23 01:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6468) Replication high watermark checkpoint file read for every LeaderAndIsrRequest - posted by "Kyle Ambroff-Kao (JIRA)" <ji...@apache.org> on 2018/01/23 03:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6469) ISR change notification queue has a maximum size - posted by "Kyle Ambroff-Kao (JIRA)" <ji...@apache.org> on 2018/01/23 03:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6468) Replication high watermark checkpoint file read for every LeaderAndIsrRequest - posted by "Kyle Ambroff-Kao (JIRA)" <ji...@apache.org> on 2018/01/23 03:34:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6469) ISR change notification queue has a maximum size - posted by "Kyle Ambroff-Kao (JIRA)" <ji...@apache.org> on 2018/01/23 03:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6469) ISR change notification queue can prevent controller from making progress - posted by "Kyle Ambroff-Kao (JIRA)" <ji...@apache.org> on 2018/01/23 04:06:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6469) ISR change notification queue can prevent controller from making progress - posted by "Kyle Ambroff-Kao (JIRA)" <ji...@apache.org> on 2018/01/23 04:10:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-6468) Replication high watermark checkpoint file read for every LeaderAndIsrRequest - posted by "Kyle Ambroff-Kao (JIRA)" <ji...@apache.org> on 2018/01/23 04:16:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6469) ISR change notification queue can prevent controller from making progress - posted by "Kyle Ambroff-Kao (JIRA)" <ji...@apache.org> on 2018/01/23 04:16:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6470) no continuous offset for function seek - posted by "chao.wu (JIRA)" <ji...@apache.org> on 2018/01/23 05:23:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-6471) seekToEnd and seek give unclear results for Consumer with read_committed isolation level - posted by "Coen Damen (JIRA)" <ji...@apache.org> on 2018/01/23 08:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6472) WordCount example code error - posted by "JONYhao (JIRA)" <ji...@apache.org> on 2018/01/23 10:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6470) no continuous offset for function seek - posted by "chao.wu (JIRA)" <ji...@apache.org> on 2018/01/23 10:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6472) WordCount example code error - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/23 17:18:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-6473) Add MockProcessorContext to public test-utils - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/23 20:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/23 20:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6472) WordCount example code error - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/23 21:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime - posted by "Nick Afshartous (JIRA)" <ji...@apache.org> on 2018/01/23 21:32:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6475) ConfigException on the broker results in UnknownServerException in the admin client - posted by "Xavier Léauté (JIRA)" <ji...@apache.org> on 2018/01/23 22:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6471) seekToEnd and seek give unclear results for Consumer with read_committed isolation level - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/23 22:40:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6473) Add MockProcessorContext to public test-utils - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/23 23:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/23 23:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6476) Document dynamic config update - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/23 23:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6243) Enable reconfiguration of metrics reporters and their custom configs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/23 23:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6244) Enable dynamic reconfiguration of log cleaners - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/24 00:19:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6058) Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2018/01/24 00:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6058) KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2018/01/24 00:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6058) KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient - posted by "Jeff Widman (JIRA)" <ji...@apache.org> on 2018/01/24 00:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6245) Enable reconfiguration of default topic configs used by brokers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/24 00:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/01/24 00:46:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/01/24 00:47:00 UTC, 7 replies.
- [jira] [Comment Edited] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/01/24 02:51:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6287) Inconsistent protocol type for empty consumer groups - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/24 04:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6421) consumer group can't show when use kafka-consumer-groups tool if the leader of __consumer_offsets partition for this group changed - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/24 04:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/24 04:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6477) Add Support for Quorum-based Producer Acknowledgment - posted by "Litao Deng (JIRA)" <ji...@apache.org> on 2018/01/24 04:31:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6477) Add Support for Quorum-based Producer Acknowledge - posted by "Litao Deng (JIRA)" <ji...@apache.org> on 2018/01/24 04:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5142) KIP-145 - Expose Record Headers in Kafka Connect - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/24 07:32:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6471) seekToEnd and seek give unclear results for Consumer with read_committed isolation level - posted by "Coen Damen (JIRA)" <ji...@apache.org> on 2018/01/24 07:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6478) kafka-run-class.bat fails if CLASSPATH contains spaces - posted by "Bert Roos (JIRA)" <ji...@apache.org> on 2018/01/24 10:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6457) Error: NOT_LEADER_FOR_PARTITION leads to NPE - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/24 11:22:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4292) KIP-86: Configurable SASL callback handlers - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/24 15:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6475) ConfigException on the broker results in UnknownServerException in the admin client - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/01/24 17:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6475) ConfigException on the broker results in UnknownServerException in the admin client - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/01/24 17:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6418) AdminClient should handle empty or null topic names better - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/01/24 17:39:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6418) AdminClient should handle empty or null topic names better - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/01/24 17:41:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6479) Broker file descriptor leak after consumer request timeout - posted by "Ryan Leslie (JIRA)" <ji...@apache.org> on 2018/01/24 17:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6242) Enable resizing various broker thread pools - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/24 18:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6480) Add config to enforce max fetch size on the broker - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/24 19:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4985) kafka-acls should resolve dns names and accept ip ranges - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/01/24 22:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6481) Improving performance of the function ControllerChannelManager.addUpdateMetadataRequestForBrokers - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/01/24 23:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6481) Improving performance of the function ControllerChannelManager.addUpdateMetadataRequestForBrokers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/25 00:16:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6481) Improving performance of the function ControllerChannelManager.addUpdateMetadataRequestForBrokers - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/01/25 00:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/25 02:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/25 02:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2018/01/25 08:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2018/01/25 09:01:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2018/01/25 09:02:00 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2018/01/25 09:28:00 UTC, 2 replies.
- [jira] [Closed] (KAFKA-6180) Add a Validator for NonNull configurations and remove redundant null checks on lists - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2018/01/25 10:02:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams - posted by "Tamas Cserveny (JIRA)" <ji...@apache.org> on 2018/01/25 13:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams - posted by "Tamas Cserveny (JIRA)" <ji...@apache.org> on 2018/01/25 13:23:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams - posted by "Tamas Cserveny (JIRA)" <ji...@apache.org> on 2018/01/25 13:25:00 UTC, 2 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 2018/01/25 13:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6484) 'ConsumerGroupCommand' performance optimization for old consumer describe group - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2018/01/25 14:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2018/01/25 14:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2018/01/25 14:40:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group - posted by "HongLiang (JIRA)" <ji...@apache.org> on 2018/01/25 14:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4256) Use IP for ZK broker register - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/25 15:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1475) Kafka consumer stops LeaderFinder/FetcherThreads, but application does not know - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/25 15:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1458) kafka hanging on shutdown - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/25 15:38:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions - posted by "Valentino Proietti (JIRA)" <ji...@apache.org> on 2018/01/25 15:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5500) it is impossible to have custom Login Modules for PLAIN SASL mechanism - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/25 15:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5617) Update to the list of third-party clients - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/25 15:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3408) consumer rebalance fail - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/25 16:04:02 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4185) Abstract out password verifier in SaslServer as an injectable dependency - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/25 16:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6091) Authorization API is called hundred's of times when there are no privileges - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/25 17:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6429) dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0 - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/25 17:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6388) Error while trying to roll a segment that already exists - posted by "Paul Davidson (JIRA)" <ji...@apache.org> on 2018/01/25 19:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/25 19:53:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6254) Introduce Incremental FetchRequests to Increase Partition Scalability - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/01/25 20:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/25 20:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/25 20:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/25 21:12:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6488) Prevent log corruption in case of OOM - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/01/25 21:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91) - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/01/25 23:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/26 00:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6489) Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2018/01/26 04:33:00 UTC, 0 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 2018/01/26 04:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6489) Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/26 05:21:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6490) JSON SerializationException Stops Connect - posted by "William R. Speirs (JIRA)" <ji...@apache.org> on 2018/01/26 15:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4991) KerberosLogin#login should probably be synchronized - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/26 16:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6467) Enforce layout of dependencies within a Connect plugin to be deterministic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/26 16:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6080) Transactional EoS for source connectors - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/26 16:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6080) Transactional EoS for source connectors - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/26 16:49:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6467) Enforce layout of dependencies within a Connect plugin to be deterministic - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/26 16:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering. - posted by "simonxia (JIRA)" <ji...@apache.org> on 2018/01/26 18:11:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2018/01/26 18:35:01 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5228) Revisit Streams DSL JavaDocs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/26 18:50:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4898) Add timeouts to streams integration tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/26 18:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4953) Global Store: cast exception when initialising with in-memory logged state store - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/26 19:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6491) Large uncompacted __consumer_offsets files should not make broker restarts slow - posted by "Mike Mintz (JIRA)" <ji...@apache.org> on 2018/01/26 20:58: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 2018/01/26 21:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/26 21:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/26 21:28:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5660) Don't throw TopologyBuilderException during runtime - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/26 21:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/26 22:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6275) Extend consumer offset reset tool to support deletion (KIP-229) - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/01/26 22:31:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams - posted by "Tamas Cserveny (JIRA)" <ji...@apache.org> on 2018/01/26 23:02:00 UTC, 1 replies.
- [jira] [Closed] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams - posted by "Tamas Cserveny (JIRA)" <ji...@apache.org> on 2018/01/27 00:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6490) JSON SerializationException Stops Connect - posted by "Prasanna Subburaj (JIRA)" <ji...@apache.org> on 2018/01/27 00:36:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3832) Kafka Connect's JSON Converter never outputs a null value - posted by "Prasanna Subburaj (JIRA)" <ji...@apache.org> on 2018/01/27 00:56:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6288) Broken symlink interrupts scanning the plugin path - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/27 01:22:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6288) Broken symlink interrupts scanning the plugin path - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/01/27 01:25:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6148) ClassCastException in BigQuery connector - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/01/27 01:26:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4850) RocksDb cannot use Bloom Filters - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5876) IQ should throw different exceptions for different errors - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-2334) Prevent HW from going back during leader failover - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3514) Stream timestamp computation needs some further thoughts - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4628) Support KTable/GlobalKTable Joins - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:23:01 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4696) Streams standby task assignment should be state-store aware - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4904) Performance of RocksDb with state record cache - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4730) Streams does not have an in-memory windowed store - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5219) Move transaction expiration logic and scheduling to the Transaction Manager - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5748) Fix console producer to set timestamp and partition - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5493) Optimize calls to flush for tasks and standby tasks - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5441) Fix transaction marker grouping by producerId in TC - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5533) Timestamp-based log compaction - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5524) Streams systems tests should be with EoS - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6098) Delete and Re-create topic operation could result in race condition - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1548) Refactor the "replica_id" in requests - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5509) add gradle option for building tarball with test jars - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:29:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4651) Improve test coverage of Stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:29:02 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:29:02 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4640) Improve Streams unit test coverage - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:29:02 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4641) Improve test coverage of StreamsThread - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:29:02 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-5509) add gradle option for building tarball with test jars - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/27 04:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6240) Support dynamic updates of frequently updated broker configs - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/27 20:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6245) Enable reconfiguration of default topic configs used by brokers - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/27 20:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector - posted by "Oleg Kuznetsov (JIRA)" <ji...@apache.org> on 2018/01/28 09:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6352) Delay message down-conversion until response is ready to be sent - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/28 22:19:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2018/01/29 00:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/29 04:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6493) Cannot use kafka.metrics.KafkaCSVMetricsReporter - posted by "okkez (JIRA)" <ji...@apache.org> on 2018/01/29 06:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down - posted by "Yu LIU (JIRA)" <ji...@apache.org> on 2018/01/29 09:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down - posted by "Yu LIU (JIRA)" <ji...@apache.org> on 2018/01/29 10:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed" - posted by "Dmitriy Matveev (JIRA)" <ji...@apache.org> on 2018/01/29 10:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6494) Extend ConfigCommand to update broker config using new AdminClient - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/29 10:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6495) Race condition when creating and deleting quickly topics may lead to metrics leak - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2018/01/29 13:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6496) NAT and Kafka - posted by "Ronald van de Kuil (JIRA)" <ji...@apache.org> on 2018/01/29 14:03:02 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6484) 'ConsumerGroupCommand' performance optimization for old consumer describe group - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/29 15:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6484) 'ConsumerGroupCommand' performance optimization for old consumer describe group - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/29 15:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6195) DNS alias support for secured connections - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/29 17:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6079) Idempotent production for source connectors - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/29 18:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6497) streams#store ambiguous InvalidStateStoreException - posted by "Pegerto Fernandez (JIRA)" <ji...@apache.org> on 2018/01/29 18:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6498) Add RocksDB statistics via Streams metrics - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/29 18:56:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6497) streams#store ambiguous InvalidStateStoreException - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/29 19:02:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-1923) Negative offsets in replication-offset-checkpoint file - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:41:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5975) No response when deleting topics and delete.topic.enable=false - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:42:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6364) Add Second Check for End Offset During Restore - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:42:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/29 19:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6148) ClassCastException in BigQuery connector - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/01/29 19:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6280) Allow for additional archive types to be loaded from plugin.path in Connect - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/01/29 20:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6451) Simplify KStreamReduce - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/30 01:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5824) Cannot write to key value store provided by ProcessorTopologyTestDriver - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/30 01:48:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5253) KStreamTestDriver must handle streams created with patterns - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/30 02:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/30 02:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6496) NAT and Kafka - posted by "hanwei (JIRA)" <ji...@apache.org> on 2018/01/30 02:39:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6500) Can not build aggregatedJavadoc - posted by "Pavel Timofeev (JIRA)" <ji...@apache.org> on 2018/01/30 04:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/30 04:42:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception - posted by "Tim Van Laer (JIRA)" <ji...@apache.org> on 2018/01/30 09:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6497) streams#store ambiguous InvalidStateStoreException - posted by "Pegerto Fernandez (JIRA)" <ji...@apache.org> on 2018/01/30 09:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors - posted by "Pegerto Fernandez (JIRA)" <ji...@apache.org> on 2018/01/30 09:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2018/01/30 10:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6501) Add test to verify markPartitionsForTruncation after fetcher thread pool resize - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/30 12:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6501) Add test to verify markPartitionsForTruncation after fetcher thread pool resize - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/01/30 12:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records - posted by "Soby Chacko (JIRA)" <ji...@apache.org> on 2018/01/30 12:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6490) JSON SerializationException Stops Connect - posted by "William R. Speirs (JIRA)" <ji...@apache.org> on 2018/01/30 13:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6503) Connect: Plugin scan is very slow - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2018/01/30 14:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6504) Connect: Some per-task-metrics not working - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2018/01/30 14:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2018/01/30 14:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2018/01/30 14:58:01 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5882) NullPointerException in StreamTask - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/30 15:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/30 15:22:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/01/30 15:22:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6246) Enable reconfiguration of listeners and security configs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/30 15:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6464) Base64URL encoding under JRE 1.7 is broken due to incorrect padding assumption - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/01/30 16:07:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6464) Base64URL encoding under JRE 1.7 is broken due to incorrect padding assumption - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/01/30 16:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6148) ClassCastException in BigQuery connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/30 16:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/30 18:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6345) NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/30 18:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2018/01/30 18:22:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6452) Add documentation for delegation token authentication mechanism - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/30 19:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6418) AdminClient should handle empty or null topic names better - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/30 22:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4029) SSL support for Connect REST API - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/30 23:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5660) Don't throw TopologyBuilderException during runtime - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/30 23:37:01 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/30 23:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/30 23:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4930) Connect Rest API allows creating connectors with an empty name - KIP-212 - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/31 00:33:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/31 01:13:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/01/31 01:13:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6454) Allow timestamp manipulation in Processor API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/31 01:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6454) Allow timestamp manipulation in Processor API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/31 01:48:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6506) Integration or unit test for Connect REST SSL Support - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/31 01:54:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets - posted by "Mayank Tankhiwale (JIRA)" <ji...@apache.org> on 2018/01/31 04:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6452) Add documentation for delegation token authentication mechanism - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/31 06:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2018/01/31 10:22:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null - posted by "Damian Guy (JIRA)" <ji...@apache.org> on 2018/01/31 10:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric - posted by "Per Steffensen (JIRA)" <ji...@apache.org> on 2018/01/31 13:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6507) NPE in KafkaStatusBackingStore - posted by "Itay Cohai (JIRA)" <ji...@apache.org> on 2018/01/31 13:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6508) Look into optimizing StreamPartitionAssignor StandbyTask Assignment - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/31 15:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6509) Add additional tests for validating store restoration completes before Topology is intitalized - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/31 15:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6498) Add RocksDB statistics via Streams metrics - posted by "james chien (JIRA)" <ji...@apache.org> on 2018/01/31 15:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6503) Connect: Plugin scan is very slow - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/31 15:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6503) Connect: Plugin scan is very slow - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/31 15:35:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4930) Connect Rest API allows creating connectors with an empty name - KIP-212 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/01/31 16:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6510) WARN: Fail to send SSL Close message - posted by "John Chu (JIRA)" <ji...@apache.org> on 2018/01/31 16:53:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/31 16:55:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/01/31 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6510) WARN: Fail to send SSL Close message - posted by "John Chu (JIRA)" <ji...@apache.org> on 2018/01/31 17:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6510) WARN: Failed to send SSL Close message java.io.IOException: Unexpected status returned by SSLEngine.wrap, expected CLOSED, received OK. - posted by "John Chu (JIRA)" <ji...@apache.org> on 2018/01/31 17:06:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6503) Connect: Plugin scan is very slow - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/31 17:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2404) Delete config znode when config values are empty - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/01/31 18:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5142) KIP-145 - Expose Record Headers in Kafka Connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/01/31 18:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/01/31 18:59:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-2334) Prevent HW from going back during leader failover - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/01/31 19:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6511) Connect header parser incorrectly parses arrays - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2018/01/31 19:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6511) Connect header parser incorrectly parses arrays - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/01/31 20:23:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/31 21:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled - posted by "Kyle Tinker (JIRA)" <ji...@apache.org> on 2018/01/31 22:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/01/31 23:35:00 UTC, 0 replies.