You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Commented] (KAFKA-6555) Making state store queryable during restoration - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/01 00:07:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6327) IllegalArgumentException in RocksDB when RocksDBException being generated - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/01 01:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/01 02:14:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6348) Kafka consumer can't restore from coordinator failure - posted by "sikaijian (JIRA)" <ji...@apache.org> on 2018/03/01 03:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4936) Allow dynamic routing of output records - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/01 03:21:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-4831) Extract WindowedSerde to public APIs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/01 04:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/01 06:09:00 UTC, 12 replies.
- [jira] [Resolved] (KAFKA-6396) Possibly kafka-connect converter should be able to stop processing chain - posted by "Alexander Koval (JIRA)" <ji...@apache.org> on 2018/03/01 11:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver - posted by "Filipe Agapito (JIRA)" <ji...@apache.org> on 2018/03/01 14:37:00 UTC, 15 replies.
- [jira] [Assigned] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver - posted by "Filipe Agapito (JIRA)" <ji...@apache.org> on 2018/03/01 14:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/01 17:28:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/01 17:28:01 UTC, 4 replies.
- [jira] [Created] (KAFKA-6602) Support Kafka to save credentials in Java Key Store on Zookeeper node - posted by "Chen He (JIRA)" <ji...@apache.org> on 2018/03/01 18:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6602) Support Kafka to save credentials in Java Key Store on Zookeeper node - posted by "Chen He (JIRA)" <ji...@apache.org> on 2018/03/01 18:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/01 19:05:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/01 19:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration - posted by "Igor Calabria (JIRA)" <ji...@apache.org> on 2018/03/01 19:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/01 20:56:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6604) ReplicaManager should not remove partitions on the log dirctory from high watermark checkpoint file - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/01 21:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6604) ReplicaManager should not remove partitions on the log dirctory from high watermark checkpoint file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/01 21:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6605) Flatten SMT does not properly handle fields that are null - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/01 22:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6605) Flatten SMT does not properly handle fields that are null - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/01 22:39:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-3513) Transient failure of OffsetValidationTest - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/01 22:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/01 23:33:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6348) Kafka consumer can't restore from coordinator failure - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/02 01:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6111) Tests for KafkaZkClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/02 01:49:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6595) Kafka connect commit offset incorrectly. - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/02 02:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer` - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/02 02:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer` - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/02 04:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/02 06:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/02 06:47:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6123) Give MetricsReporter auto-generated client.id - posted by "Kevin Lu (JIRA)" <ji...@apache.org> on 2018/03/02 09:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/02 16:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6473) Add MockProcessorContext to public test-utils - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/03/02 18:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/02 21:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6606) Regression in consumer auto-commit backoff behavior - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/02 21:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6606) Regression in consumer auto-commit backoff behavior - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/02 21:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/02 23:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6606) Regression in consumer auto-commit backoff behavior - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/03 01:23:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/03 04:54:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/03 05:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1954) Speed Up The Unit Tests - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/03 06:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1368) Upgrade log4j - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/03 06:27:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-4854) Producer RecordBatch executes callbacks with `null` provided for metadata if an exception is encountered - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/03 06:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6608) Add timeout parameter to methods which fetches and resets offsets - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/03/03 18:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6608) Add timeout parameter to methods which fetches and resets offsets - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/03/03 18:13:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6609) Offset commit reordering possible on coordinator disconnect - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/03 21:26:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6606) Regression in consumer auto-commit backoff behavior - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/03 21:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/03 22:41:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6608) Add timeout parameter to commitSync - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/03/04 03:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6608) Add timeout parameter to commitSync - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/03/04 03:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position() - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/03/04 18:55:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6127) Streams should never block infinitely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/05 01:40:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-6127) Streams should never block infinitely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/05 01:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/05 03:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed - posted by "Simon S (JIRA)" <ji...@apache.org> on 2018/03/05 12:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2610) Metrics for SSL handshake - posted by "Andy Feller (JIRA)" <ji...@apache.org> on 2018/03/05 14:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6589) Extract Heartbeat thread from Abstract Coordinator for testability purposes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/05 15:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4514) Add Codec for ZStandard Compression - posted by "Bert Sanders (JIRA)" <ji...@apache.org> on 2018/03/05 16:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6610) initial high watermark -1, used for truncation, cause "Cannot truncate to a negative offset" - posted by "dongyan li (JIRA)" <ji...@apache.org> on 2018/03/05 17:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6610) initial high watermark -1, used for truncation, cause "Cannot truncate to a negative offset" - posted by "dongyan li (JIRA)" <ji...@apache.org> on 2018/03/05 18:08:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/05 18:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6610) initial high watermark -1, used for truncation, cause "Cannot truncate to a negative offset" - posted by "dongyan li (JIRA)" <ji...@apache.org> on 2018/03/05 18:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/05 19:35:00 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6610) initial high watermark -1, used for truncation, cause "Cannot truncate to a negative offset" - posted by "dongyan li (JIRA)" <ji...@apache.org> on 2018/03/05 21:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2018/03/05 23:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5613) Deprecate JmxTool? - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/05 23:28:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6611) Re-write simple benchmark in system tests with JMXTool - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/05 23:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6612) Added logic to prevent increasing partition counts during topic deletion - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/03/05 23:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6612) Added logic to prevent increasing partition counts during topic deletion - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/03/05 23:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6612) Added logic to prevent increasing partition counts during topic deletion - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/06 00:00:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-6610) initial high watermark -1, used for truncation, cause "Cannot truncate to a negative offset" - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/06 00:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/06 01:02:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-6611) Re-write simple benchmark in system tests with JMXTool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/06 01:48:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6613) The controller shouldn't stop partition reassignment after an exception is being thrown - posted by "chandra kasiraju (JIRA)" <ji...@apache.org> on 2018/03/06 01:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/06 03:05:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5612) Replace JmxTool with a MetricsReporter in system tests - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/06 03:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4974) System test failure in 0.8.2.2 upgrade tests - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/06 04:36:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4999) Add convenience overload for seek* methods - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/06 04:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4999) Add convenience overload for seek* methods - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/06 04:42:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/06 05:03:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5199) Run Kafka JUnit build inside Docker - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/06 05:07:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5306) Official init.d scripts - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/06 05:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6309) add support for getting topic defaults from AdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/06 05:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5471) Original Kafka paper link broken - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/06 05:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5626) Producer should be able to negotiate ProduceRequest version with broker - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/06 05:37:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/06 06:23:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6507) NPE in KafkaStatusBackingStore - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/06 07:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1623) kafka is sometimes slow to accept connections - posted by "JiminHsieh (JIRA)" <ji...@apache.org> on 2018/03/06 09:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6052) Windows: Consumers not polling when isolation.level=read_committed - posted by "Veera (JIRA)" <ji...@apache.org> on 2018/03/06 11:39:00 UTC, 8 replies.
- [jira] [Created] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime - posted by "Dmitry Vsekhvalnov (JIRA)" <ji...@apache.org> on 2018/03/06 14:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime - posted by "Dmitry Vsekhvalnov (JIRA)" <ji...@apache.org> on 2018/03/06 14:35:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6615) Add scripts for DumpLogSegments - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/06 15:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6615) Add scripts for DumpLogSegments - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/06 15:53:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6423) Slow shutdown with many open files - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/03/06 23:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6175) AbstractIndex should cache index file to avoid unnecessary disk access during resize() - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/03/06 23:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6172) Cache lastEntry in TimeIndex to avoid unnecessary disk access - posted by "Ivan Babrou (JIRA)" <ji...@apache.org> on 2018/03/06 23:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6615) Add scripts for DumpLogSegments - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/06 23:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2 - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/03/06 23:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6616) kafka-merge-pr.py should use GitHub's REST API to merge - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/03/07 00:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6616) kafka-merge-pr.py should use GitHub's REST API to merge - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/03/07 00:35:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3312) Add a offsets methods to ZkUtils and replace relevant usages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/07 05:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/07 05:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5999) Offset Fetch Request - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/07 06:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6617) Improve controller performance by batching reassignment znode write operation - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/07 06:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5626) Producer should be able to negotiate ProduceRequest version with broker - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/07 06:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4974) System test failure in 0.8.2.2 upgrade tests - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/03/07 06:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6618) Prevent two controllers from updating znodes concurrently - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/07 06:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6618) Prevent two controllers from updating znodes concurrently - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/07 06:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6619) InstanceAlreadyExistsException while Tomcat starting up - posted by "xiezhi (JIRA)" <ji...@apache.org> on 2018/03/07 07:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6619) InstanceAlreadyExistsException while Tomcat starting up - posted by "xiezhi (JIRA)" <ji...@apache.org> on 2018/03/07 07:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6620) Documentation about "exactly_once" doesn't mention "transaction.state.log.min.isr" - posted by "Daniel Qian (JIRA)" <ji...@apache.org> on 2018/03/07 08:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5999) Offset Fetch Request - posted by "Zhao Weilong (JIRA)" <ji...@apache.org> on 2018/03/07 11:00:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6195) DNS alias support for secured connections - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/03/07 14:06:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-6621) Update Streams docs with details for UncaughtExceptionHandler - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/07 20:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2018/03/07 21:20:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-6400) Consider setting default cache size to zero in Kafka Streams - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2018/03/07 21:30:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2018/03/07 22:06:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6400) Consider setting default cache size to zero in Kafka Streams - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2018/03/07 22:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/07 23:56:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6622) GroupMetadataManager.loadGroupsAndOffsets decompresses record batch needlessly - posted by "radai rosenblatt (JIRA)" <ji...@apache.org> on 2018/03/08 00:24:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6622) GroupMetadataManager.loadGroupsAndOffsets decompresses record batch needlessly - posted by "radai rosenblatt (JIRA)" <ji...@apache.org> on 2018/03/08 00:25:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5939) Add a dryrun option to release.py - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/08 00:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/03/08 00:56:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/03/08 00:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6623) Consider renaming inefficient RecordBatch operations - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/08 01:22: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/03/08 01:32:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6624) log segment deletion could cause a disk to be marked offline incorrectly - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/03/08 01:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6624) log segment deletion could cause a disk to be marked offline incorrectly - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/03/08 01:38:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-6619) InstanceAlreadyExistsException while Tomcat starting up - posted by "xiezhi (JIRA)" <ji...@apache.org> on 2018/03/08 02:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6623) Consider renaming inefficient RecordBatch operations - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/08 06:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6625) kafka offset reset when I upgrade kafka from 0.11.0 to 1.0.0 version - posted by "barry010 (JIRA)" <ji...@apache.org> on 2018/03/08 07:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6625) kafka offset reset when I upgrade kafka from 0.11.0 to 1.0.0 version - posted by "barry010 (JIRA)" <ji...@apache.org> on 2018/03/08 07:20:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords - posted by "Maciej Bryński (JIRA)" <ji...@apache.org> on 2018/03/08 07:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords - posted by "Maciej Bryński (JIRA)" <ji...@apache.org> on 2018/03/08 07:43:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-3530) Making the broker-list option consistent across all tools - posted by "Chia-Ping Tsai (JIRA)" <ji...@apache.org> on 2018/03/08 13:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6598) Kafka to support using ETCD beside Zookeeper - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2018/03/08 14:35:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6627) Console producer default config values override explicitly provided properties - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/08 18:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6473) Add MockProcessorContext to public test-utils - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/03/08 19:05:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/08 19:40:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6628) RocksDBSegmentedBytesStoreTest does not cover time window serdes - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/08 22:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/08 22:32:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6630) Speed up the processing of StopReplicaResponse events on the controller - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/03/08 22:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6630) Speed up the processing of TopicDeletionStopReplicaResponseReceived events on the controller - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/03/08 22:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6630) Speed up the processing of TopicDeletionStopReplicaResponseReceived events on the controller - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/08 22:59:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6631) Kafka Streams - Rebalancing exception in Kafka 1.0.0 - posted by "Alexander Ivanichev (JIRA)" <ji...@apache.org> on 2018/03/08 23:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6539) KafkaConsumer endlessly try to connect to a dead broker, ignoring brokers alive - posted by "Simon Trigona (JIRA)" <ji...@apache.org> on 2018/03/09 00:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6627) Console producer default config values override explicitly provided properties - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/09 02:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/09 02:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/09 05:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5946) Give connector method parameter better name - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/09 05:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/09 05:29:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6632) Very slow hashCode methods in Kafka Connect types - posted by "Maciej Bryński (JIRA)" <ji...@apache.org> on 2018/03/09 10:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to infinity - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2018/03/09 10:42:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6633) Is KafkaProducer still thread safe in version 1.0.1 - posted by "Herbert Koelman (JIRA)" <ji...@apache.org> on 2018/03/09 10:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6633) Is KafkaProducer still thread safe in version 1.0.1 - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2018/03/09 11:48:01 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6633) Is KafkaProducer still thread safe in version 1.0.1 - posted by "Mickael Maison (JIRA)" <ji...@apache.org> on 2018/03/09 11:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6632) Very slow hashCode methods in Kafka Connect types - posted by "Maciej Bryński (JIRA)" <ji...@apache.org> on 2018/03/09 12:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6632) Very slow hashCode methods in Kafka Connect types - posted by "Maciej Bryński (JIRA)" <ji...@apache.org> on 2018/03/09 12:21:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-6633) Is KafkaProducer still thread safe in version 1.0.1 - posted by "Herbert Koelman (JIRA)" <ji...@apache.org> on 2018/03/09 12:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4831) Extract WindowedSerde to public APIs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/09 19:09:03 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-6627) Console producer default config values override explicitly provided properties - posted by "Sandor Murakozi (JIRA)" <ji...@apache.org> on 2018/03/09 20:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6631) Kafka Streams - Rebalancing exception in Kafka 1.0.0 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/09 22:11:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-6622) GroupMetadataManager.loadGroupsAndOffsets decompresses record batch needlessly - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/09 22:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/03/09 23:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6634) Delay initiating the txn on producers until initializeTopology with EOS turned on - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/09 23:18: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/03/10 00:43:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/10 08:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5889) MetricsTest is flaky - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/10 17:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6635) Producer close does not await pending transaction - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/11 07:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6634) Delay initiating the txn on producers until initializeTopology with EOS turned on - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/11 18:29:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING - posted by "Milind Jain (JIRA)" <ji...@apache.org> on 2018/03/11 20:48:00 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/11 20:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING - posted by "Milind Jain (JIRA)" <ji...@apache.org> on 2018/03/11 21:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5609) Connect log4j should log to file by default - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/12 00:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer` - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/12 01:05:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6317) Maven artifact for kafka should not depend on log4j - posted by "Gérald Quintana (JIRA)" <ji...@apache.org> on 2018/03/12 08:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4493) Connections to Kafka brokers should be validated - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/12 09:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired - posted by "Abhishek Agarwal (JIRA)" <ji...@apache.org> on 2018/03/12 11:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6337) Error for partition [__consumer_offsets,15] to broker - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/12 16:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5467) setting offset retention minutes to a lower value is not reflecting - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/12 17:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6022) mirror maker stores offset in zookeeper - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/12 17:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5504) Kafka controller is not getting elected - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/12 17:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4984) Unable to produce or consume when enabling authentication SASL/Kerberos - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/12 17:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6624) log segment deletion could cause a disk to be marked offline incorrectly - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/12 18:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6636) ReplicaFetcherThread should not die if hw < 0 - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/12 19:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6637) if set topic config segment.ms=0 Kafka broker won't be able to start - posted by "Chong Wang (JIRA)" <ji...@apache.org> on 2018/03/12 19:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6637) if set topic config segment.ms=0 Kafka broker won't be able to start - posted by "Chong Wang (JIRA)" <ji...@apache.org> on 2018/03/12 19:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6636) ReplicaFetcherThread should not die if hw < 0 - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/12 20:44:02 UTC, 0 replies.
- [jira] [Created] (KAFKA-6638) Controller should remove replica from ISR if the replica is removed from the replica set - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/12 20:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/12 20:56:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/12 20:57:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6639) Follower may have sparse index if catching up - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/12 21:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5540) Deprecate and remove internal converter configs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/12 22:08:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3368) Add the Message/Record set protocol to the protocol docs - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/12 22:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4831) Extract WindowedSerde to public APIs - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/12 22:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics() - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/12 22:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics() - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/12 23:25:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/12 23:29:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/13 00:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/13 00:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6638) Leader should remove unassigned replica from ISR - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/13 00:50:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6638) Leader should remove unassigned replica from ISR - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/13 00:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6642) Rack aware replica assignment in kafka streams - posted by "Ashish Surana (JIRA)" <ji...@apache.org> on 2018/03/13 04:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6624) log segment deletion could cause a disk to be marked offline incorrectly - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2018/03/13 05:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has retention time - posted by "Navinder Brar (JIRA)" <ji...@apache.org> on 2018/03/13 05:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has retention time - posted by "Navinder Brar (JIRA)" <ji...@apache.org> on 2018/03/13 05:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6643) Warm up new replicas from scratch when changelog topic has LIMITED retention time - posted by "Navinder Brar (JIRA)" <ji...@apache.org> on 2018/03/13 05:52:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/13 06:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen() - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/13 06:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6617) Improve controller performance by batching reassignment znode write operation - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/13 06:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6617) KAFKA-6617; Improve controller performance by batching reassignment znode write operation - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/13 06:30:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6637) if set topic config segment.ms=0 Kafka broker won't be able to start - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/13 07:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6637) if set topic config segment.ms=0 Kafka broker won't be able to start - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/13 07:08:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6644) Make Server Info more generic for Kafka Interactive Queries - posted by "Mike Graham (JIRA)" <ji...@apache.org> on 2018/03/13 08:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6576) Configurable Quota Management (KIP-257) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/13 09:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6535) Set default retention ms for Streams repartition topics to Long.MAX_VALUE - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2018/03/13 11:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6645) Sticky Partition Assignment across Kafka Streams application restarts - posted by "Giridhar Addepalli (JIRA)" <ji...@apache.org> on 2018/03/13 12:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6645) Sticky Partition Assignment across Kafka Streams application restarts - posted by "Giridhar Addepalli (JIRA)" <ji...@apache.org> on 2018/03/13 12:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6645) Sticky Partition Assignment to facilitate faster restarts of kafka streams applications - posted by "Giridhar Addepalli (JIRA)" <ji...@apache.org> on 2018/03/13 12:42:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4027) Leader for a cetain partition unavailable forever - posted by "Antonio Verardi (JIRA)" <ji...@apache.org> on 2018/03/13 14:38:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-6634) Delay initiating the txn on producers until initializeTopology with EOS turned on - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/13 15:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6645) Host Affinity to facilitate faster restarts of kafka streams applications - posted by "Giridhar Addepalli (JIRA)" <ji...@apache.org> on 2018/03/13 16:27:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4027) Leader for a cetain partition unavailable forever - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/13 16:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6646) Add a GlobalKStream object type for stream event broadcast - posted by "Antony Stubbs (JIRA)" <ji...@apache.org> on 2018/03/13 17:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean - posted by "George Bloggs (JIRA)" <ji...@apache.org> on 2018/03/13 17:11:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all - posted by "radai rosenblatt (JIRA)" <ji...@apache.org> on 2018/03/13 17:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all - posted by "radai rosenblatt (JIRA)" <ji...@apache.org> on 2018/03/13 17:19:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all - posted by "radai rosenblatt (JIRA)" <ji...@apache.org> on 2018/03/13 17:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/13 17:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/13 17:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6644) Make Server Info more generic for Kafka Interactive Queries - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/13 17:46:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/13 17:50:00 UTC, 10 replies.
- [jira] [Updated] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean - posted by "George Bloggs (JIRA)" <ji...@apache.org> on 2018/03/13 17:54:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4730) Streams does not have an in-memory windowed store - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/03/13 17:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/13 18:00:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/03/13 18:00:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6376) Improve Streams metrics for skipped records - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/03/13 18:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown - posted by "Julio Ng (JIRA)" <ji...@apache.org> on 2018/03/13 21:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown - posted by "Julio Ng (JIRA)" <ji...@apache.org> on 2018/03/13 21:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6650) The controller should be able to handle a partially deleted topic - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/03/13 22:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6651) SchemaBuilder should not allow Arrays or Maps to be created by type() - posted by "Jeremy Custenborder (JIRA)" <ji...@apache.org> on 2018/03/13 22:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6652) The controller should log failed attempts to transition a replica to OfflineReplica state - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/03/13 23:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6651) SchemaBuilder should not allow Arrays or Maps to be created by type() - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/14 01:47:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6500) Can not build aggregatedJavadoc - posted by "Jimin Hsieh (JIRA)" <ji...@apache.org> on 2018/03/14 03:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/14 04:17:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-6645) Host Affinity to facilitate faster restarts of kafka streams applications - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/14 05:36:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-6646) Add a GlobalKStream object type for stream event broadcast - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/14 05:38:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/14 06:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6653) Delayed operations may not be completed when there is lock contention - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/03/14 08:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6654) Customize SSLContext creation - posted by "Robert Wruck (JIRA)" <ji...@apache.org> on 2018/03/14 11:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception - posted by "Srini (JIRA)" <ji...@apache.org> on 2018/03/14 14:25:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception - posted by "Srini (JIRA)" <ji...@apache.org> on 2018/03/14 15:14:31 UTC, 0 replies.
- [jira] [Created] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/14 16:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6657) Add StreamsConfig prefix for different consumers - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/14 17:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/14 18:40:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6658) Fix RoundTripWorkload and make k/v generation configurable - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/03/14 18:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6658) Fix RoundTripWorkload and make k/v generation configurable - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/03/14 18:52:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6659) Improve error message if state store is not found - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/14 20:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6660) Monitoring number of messages expired due to retention policy - posted by "Matt Garbis (JIRA)" <ji...@apache.org> on 2018/03/14 20:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/14 21:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/14 21:35:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/14 21:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics() - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/14 22:16:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean - posted by "George Bloggs (JIRA)" <ji...@apache.org> on 2018/03/14 22:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/14 22:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/14 22:58:00 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer` - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/15 00:38:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer` - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/15 00:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6657) Add StreamsConfig prefix for different consumers - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2018/03/15 01:40:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers - posted by "siva santhalingam (JIRA)" <ji...@apache.org> on 2018/03/15 01:40:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-6662) Consumer use offsetsForTimes() get offset return None. - posted by "Matt Wang (JIRA)" <ji...@apache.org> on 2018/03/15 06:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6662) Consumer use offsetsForTimes() get offset return None. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/15 06:37:00 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6662) Consumer use offsetsForTimes() get offset return None. - posted by "Matt Wang (JIRA)" <ji...@apache.org> on 2018/03/15 06:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6653) Delayed operations may not be completed when there is lock contention - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/15 07:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6653) Delayed operations may not be completed when there is lock contention - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/15 07:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6663) Expression for GlobalKTable is not correct - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/15 09:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6351) libs directory has duplicate javassist jars - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/15 14:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6655) CleanupThread: Failed to lock the state directory due to an unexpected exception (Windows OS) - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/15 16:55:00 UTC, 2 replies.
- [jira] [Reopened] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/15 16:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS) - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/15 17:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/15 17:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS) - posted by "George Bloggs (JIRA)" <ji...@apache.org> on 2018/03/15 17:47:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6664) KIP-270 Substitution Within Configuration Values - posted by "Ron Dagostino (JIRA)" <ji...@apache.org> on 2018/03/15 18:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6664) KIP-269 Substitution Within Configuration Values - posted by "Ron Dagostino (JIRA)" <ji...@apache.org> on 2018/03/15 18:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6663) Expression for GlobalKTable is not correct - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/15 18:32:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6663) Expression for GlobalKTable is not correct - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/15 18:33:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6660) Monitoring number of messages expired due to retention policy - posted by "Matt Garbis (JIRA)" <ji...@apache.org> on 2018/03/15 18:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock - posted by "Dmitry Konstantinov (JIRA)" <ji...@apache.org> on 2018/03/15 19:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock - posted by "Dmitry Konstantinov (JIRA)" <ji...@apache.org> on 2018/03/15 19:25:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6562) KIP-255: OAuth Authentication via SASL/OAUTHBEARER - posted by "Ron Dagostino (JIRA)" <ji...@apache.org> on 2018/03/15 19:30:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6664) KIP-269 Substitution Within Configuration Values - posted by "Ron Dagostino (JIRA)" <ji...@apache.org> on 2018/03/15 19:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/15 21:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/15 21:45:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/15 23:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2018/03/15 23:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2018/03/15 23:05:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2018/03/15 23:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/15 23:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/15 23:33:01 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6663) Expression for GlobalKTable is not correct - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/16 03:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4368) Unclean shutdown breaks Kafka cluster - posted by "Umesh Chaudhary (JIRA)" <ji...@apache.org> on 2018/03/16 07:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5962) java.io.IOException: Map failed - posted by "Umesh Chaudhary (JIRA)" <ji...@apache.org> on 2018/03/16 07:23:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6667) Issues in kafka Streaming when using encryption with custom serializers and deserializers - posted by "Amandeep Singh (JIRA)" <ji...@apache.org> on 2018/03/16 07:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5962) java.io.IOException: Map failed - posted by "Mehmet Soner (JIRA)" <ji...@apache.org> on 2018/03/16 08:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5962) java.io.IOException: Map failed - posted by "Mehmet Soner (JIRA)" <ji...@apache.org> on 2018/03/16 08:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6668) Broker crashes on restart ,got a CorruptRecordException: Record size is smaller than minimum record overhead(14) - posted by "mayong (JIRA)" <ji...@apache.org> on 2018/03/16 09:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6669) KIP-271: Add NetworkClient redirector - posted by "Sergey Korytnikov (JIRA)" <ji...@apache.org> on 2018/03/16 13:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6669) KIP-271: Add NetworkClient redirector - posted by "Sergey Korytnikov (JIRA)" <ji...@apache.org> on 2018/03/16 13:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6669) KIP-271: Add NetworkClient redirector - posted by "Sergey Korytnikov (JIRA)" <ji...@apache.org> on 2018/03/16 13:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams - posted by "Debasish Ghosh (JIRA)" <ji...@apache.org> on 2018/03/16 14:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/16 15:02:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/16 16:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock - posted by "Eugene Sevastyanov (JIRA)" <ji...@apache.org> on 2018/03/16 16:45:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock - posted by "Eugene Sevastyanov (JIRA)" <ji...@apache.org> on 2018/03/16 16:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6671) Consumer group coordinator releases group before new coordinator is ready. - posted by "Rob Gevers (JIRA)" <ji...@apache.org> on 2018/03/16 17:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6671) Consumer group coordinator releases group before new coordinator is ready. - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/16 18:40:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock - posted by "Dmitry Konstantinov (JIRA)" <ji...@apache.org> on 2018/03/16 18:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6667) Issues in kafka Streaming when using encryption with custom serializers and deserializers - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/16 20:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6667) Issues in kafka Streaming when using encryption with custom serializers and deserializers - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/16 20:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6663) Expression for GlobalKTable is not correct - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/16 20:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6672) ConfigCommand failing to alter configs - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/16 21:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals. - posted by "Koen De Groote (JIRA)" <ji...@apache.org> on 2018/03/16 22:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6052) Windows: Consumers not polling when isolation.level=read_committed - posted by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2018/03/16 22:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6454) Allow timestamp manipulation in Processor API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/16 23:03:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6658) Fix RoundTripWorkload and make k/v generation configurable - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/16 23:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6672) ConfigCommand failing to alter configs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/16 23:36:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6672) ConfigCommand failing to alter configs - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/17 05:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1106) HighwaterMarkCheckpoint failure puting broker into a bad state - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 06:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3238) Deadlock Mirrormaker consumer not fetching any messages - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 09:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3550) Broker does not honor MetadataRequest api version; always returns v0 MetadataResponse - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 09:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3553) Issue with getting data of next offset after restarting the consumer and producer is always running - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 09:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4782) change chroot for a kafka instance - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 13:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5187) producer.close() times out at 30 seconds - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 13:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6613) The controller shouldn't stop partition reassignment after an exception is being thrown - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 13:43:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6596) Why we can not see any consumer offset produce rate in kafka manager - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 13:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6338) java.lang.NoClassDefFoundError: org/apache/kafka/common/network/LoginType - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/17 16:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2 - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/17 17:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6674) Kafka start script does not work on ibm jre - posted by "Tamar Thais (JIRA)" <ji...@apache.org> on 2018/03/17 17:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6674) Kafka start script does not work on ibm jre - posted by "Tamar Thais (JIRA)" <ji...@apache.org> on 2018/03/17 17:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6208) Reduce startup time for Kafka Connect workers - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/17 18:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/17 18:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/17 21:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/17 21:34:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6677) Remove EOS producer config max.in.flight.request.per.connection=1 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/18 01:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6659) Improve error message if state store is not found - posted by "Stuart (JIRA)" <ji...@apache.org> on 2018/03/18 07:22:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-6678) Upgrade dependencies with later release versions - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/18 16:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6678) Upgrade dependencies with later release versions - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/18 16:02:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6679) Random corruption (CRC validation issues) - posted by "Ari Uka (JIRA)" <ji...@apache.org> on 2018/03/18 19:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6679) Random corruption (CRC validation issues) - posted by "Ari Uka (JIRA)" <ji...@apache.org> on 2018/03/18 19:13:00 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/19 01:28:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/19 03:45: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/03/19 03:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/19 03:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/19 03:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics - posted by "Gunnar Morling (JIRA)" <ji...@apache.org> on 2018/03/19 07:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics - posted by "Gunnar Morling (JIRA)" <ji...@apache.org> on 2018/03/19 07:08:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker. - posted by "Chetan Pandey (JIRA)" <ji...@apache.org> on 2018/03/19 09:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted. - posted by "Jurriaan Pruis (JIRA)" <ji...@apache.org> on 2018/03/19 10:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6680) Fix config initialization in DynamicBrokerConfig - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/19 11:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group - posted by "Narayan Periwal (JIRA)" <ji...@apache.org> on 2018/03/19 13:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group - posted by "Narayan Periwal (JIRA)" <ji...@apache.org> on 2018/03/19 13:15:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6682) Kafka reconnection after broker restart - posted by "Tomasz Gąska (JIRA)" <ji...@apache.org> on 2018/03/19 13:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/03/19 15:12:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/03/19 15:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started" - posted by "Chema Sanchez (JIRA)" <ji...@apache.org> on 2018/03/19 15:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started" - posted by "Chema Sanchez (JIRA)" <ji...@apache.org> on 2018/03/19 15:40:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6679) Random corruption (CRC validation issues) - posted by "Ari Uka (JIRA)" <ji...@apache.org> on 2018/03/19 15:45:00 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-6659) Improve error message if state store is not found - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/19 15:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6680) Fix config initialization in DynamicBrokerConfig - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/19 15:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6684) Support casting values with bytes schema to string - posted by "Amit Sela (JIRA)" <ji...@apache.org> on 2018/03/19 15:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6685) Connect deserialization log message should distinguish key from value - posted by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2018/03/19 15:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6684) Support casting values with bytes schema to string - posted by "Amit Sela (JIRA)" <ji...@apache.org> on 2018/03/19 15:57:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6684) Support casting values with bytes schema to string - posted by "Amit Sela (JIRA)" <ji...@apache.org> on 2018/03/19 15:57:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6685) Connect deserialization log message should distinguish key from value - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/19 16:07:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-6685) Connect deserialization log message should distinguish key from value - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/19 16:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/19 16:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/19 16:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6687) Allow to read a topic multiple times - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/19 16:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started" - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/19 19:45:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-3365) Add a documentation field for types and update doc generation - posted by "Andras Beni (JIRA)" <ji...@apache.org> on 2018/03/19 20:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3365) Add a documentation field for types and update doc generation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/19 20:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6679) Random corruption (CRC validation issues) - posted by "Ari Uka (JIRA)" <ji...@apache.org> on 2018/03/19 21:26:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6680) Fix config initialization in DynamicBrokerConfig - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/19 22:23:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2018/03/19 22:34:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2018/03/19 23:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6240) Support dynamic updates of frequently updated broker configs - posted by "Brett Rann (JIRA)" <ji...@apache.org> on 2018/03/19 23:45:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/20 01:03:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6688) The Trogdor coordinator should track task statuses - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/03/20 04:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6689) Kafka not release .deleted file. - posted by "A (JIRA)" <ji...@apache.org> on 2018/03/20 04:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6688) The Trogdor coordinator should track task statuses - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/20 05:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6689) Kafka not release .deleted file. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/20 06:31:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6689) Kafka not release .deleted file. - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/20 07:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6613) The controller shouldn't stop partition reassignment after an exception is being thrown - posted by "chandra kasiraju (JIRA)" <ji...@apache.org> on 2018/03/20 07:31:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6685) Connect deserialization log message should distinguish key from value - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/03/20 10:26:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6690) Priorities for Source Topics - posted by "Bala Prassanna I (JIRA)" <ji...@apache.org> on 2018/03/20 13:20:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6690) Priorities for Source Topics - posted by "Bala Prassanna I (JIRA)" <ji...@apache.org> on 2018/03/20 13:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6691) Requesting High Watermark and Truncation documentation be added to Docs - posted by "Justin Manchester (JIRA)" <ji...@apache.org> on 2018/03/20 14:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group - posted by "Narayan Periwal (JIRA)" <ji...@apache.org> on 2018/03/20 16:53:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore - posted by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2018/03/20 16:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore - posted by "Yeva Byzek (JIRA)" <ji...@apache.org> on 2018/03/20 16:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6084) ReassignPartitionsCommand should propagate JSON parsing failures - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2018/03/20 17:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6682) Kafka reconnection after broker restart - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/20 17:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6682) Kafka reconnection after broker restart - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/20 17:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/20 17:59:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/20 18:00:00 UTC, 7 replies.
- [jira] [Commented] (KAFKA-6376) Improve Streams metrics for skipped records - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/20 18:02:00 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/20 18:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6693) Add Consumer-only benchmark workload to Trogdor - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2018/03/20 18:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6694) The Trogdor Coordinator should support filtering task responses - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/03/20 21:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6694) The Trogdor Coordinator should support filtering task responses - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/20 21:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6695) Add a system test for dynamic broker config update - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/03/20 21:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6696) Trogdor should support destroying tasks - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/03/20 22:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals. - posted by "Asutosh Pandya (JIRA)" <ji...@apache.org> on 2018/03/21 01:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6697) JBOD configured broker should not die if log directory is invalid - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/21 05:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6698) ConsumerBounceTest#testClose sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/21 08:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6698) ConsumerBounceTest#testClose sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/21 08:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/03/21 09:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5649) Producer is being closed generating ssl exception - posted by "Arpan Khandelwal (JIRA)" <ji...@apache.org> on 2018/03/21 12:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6700) allow producer performance test to run for a fixed duration - posted by "Chris Burroughs (JIRA)" <ji...@apache.org> on 2018/03/21 15:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6700) allow producer performance test to run for a fixed duration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/21 15:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/21 17:59:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-6701) synchronize Log modification between delete cleanup and async delete - posted by "Sumant Tambe (JIRA)" <ji...@apache.org> on 2018/03/21 18:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started" - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/21 18:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6697) JBOD configured broker should not die if log directory is invalid - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/21 21:29:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/21 23:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6538) Enhance ByteStore exceptions with more context information - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/21 23:35:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6459) By (Re-)joining group StreamThread got NPE - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/03/22 00:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6457) Error: NOT_LEADER_FOR_PARTITION leads to NPE - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/03/22 00:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6457) Error: NOT_LEADER_FOR_PARTITION leads to NPE - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2018/03/22 00:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals. - posted by "Asutosh Pandya (JIRA)" <ji...@apache.org> on 2018/03/22 02:10:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6702) Wrong className in LoggerFactory.getLogger method - posted by "JieFang.He (JIRA)" <ji...@apache.org> on 2018/03/22 02:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6702) Wrong className in LoggerFactory.getLogger method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/22 02:42:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals. - posted by "Koen De Groote (JIRA)" <ji...@apache.org> on 2018/03/22 08:32:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6670) Implement a Scala wrapper library for Kafka Streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/22 13:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect - posted by "UYAR Farid (JIRA)" <ji...@apache.org> on 2018/03/22 15:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/03/22 15:54:00 UTC, 10 replies.
- [jira] [Created] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader - posted by "Attila Sasvari (JIRA)" <ji...@apache.org> on 2018/03/22 18:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader - posted by "Attila Sasvari (JIRA)" <ji...@apache.org> on 2018/03/22 18:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader - posted by "Attila Sasvari (JIRA)" <ji...@apache.org> on 2018/03/22 19:00:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-6704) Checking hasNext from SegementIterator could throw InvalidStateStoreException - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/03/22 20:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6696) Trogdor should support destroying tasks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/22 21:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3591) JmxTool should exit out if a provided query matches no values - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/22 23:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6705) producer.send() should be non-blocking - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/23 01:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6705) producer.send() should be non-blocking - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/23 01:37:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-6685) Connect deserialization log message should distinguish key from value - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/03/23 02:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6127) Streams should never block infinitely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/23 03:55:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started" - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/03/23 05:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6705) producer.send() should be non-blocking - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/23 06:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6705) producer.send() should not block due to metadata not available - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/03/23 07:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6702) Wrong className in LoggerFactory.getLogger method - posted by "JieFang.He (JIRA)" <ji...@apache.org> on 2018/03/23 07:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade - posted by "Di Shang (JIRA)" <ji...@apache.org> on 2018/03/23 07:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade - posted by "abel-sun (JIRA)" <ji...@apache.org> on 2018/03/23 07:49:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-3370) Add options to auto.offset.reset to reset offsets upon initialization only - posted by "Benson Hon (JIRA)" <ji...@apache.org> on 2018/03/23 07:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6707) The value of Type.LONG should be *L - posted by "JieFang.He (JIRA)" <ji...@apache.org> on 2018/03/23 08:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6707) The value of Type.LONG should be *L - posted by "JieFang.He (JIRA)" <ji...@apache.org> on 2018/03/23 08:57:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6707) The default value for config of Type.LONG should be *L - posted by "JieFang.He (JIRA)" <ji...@apache.org> on 2018/03/23 08:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6707) The default value for config of Type.LONG should be *L - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/23 09:08:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX - posted by "Carlos Manuel Pacheco SOARES (JIRA)" <ji...@apache.org> on 2018/03/23 10:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/03/23 11:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6708) Review JavaDocs and Documentation with regards to Serde Useage - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/03/23 15:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6708) Review JavaDocs and Documentation with regards to Serde Useage - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/03/23 15:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6708) Review JavaDocs, Documentation and Exception messages with regards to Serde Useage - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/03/23 15:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6708) Review Exception messages with regards to Serde Useage - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/03/23 15:39:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader - posted by "Attila Sasvari (JIRA)" <ji...@apache.org> on 2018/03/23 16:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4840) There are still cases where producer buffer pool will not remove waiters. - posted by "Andrew Olson (JIRA)" <ji...@apache.org> on 2018/03/23 16:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6680) Fix config initialization in DynamicBrokerConfig - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/23 16:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/23 17:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6437) Streams does not warn about missing input topics, but hangs - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/03/23 19:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/23 22:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/23 22:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6652) The controller should log failed attempts to transition a replica to OfflineReplica state if there is no leadership info - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/03/24 00:18:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6652) The controller should log failed attempts to transition a replica to OfflineReplica state if there is no leadership info - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/24 00:25:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file - posted by "Brett Rann (JIRA)" <ji...@apache.org> on 2018/03/24 01:47:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6709) broker failed to handle request due to OOM - posted by "Zou Tao (JIRA)" <ji...@apache.org> on 2018/03/24 09:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6709) broker failed to handle request due to OOM - posted by "Zou Tao (JIRA)" <ji...@apache.org> on 2018/03/24 09:28:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-6705) producer.send() should not block due to metadata not available - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2018/03/24 10:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion() - posted by "Sanket Band (JIRA)" <ji...@apache.org> on 2018/03/24 10:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6709) broker failed to handle request due to OOM - posted by "Jimin Hsieh (JIRA)" <ji...@apache.org> on 2018/03/24 11:09:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-6710) Streams integration tests hang during shutdown - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/03/24 15:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6710) Streams integration tests hang during shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/24 15:40:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6637) if set topic config segment.ms=0 Kafka broker won't be able to start - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/24 19:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6711) Checkpoint of InMemoryStore along with GlobalKTable - posted by "Cemalettin Koç (JIRA)" <ji...@apache.org> on 2018/03/24 20:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6710) Streams integration tests hang during shutdown - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2018/03/24 21:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6712) Throw a specific exception with wrong topic name for interactive queries - posted by "Francesco Guardiani (JIRA)" <ji...@apache.org> on 2018/03/25 09:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6713) Provide an easy way replace store with a custom one on High-Level Streams DSL - posted by "Cemalettin Koç (JIRA)" <ji...@apache.org> on 2018/03/25 10:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6712) Throw a specific exception with wrong topic name for interactive queries - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/25 18:35:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6712) Throw a specific exception with wrong topic name for interactive queries - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/25 18:38:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6709) broker failed to handle request due to OOM - posted by "Zou Tao (JIRA)" <ji...@apache.org> on 2018/03/26 01:02:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6714) KafkaController marks all Brokers as "Shutting down", though only one broker has been shut down - posted by "Uwe Eisele (JIRA)" <ji...@apache.org> on 2018/03/26 12:01:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6714) KafkaController marks all Brokers as "Shutting down", though only one broker has been shut down - posted by "Uwe Eisele (JIRA)" <ji...@apache.org> on 2018/03/26 12:02:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-6715) Leader transition for all partitions lead by two brokers without visible reason - posted by "Uwe Eisele (JIRA)" <ji...@apache.org> on 2018/03/26 13:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6715) Leader transition for all partitions lead by two brokers without visible reason - posted by "Uwe Eisele (JIRA)" <ji...@apache.org> on 2018/03/26 13:25:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6531) SocketServerTest#closingChannelException fails sometimes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/26 17:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6712) Throw a specific exception with wrong topic name for interactive queries - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/26 17:31:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6712) Throw a specific exception with wrong topic name for interactive queries - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/26 17:31:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2 - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2018/03/26 17:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/26 18:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6711) Checkpoint of InMemoryStore along with GlobalKTable - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/26 18:40:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/26 18:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6711) Checkpoint of InMemoryStore along with GlobalKTable - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/26 18:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6713) Provide an easy way replace store with a custom one on High-Level Streams DSL - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/26 18:54:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-6713) Provide an easy way replace store with a custom one on High-Level Streams DSL - posted by "Cemalettin Koç (JIRA)" <ji...@apache.org> on 2018/03/26 20:14:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6713) Provide an easy way replace store with a custom one on High-Level Streams DSL - posted by "Cemalettin Koç (JIRA)" <ji...@apache.org> on 2018/03/26 20:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file - posted by "Cemalettin Koç (JIRA)" <ji...@apache.org> on 2018/03/26 21:08:00 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/26 21:10:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file - posted by "Cemalettin Koç (JIRA)" <ji...@apache.org> on 2018/03/27 07:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6717) TopicPartition Assined twice to a consumer group for different consumers - posted by "Yuancheng PENG (JIRA)" <ji...@apache.org> on 2018/03/27 09:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances - posted by "Yuancheng PENG (JIRA)" <ji...@apache.org> on 2018/03/27 09:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams - posted by "Deepak Goyal (JIRA)" <ji...@apache.org> on 2018/03/27 13:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams - posted by "Deepak Goyal (JIRA)" <ji...@apache.org> on 2018/03/27 13:14:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-6698) ConsumerBounceTest#testClose sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/27 15:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/27 16:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/27 16:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5540) Deprecate and remove internal converter configs - posted by "Chris Egerton (JIRA)" <ji...@apache.org> on 2018/03/27 16:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5540) Deprecate and remove internal converter configs - posted by "Chris Egerton (JIRA)" <ji...@apache.org> on 2018/03/27 16:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException - posted by "Chris Egerton (JIRA)" <ji...@apache.org> on 2018/03/27 17:23:00 UTC, 12 replies.
- [jira] [Assigned] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/27 17:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/27 17:35:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/27 17:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6719) Kafka Reassign Partitions Failure - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2018/03/27 18:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6719) Kafka Reassign Partitions Failure - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2018/03/27 18:37:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException - posted by "Chris Egerton (JIRA)" <ji...@apache.org> on 2018/03/27 20:19:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6473) Add MockProcessorContext to public test-utils - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/27 21:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask - posted by "Vikas Tikoo (JIRA)" <ji...@apache.org> on 2018/03/27 21:35:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist - posted by "Daniel Wojda (JIRA)" <ji...@apache.org> on 2018/03/27 21:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2018/03/27 22:34:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend - posted by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/27 23:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/27 23:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-6721) Consolidate state store management for global stores and normal stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/27 23:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6386) Deprecate KafkaStreams constructor taking StreamsConfig parameter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/27 23:12:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-6473) Add MockProcessorContext to public test-utils - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/03/27 23:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient - posted by "wade wu (JIRA)" <ji...@apache.org> on 2018/03/28 00:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient - posted by "wade wu (JIRA)" <ji...@apache.org> on 2018/03/28 00:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown - posted by "Srinivas Dhruvakumar (JIRA)" <ji...@apache.org> on 2018/03/28 02:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6473) Add MockProcessorContext to public test-utils - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/28 03:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/03/28 03:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2018/03/28 03:26:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-6642) Rack aware replica assignment in kafka streams - posted by "Ashish Surana (JIRA)" <ji...@apache.org> on 2018/03/28 04:07:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6642) Rack aware replica assignment in kafka streams - posted by "Ashish Surana (JIRA)" <ji...@apache.org> on 2018/03/28 04:13:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6642) Rack aware task assignment in kafka streams - posted by "Ashish Surana (JIRA)" <ji...@apache.org> on 2018/03/28 04:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6684) Support casting values with bytes schema to string - posted by "Amit Sela (JIRA)" <ji...@apache.org> on 2018/03/28 13:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6724) ConsumerPerformance resets offsets on every startup - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2018/03/28 13:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6724) ConsumerPerformance resets offsets on every startup - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/28 14:01:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6724) ConsumerPerformance resets offsets on every startup - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2018/03/28 14:54:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/03/28 17:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6642) Rack aware task assignment in kafka streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/28 17:32:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6724) ConsumerPerformance resets offsets on every startup - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/03/28 17:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6376) Improve Streams metrics for skipped records - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/03/28 17:34:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-5253) TopologyTestDriver must handle streams created with patterns - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/03/28 18:34:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-6376) Improve Streams metrics for skipped records - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2018/03/28 19:56:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist - posted by "Daniel Wojda (JIRA)" <ji...@apache.org> on 2018/03/28 20:39:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/28 21:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext - posted by "Matt Farmer (JIRA)" <ji...@apache.org> on 2018/03/29 01:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/29 04:59:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade - posted by "Di Shang (JIRA)" <ji...@apache.org> on 2018/03/29 05:33:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics A - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2018/03/29 12:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6727) org.apache.kafka.clients.admin.Config has broken equals and hashCode method. - posted by "Andy Coates (JIRA)" <ji...@apache.org> on 2018/03/29 12:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics API - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2018/03/29 13:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/29 14:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6727) org.apache.kafka.clients.admin.Config has broken equals and hashCode method. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/29 14:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext - posted by "Matt Farmer (JIRA)" <ji...@apache.org> on 2018/03/29 16:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group - posted by "Narayan Periwal (JIRA)" <ji...@apache.org> on 2018/03/29 16:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6460) Add mocks for state stores used in Streams unit testing - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/29 21:10:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/29 21:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6395) KIP: Add Record Header support to Kafka Streams - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/03/29 21:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6612) Added logic to prevent increasing partition counts during topic deletion - posted by "Lucas Wang (JIRA)" <ji...@apache.org> on 2018/03/29 21:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6642) Rack aware task assignment in kafka streams - posted by "Ashish Surana (JIRA)" <ji...@apache.org> on 2018/03/30 10:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6728) Kafka Connect Header Null Pointer Exception - posted by "Philippe Hong (JIRA)" <ji...@apache.org> on 2018/03/30 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6728) Kafka Connect Header Null Pointer Exception - posted by "Philippe Hong (JIRA)" <ji...@apache.org> on 2018/03/30 14:52:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6728) Kafka Connect Header Null Pointer Exception - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/30 15:45:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6538) Enhance ByteStore exceptions with more context information - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/03/30 16:13:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6538) Enhance ByteStore exceptions with more context information - posted by "Jagadesh Adireddi (JIRA)" <ji...@apache.org> on 2018/03/30 17:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6728) Kafka Connect Header Null Pointer Exception - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/30 17:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6704) Checking hasNext from SegementIterator could throw InvalidStateStoreException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/30 22:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/30 22:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-6730) Simplify state store recovery - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/30 23:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/03/30 23:28:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/03/30 23:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6390) Update ZooKeeper to 3.4.11, Gradle and other minor updates - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/03/30 23:29:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/03/31 00:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/31 14:58:00 UTC, 0 replies.