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

---

- [jira] [Updated] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2019/01/01 08:52:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7758) When Naming a Repartition Topic with Aggregations Reuse Repartition Graph Node for Multiple Operations - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/01 18:04:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7380) Global thread restore blocks KafkaStreams#start() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/02 03:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7132) Consider adding faster form of rebalancing - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/02 03:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4696) Streams standby task assignment should be state-store aware - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/02 03:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6127) Streams should never block infinitely - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/02 03:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS - posted by "Sarvesh Tamba (JIRA)" <ji...@apache.org> on 2019/01/02 05:39:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode - posted by "huxihx (JIRA)" <ji...@apache.org> on 2019/01/02 09:23:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode - posted by "huxihx (JIRA)" <ji...@apache.org> on 2019/01/02 09:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/02 09:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values - posted by "Manohar Vanam (JIRA)" <ji...@apache.org> on 2019/01/02 11:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values - posted by "Manohar Vanam (JIRA)" <ji...@apache.org> on 2019/01/02 11:21:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7781) Add validation check for Topic retention.ms property - posted by "Kamal Chandraprakash (JIRA)" <ji...@apache.org> on 2019/01/02 11:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7782) cleanup policy for offsets topic should be configurable - posted by "Nir Barel (JIRA)" <ji...@apache.org> on 2019/01/02 12:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7781) Add validation check for Topic retention.ms property - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/02 12:33:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7778) Add KTable.suppress to Scala API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/02 14:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7778) Add KTable.suppress to Scala API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/02 14:08:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-7223) KIP-328: Add in-memory Suppression - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/02 14:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/02 14:11:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6627) Console producer default config values override explicitly provided properties - posted by "Kan Li (JIRA)" <ji...@apache.org> on 2019/01/02 19:46:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-6627) Console producer default config values override explicitly provided properties - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2019/01/02 19:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7783) Improve testing of idempotent/transactional producer shutdown - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/02 22:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/02 23:01:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/02 23:07:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1705) Add MR layer to Kafka - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2019/01/03 01:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests - posted by "Gwen Shapira (JIRA)" <ji...@apache.org> on 2019/01/03 01:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction - posted by "Sebastian Puzoń (JIRA)" <ji...@apache.org> on 2019/01/03 07:04:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction - posted by "Sebastian Puzoń (JIRA)" <ji...@apache.org> on 2019/01/03 07:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction - posted by "Sebastian Puzoń (JIRA)" <ji...@apache.org> on 2019/01/03 07:05:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction - posted by "Sebastian Puzoń (JIRA)" <ji...@apache.org> on 2019/01/03 07:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams - posted by "Khaireddine Rezgui (JIRA)" <ji...@apache.org> on 2019/01/03 08:43:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7784) Producer & message format : better management when inter.broker.protocol.version is overrided - posted by "Hervé RIVIERE (JIRA)" <ji...@apache.org> on 2019/01/03 10:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7785) Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package - posted by "Jacek Laskowski (JIRA)" <ji...@apache.org> on 2019/01/03 14:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/03 18:33:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/03 18:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7785) Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/03 18:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7775) [KStream] remove topic prefix from consumer configuration to resolve unnecessary warning - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/03 19:18:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-7768) Java doc link 404 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/03 19:24:00 UTC, 8 replies.
- [jira] [Commented] (KAFKA-7725) Add a delay for further CG rebalances, beyond KIP-134 group.initial.rebalance.delay.ms - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/03 21:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7680) fetching a refilled chunk of log can cause log divergence - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/03 21:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7728) Add JoinReason to the join group request for better rebalance handling - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/03 22:51:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6431) Lock contention in Purgatory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/04 00:09:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7734) Metrics tags should use LinkedHashMap to guarantee ordering - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/04 01:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7734) Metrics tags should use LinkedHashMap to guarantee ordering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/04 01:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7734) Metrics tags should use LinkedHashMap to guarantee ordering - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/04 01:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/04 05:59:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2019/01/04 07:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7752) zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2019/01/04 10:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7752) zookeeper-security-migration.sh does not remove ACL on kafka-acl-extended - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/04 10:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/04 12:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7688) Allow byte array class for Decimal Logical Types to fix Debezium Issues - posted by "Manjeet Duhan (JIRA)" <ji...@apache.org> on 2019/01/04 12:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7780) Kafka client should validate topic-level configs and update only unique values - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/04 13:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7580) Unit Test 'shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir' fails when run as root user - posted by "Sarvesh Tamba (JIRA)" <ji...@apache.org> on 2019/01/04 13:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7743) "pure virtual method called" error message thrown for unit tests which PASS - posted by "Sarvesh Tamba (JIRA)" <ji...@apache.org> on 2019/01/04 14:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read - posted by "Jeff Nadler (JIRA)" <ji...@apache.org> on 2019/01/04 16:28:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read - posted by "Jeff Nadler (JIRA)" <ji...@apache.org> on 2019/01/04 16:29:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/04 18:00:00 UTC, 9 replies.
- [jira] [Resolved] (KAFKA-6928) StreamsPartitionAssignor is double retrying within InternalTopicManager - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/04 18:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4835) Allow users control over repartitioning - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/04 19:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/04 19:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2019/01/04 21:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/04 22:40:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-7772) Dynamically adjust log level in Connect workers - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2019/01/05 00:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7787) Add error specifications to KAFKA-7609 - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/05 01:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7788) Support null defaults in KAFKA-7609 RPC specifications - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/05 01:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/05 05:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7181) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters IllegalStateException - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/05 05:32:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7181) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters IllegalStateException - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/05 05:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7769) Illegal batch type class - posted by "Asaf Mesika (JIRA)" <ji...@apache.org> on 2019/01/05 08:15:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/05 10:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5056) Shuffling of partitions in old consumer fetch requests removed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/05 10:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/05 10:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4835) Allow users control over repartitioning - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/05 14:51:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-4835) Allow users control over repartitioning - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/06 03:36:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7768) Java doc link 404 - posted by "Slim Ouertani (JIRA)" <ji...@apache.org> on 2019/01/06 10:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro - posted by "Slim Ouertani (JIRA)" <ji...@apache.org> on 2019/01/06 12:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7632) Allow fine-grained configuration for compression - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/06 18:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7632) Allow fine-grained configuration for compression - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/06 18:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6989) Support Async Processing in Streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/06 21:07:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7789) SSL-related unit tests hang when run on Fedora 29 - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2019/01/07 11:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7789) SSL-related unit tests hang when run on Fedora 29 - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2019/01/07 12:09:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7361) Kafka wont reconnect after NoRouteToHostException - posted by "Igor Soarez (JIRA)" <ji...@apache.org> on 2019/01/07 12:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7790) Trogdor - Does not time out tasks in time - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2019/01/07 13:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7755) Kubernetes - Kafka clients are resolving DNS entries only one time - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/07 13:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration - posted by "Dmitry Buykin (JIRA)" <ji...@apache.org> on 2019/01/07 13:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration - posted by "Dmitry Buykin (JIRA)" <ji...@apache.org> on 2019/01/07 14:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7755) Kubernetes - Kafka clients are resolving DNS entries only one time - posted by "Loïc Monney (JIRA)" <ji...@apache.org> on 2019/01/07 14:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7790) Trogdor - Does not time out tasks in time - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2019/01/07 15:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7791) Not log retriable exceptions as errors - posted by "Yaroslav Klymko (JIRA)" <ji...@apache.org> on 2019/01/07 17:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7768) Java doc link 404 - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/07 17:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3184) Add Checkpoint for In-memory State Store - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/07 18:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5061) client.id should be set for Connect producers/consumers - posted by "Paul Davidson (JIRA)" <ji...@apache.org> on 2019/01/07 18:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7160) Add check for group ID length - posted by "Radwa Osama (JIRA)" <ji...@apache.org> on 2019/01/07 18:28:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-7755) Kubernetes - Kafka clients are resolving DNS entries only one time - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2019/01/07 19:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7792) Trogdor should have an uptime function - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/07 20:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7102) Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@10c8df20 - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2019/01/07 20:50:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7699) Improve wall-clock time punctuations - posted by "Yishun Guan (JIRA)" <ji...@apache.org> on 2019/01/07 21:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations - posted by "Yishun Guan (JIRA)" <ji...@apache.org> on 2019/01/07 21:17:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/07 21:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/07 21:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/07 21:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/07 21:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4218) Enable access to key in ValueTransformer - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/07 21:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/07 21:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/07 21:41:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7793) Improve the Trogdor command-line - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/07 21:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/07 22:01:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-7621) Clients can't deal with server IP address change - posted by "Andrey Dyachkov (JIRA)" <ji...@apache.org> on 2019/01/08 10:35:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-7790) Trogdor - Does not time out tasks in time - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/08 10:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7749) confluent does not provide option to set consumer properties at connector level - posted by "Sönke Liebau (JIRA)" <ji...@apache.org> on 2019/01/08 11:50:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7160) Add check for group ID length - posted by "roo (JIRA)" <ji...@apache.org> on 2019/01/08 12:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7789) SSL-related unit tests hang when run on Fedora 29 - posted by "Tom Bentley (JIRA)" <ji...@apache.org> on 2019/01/08 13:09:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2019/01/08 14:03:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2019/01/08 14:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2019/01/08 14:05:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7773) Use verifiable consumer in system tests to avoid reliance on console consumer idle timeout - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/08 14:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7253) The connector type responded by worker is always null when creating connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/08 16:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7253) The connector type responded by worker is always null when creating connector - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/08 16:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7794) kafka.tools.GetOffsetShell does not return the offset in some cases - posted by "Daniele Ascione (JIRA)" <ji...@apache.org> on 2019/01/08 17:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7794) kafka.tools.GetOffsetShell does not return the offset in some cases - posted by "Daniele Ascione (JIRA)" <ji...@apache.org> on 2019/01/08 17:36:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-7795) Broker fails on duplicate configuration keys - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2019/01/08 18:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7795) Broker fails on duplicate configuration keys - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2019/01/08 18:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7795) Add strict config parsing mode - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2019/01/08 18:42:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-7795) Produce a warning when duplicate config keys are detected - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2019/01/08 19:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7796) structured streaming fetched wrong current offset from kafka - posted by "Ryne Yang (JIRA)" <ji...@apache.org> on 2019/01/08 19:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7795) Produce a warning when duplicate config keys are detected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/08 20:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7698) Kafka Broker fail to start: ProducerFencedException thrown from producerstatemanager.scala!checkProducerEpoch - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/08 20:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/08 20:40:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists - posted by "Patrik Kleindl (JIRA)" <ji...@apache.org> on 2019/01/08 20:52:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/08 20:57:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4218) Enable access to key in ValueTransformer - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/08 21:12:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7797) Replication throttling configs aren't in the docs - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2019/01/08 21:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7798) Expose embedded client context from KafkaStreams threadMetadata - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/08 21:59:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/08 22:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7800) Extend Admin API to support dynamic application log levels - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2019/01/08 22:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7798) Expose embedded client context from KafkaStreams threadMetadata - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/08 22:26:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2019/01/09 01:07:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6774) Improve default groupId behavior in consumer - posted by "Allen Wang (JIRA)" <ji...@apache.org> on 2019/01/09 01:15:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/09 01:39:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/09 02:06:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7801) TopicCommand should not be able to alter transaction topic partition count - posted by "huxihx (JIRA)" <ji...@apache.org> on 2019/01/09 05:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7801) TopicCommand should not be able to alter transaction topic partition count - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/09 05:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7802) Connection to Broker Disconnected Taking Down the Whole Cluster - posted by "Candice Wan (JIRA)" <ji...@apache.org> on 2019/01/09 06:58:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7802) Connection to Broker Disconnected Taking Down the Whole Cluster - posted by "Candice Wan (JIRA)" <ji...@apache.org> on 2019/01/09 06:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/09 08:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/09 08:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7771) Group/Transaction coordinators should update assignment based on current partition count - posted by "huxihx (JIRA)" <ji...@apache.org> on 2019/01/09 08:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7771) Group/Transaction coordinators should update assignment based on current partition count - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/09 09:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5337) Partition assignment strategy that distributes lag evenly across consumers in each group - posted by "BDeus (JIRA)" <ji...@apache.org> on 2019/01/09 09:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7803) Streams internal topics config is not updated when the code is changed - posted by "Tim Van Laer (JIRA)" <ji...@apache.org> on 2019/01/09 10:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7803) Kafka Streams internal topics config is not updated when the code is changed - posted by "Tim Van Laer (JIRA)" <ji...@apache.org> on 2019/01/09 10:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7804) Update the docs for KIP-377 - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2019/01/09 14:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7804) Update the docs for KIP-377 - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2019/01/09 14:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7805) Use --bootstrap-server option in ducktape tests where applicable - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2019/01/09 14:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/09 17:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7807) Special Characters in Topic Name Appear to Break Replication - posted by "Joseph Niemiec (JIRA)" <ji...@apache.org> on 2019/01/09 17:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/09 19:13:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7786) Fast update of leader epoch may stall partition fetching due to FENCED_LEADER_EPOCH - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/09 19:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2019/01/09 19:36:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2019/01/09 19: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 "Joseph Niemiec (JIRA)" <ji...@apache.org> on 2019/01/09 19:40:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2019/01/09 20:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7808) AdminClient#describeTopic should not throw InvalidTopic if topic name is not found - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/09 20:55:01 UTC, 1 replies.
- [jira] [Created] (KAFKA-7808) AdminClient#describeTopic should not throw InvalidTopic if topic name is not found - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/09 20:55:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7798) Expose embedded client context from KafkaStreams threadMetadata - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/09 21:27:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7808) AdminClient#describeTopic should not throw InvalidTopic if topic name is not found - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2019/01/09 21:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7151) IOException on broker may result in state where unclean leader election is required - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2019/01/09 21:51:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-6431) Lock contention in Purgatory - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2019/01/10 04:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6431) Lock contention in Purgatory - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2019/01/10 04:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7807) Special Characters in Topic Name Appear to Break Replication - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2019/01/10 04:36:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space - posted by "Suman Kalyan Ghosh (JIRA)" <ji...@apache.org> on 2019/01/10 05:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space - posted by "Suman Kalyan Ghosh (JIRA)" <ji...@apache.org> on 2019/01/10 05:31:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-5761) Serializer API should support ByteBuffer - posted by "douyu (JIRA)" <ji...@apache.org> on 2019/01/10 05:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space - posted by "Suman Kalyan Ghosh (JIRA)" <ji...@apache.org> on 2019/01/10 08:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7810) AdminClient not found flink consumer group - posted by "dengjie (JIRA)" <ji...@apache.org> on 2019/01/10 09:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7810) AdminClient not found flink consumer group - posted by "huxihx (JIRA)" <ji...@apache.org> on 2019/01/10 10:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7804) Update the docs for KIP-377 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/10 12:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2019/01/10 13:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7811) Avoid unnecessary lock acquire when KafkaConsumer commit offsets - posted by "lambdaliu (JIRA)" <ji...@apache.org> on 2019/01/10 13:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7811) Avoid unnecessary lock acquire when KafkaConsumer commit offsets - posted by "lambdaliu (JIRA)" <ji...@apache.org> on 2019/01/10 13:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/10 13:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7811) Avoid unnecessary lock acquire when KafkaConsumer commits offsets - posted by "lambdaliu (JIRA)" <ji...@apache.org> on 2019/01/10 13:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7811) Avoid unnecessary lock acquire when KafkaConsumer commits offsets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/10 13:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2019/01/10 13:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7802) Connection to Broker Disconnected Taking Down the Whole Cluster - posted by "Christoffer Hammarström (JIRA)" <ji...@apache.org> on 2019/01/10 16:16:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-7802) Connection to Broker Disconnected Taking Down the Whole Cluster - posted by "Christoffer Hammarström (JIRA)" <ji...@apache.org> on 2019/01/10 16:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/10 16:48:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/10 16:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/10 16:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7790) Fix Bugs in Trogdor Task Expiration - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/10 18:24:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/10 19:17:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7741) Bad dependency via SBT - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/10 20:16:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-4453) add request prioritization - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2019/01/10 21:28:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-7741) Bad dependency via SBT - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/10 23:53:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-7741) Bad dependency via SBT - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/11 00:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException - posted by "flying (JIRA)" <ji...@apache.org> on 2019/01/11 05:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException - posted by "flying (JIRA)" <ji...@apache.org> on 2019/01/11 05:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability - posted by "Ashish Surana (JIRA)" <ji...@apache.org> on 2019/01/11 05:34:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-7812) Deadlock in SaslServerAuthenticator related threads - posted by "Abhi (JIRA)" <ji...@apache.org> on 2019/01/11 09:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7812) Deadlock in SaslServerAuthenticator related threads - posted by "Rajini Sivaram (JIRA)" <ji...@apache.org> on 2019/01/11 09:54:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7813) JmxTool throws NPE when --object-name is omitted - posted by "Attila Sasvari (JIRA)" <ji...@apache.org> on 2019/01/11 10:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7814) Broker shut down while cleaning up log file - posted by "EverZhang (JIRA)" <ji...@apache.org> on 2019/01/11 11:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7814) Broker shut down while cleaning up log file - posted by "EverZhang (JIRA)" <ji...@apache.org> on 2019/01/11 11:55:00 UTC, 7 replies.
- [jira] [Updated] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/11 14:36:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/11 14:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/11 14:43:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6738) Kafka Connect handling of bad data - posted by "Jordan Moore (JIRA)" <ji...@apache.org> on 2019/01/11 17:27:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6738) Kafka Connect handling of bad data - posted by "Jordan Moore (JIRA)" <ji...@apache.org> on 2019/01/11 17:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7792) Trogdor should have an uptime function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/11 19:31:01 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-7814) Broker shut down while cleaning up log file - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2019/01/11 20:02:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7815) SourceTask should expose ACK'd offsets, metadata - posted by "Ryanne Dolan (JIRA)" <ji...@apache.org> on 2019/01/11 20:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7790) Fix Bugs in Trogdor Task Expiration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/11 21:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7793) Improve the Trogdor command-line - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/12 00:37:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/12 00:38:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-7609) Add Protocol Generator for Kafka - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/12 00:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7814) Broker shut down while cleaning up log file - posted by "EverZhang (JIRA)" <ji...@apache.org> on 2019/01/12 01:00:52 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7214) Mystic FATAL error - posted by "Balaji (JIRA)" <ji...@apache.org> on 2019/01/12 01:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7214) Mystic FATAL error - posted by "Balaji (JIRA)" <ji...@apache.org> on 2019/01/12 01:26:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-7815) SourceTask should expose ACK'd offsets, metadata - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/13 02:27:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-7816) Windowed topic should have window size as part of the metadata - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/13 03:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7781) Add validation check for Topic retention.ms property - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/13 04:00:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6958) Allow to define custom processor names with KStreams DSL - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/13 05:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4721) KafkaStreams (and possibly others) should inherit Closeable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/13 06:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7781) Add validation check for Topic retention.ms property - posted by "Manikumar (JIRA)" <ji...@apache.org> on 2019/01/13 13:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7658) Add KStream#toTable to the Streams DSL - posted by "Kamal Chandraprakash (JIRA)" <ji...@apache.org> on 2019/01/13 17:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7024) Rocksdb state directory should be created before opening the DB - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/14 00:03:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7813) JmxTool throws NPE when --object-name is omitted - posted by "huxihx (JIRA)" <ji...@apache.org> on 2019/01/14 01:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7813) JmxTool throws NPE when --object-name is omitted - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/14 01:56:00 UTC, 0 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 "GaoLiang (JIRA)" <ji...@apache.org> on 2019/01/14 08:08:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition - posted by "Candice Wan (JIRA)" <ji...@apache.org> on 2019/01/14 08:16:00 UTC, 3 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 "GaoLiang (JIRA)" <ji...@apache.org> on 2019/01/14 08:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2019/01/14 08:23:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-7817) Multiple Consumer Group Management with Regex - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2019/01/14 09:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7817) Multiple Consumer Group Management with Regex - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2019/01/14 09:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7297) Both read/write access to Log.segments should be protected by lock - posted by "Zhanxiang (Patrick) Huang (JIRA)" <ji...@apache.org> on 2019/01/14 10:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7818) Make the KafkaConsumer AutoCloseable - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/14 12:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7818) Make the KafkaConsumer AutoCloseable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/14 12:55:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-4325) Improve processing of late records for window operations - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/14 13:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7805) Use --bootstrap-server option in ducktape tests where applicable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/14 15:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7819) Trogdor - Improve RoundTripWorker - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2019/01/14 15:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters - posted by "Dmitry Buykin (JIRA)" <ji...@apache.org> on 2019/01/14 16:10:00 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-4850) RocksDb cannot use Bloom Filters - posted by "Dmitry Buykin (JIRA)" <ji...@apache.org> on 2019/01/14 16:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7818) Make the KafkaConsumer AutoCloseable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/14 17:08:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/14 17:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/14 17:29:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist - posted by "Arabelle Hou (JIRA)" <ji...@apache.org> on 2019/01/14 18:36:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7817) Multiple Consumer Group Management with Regex - posted by "Alex Dunayevsky (JIRA)" <ji...@apache.org> on 2019/01/14 19:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7820) distinct count kafka streams api - posted by "Vinoth Rajasekar (JIRA)" <ji...@apache.org> on 2019/01/14 19:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6627) Console producer default config values override explicitly provided properties - posted by "Kan Li (JIRA)" <ji...@apache.org> on 2019/01/14 20:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7821) Streams: default cache size can lose session windows in high-throughput deployment - posted by "Matthew Jarvie (JIRA)" <ji...@apache.org> on 2019/01/14 21:27:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7821) Default cache size can lose session windows in high-throughput deployment - posted by "Matthew Jarvie (JIRA)" <ji...@apache.org> on 2019/01/14 21:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7503) Integration Test Framework for Connect - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/14 21:58:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7503) Integration Test Framework for Connect - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2019/01/14 22:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7820) distinct count kafka streams api - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/14 22:38:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-7818) Make the KafkaConsumer AutoCloseable - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/01/14 23:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7461) Connect Values converter should have coverage of logical types - posted by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2019/01/14 23:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7461) Connect Values converter should have coverage of logical types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/14 23:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6803) Caching is turned off for stream-stream Join - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/15 01:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6803) Caching is turned off for stream-stream Join - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/15 01:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7820) distinct count kafka streams api - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/15 03:47:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4850) RocksDb cannot use Bloom Filters - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/15 04:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7497) Kafka Streams should support self-join on streams - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/15 04:13:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-7822) Kafka Log Implementation picture in the documentation is wrong - posted by "Lars Francke (JIRA)" <ji...@apache.org> on 2019/01/15 09:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7822) Kafka Log Implementation picture in the documentation is wrong - posted by "hackerwin7 (JIRA)" <ji...@apache.org> on 2019/01/15 09:36:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7823) Missing release notes pages - posted by "Viktor Somogyi (JIRA)" <ji...@apache.org> on 2019/01/15 09:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7822) Kafka Log Implementation picture in the documentation is wrong - posted by "Lars Francke (JIRA)" <ji...@apache.org> on 2019/01/15 09:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2019/01/15 13:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store - posted by "Tommy Becker (JIRA)" <ji...@apache.org> on 2019/01/15 14:27:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-7391) Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit) - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/15 16:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7391) Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/15 16:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7824) Require member.id for initial join group request - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/15 17:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7824) Require member.id for initial join group request - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/15 17:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7480) GlobalThread should honor custom auto.offset.reset policy - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/15 17:48:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4113) Allow KTable bootstrap - posted by "Edmondo Porcu (JIRA)" <ji...@apache.org> on 2019/01/15 17:59:00 UTC, 9 replies.
- [jira] [Created] (KAFKA-7825) Kafka MirrorMaker crashes unexpectedly - posted by "Joe Devilla (JIRA)" <ji...@apache.org> on 2019/01/15 18:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7294) Optimize repartitioning for merge() - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/15 18:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7821) Streams: default cache size can lose session windows in high-throughput deployment - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/15 19:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6455) Improve timestamp propagation at DSL level - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/15 19:46:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7826) Connect Standalone System tests are failing - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2019/01/15 19:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7826) Connect Standalone System tests are failing - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2019/01/15 19:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7826) Connect Standalone System tests are failing - posted by "Magesh kumar Nandakumar (JIRA)" <ji...@apache.org> on 2019/01/15 19:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7825) Kafka MirrorMaker crashes unexpectedly - posted by "Joe Devilla (JIRA)" <ji...@apache.org> on 2019/01/15 20:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7824) Require member.id for initial join group request - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/15 21:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7824) Require member.id for initial join group request - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/15 21:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7827) Consumer stops receiving messages when FIRST leader started is killed - posted by "Somnath Choudhuri (JIRA)" <ji...@apache.org> on 2019/01/15 21:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/15 22:56:00 UTC, 12 replies.
- [jira] [Comment Edited] (KAFKA-7820) distinct count kafka streams api - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/16 00:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7828) Add Trogdor ExternalCommandSpec and ExternalCommandWorker - posted by "Xi Yang (JIRA)" <ji...@apache.org> on 2019/01/16 01:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7827) Consumer stops receiving messages when FIRST leader started is killed - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2019/01/16 07:08:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7814) Broker shut down while cleaning up log file - posted by "EverZhang (JIRA)" <ji...@apache.org> on 2019/01/16 08:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-4113) Allow KTable bootstrap - posted by "Edmondo Porcu (JIRA)" <ji...@apache.org> on 2019/01/16 10:53:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-7814) Broker shut down while cleaning up log file - posted by "Ishwor (JIRA)" <ji...@apache.org> on 2019/01/16 12:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7828) Execute Trogdor tasks with external commands - posted by "Xi Yang (JIRA)" <ji...@apache.org> on 2019/01/16 13:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7828) Execute Trogdor tasks with external commands - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/16 13:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3370) Add options to auto.offset.reset to reset offsets upon initialization only - posted by "Tayida Tapjinda (JIRA)" <ji...@apache.org> on 2019/01/16 17:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7829) Inaccurate description for --reassignment-json-file option in ReassignPartitionsCommand - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/16 17:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7829) Inaccurate description for --reassignment-json-file option in ReassignPartitionsCommand - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/16 17:28:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4107) Support offset reset capability in Kafka Connect - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2019/01/16 17:56:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7829) Inaccurate description for --reassignment-json-file option in ReassignPartitionsCommand - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2019/01/16 18:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7829) Javadoc should show that alterReplicaLogDirs() is supported in Kafka 1.1.0 or later - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2019/01/16 18:33:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7829) Javadoc should show that AdminClient.alterReplicaLogDirs() is supported in Kafka 1.1.0 or later - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2019/01/16 18:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7829) Javadoc should show that AdminClient.alterReplicaLogDirs() is supported in Kafka 1.1.0 or later - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/16 18:38:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7830) Convert Kafka RPCs to use automatically generated code - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/16 18:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7831) Consumer SubscriptionState missing synchronization - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/16 18:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7609) Add Protocol Generator for Kafka - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/16 18:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7832) Use automatic RPC generation in CreateTopics - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/16 19:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7788) Support null defaults in KAFKA-7609 RPC specifications - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/16 19:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7787) Add error specifications to KAFKA-7609 - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/16 19:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7833) StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder - posted by "Sam Lendle (JIRA)" <ji...@apache.org> on 2019/01/16 19:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7834) Extend collected logs in system test services to include heap dumps - posted by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2019/01/16 19:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7834) Extend collected logs in system test services to include heap dumps - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/16 19:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/16 20:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/16 22:47:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/16 22:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6687) Allow to read a topic multiple times - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/17 00:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/17 03:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7833) StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/17 03:38:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-7833) StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/17 03:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7520) Adding possibility to configure versions in Mirror Maker ducktape test - posted by "Andras Katona (JIRA)" <ji...@apache.org> on 2019/01/17 10:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7520) Adding possibility to configure versions in Mirror Maker ducktape test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/17 10:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/17 10:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/17 15:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7835) Kafka Connect - Unable to create multiple connectors in a single HTTP (REST) call - posted by "Suraj Fale (JIRA)" <ji...@apache.org> on 2019/01/17 16:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7835) Kafka Connect - Unable to create multiple connectors in a single HTTP (REST) call - posted by "Suraj Fale (JIRA)" <ji...@apache.org> on 2019/01/17 16:15:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-7738) Track partition leader epochs in client metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/17 18:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7738) Track partition leader epochs in client metadata - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/17 18:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2019/01/17 19:31:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2019/01/17 19:36:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-6359) Work for KIP-236 - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2019/01/17 22:24:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6359) Work for KIP-236 - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2019/01/17 22:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7832) Use automatic RPC generation in CreateTopics - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2019/01/17 22:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7829) Javadoc should show that AdminClient.alterReplicaLogDirs() is supported in Kafka 1.1.0 or later - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/17 23:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 00:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7836) The propagation of log dir failure can be delayed due to slowness in closing the file handles - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/18 00:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7836) The propagation of log dir failure can be delayed due to slowness in closing the file handles - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/18 00:56:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7698) Kafka Broker fail to start: ProducerFencedException thrown from producerstatemanager.scala!checkProducerEpoch - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/18 00:58:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7837) maybeShrinkIsr may not reflect OfflinePartitions immediately - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/18 01:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7837) maybeShrinkIsr may not reflect OfflinePartitions immediately - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/18 01:06:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-7838) improve logging in Partition.maybeShrinkIsr() - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/18 01:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is invalid. (kafka.log.LogCleanerManager$) - posted by "Zack Kobza (JIRA)" <ji...@apache.org> on 2019/01/18 01:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7838) improve logging in Partition.maybeShrinkIsr() - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2019/01/18 02:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2019/01/18 02:25:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2019/01/18 02:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index - posted by "Ivan Ponomarev (JIRA)" <ji...@apache.org> on 2019/01/18 04:34:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7839) CLASSPATH with single component containing globs breaks kafka-run-class.sh - posted by "Robert Wunderer (JIRA)" <ji...@apache.org> on 2019/01/18 08:34:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7839) CLASSPATH with single component containing globs breaks kafka-run-class.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/18 08:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6848) Kafka consumer failed to get correct offset after commit - posted by "zhenyu jiang (JIRA)" <ji...@apache.org> on 2019/01/18 09:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6848) Kafka consumer failed to get correct offset after commit - posted by "zhenyu jiang (JIRA)" <ji...@apache.org> on 2019/01/18 09:34:00 UTC, 0 replies.
- [jira] [Updated] (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 "Juris Pavlyuchenkov (JIRA)" <ji...@apache.org> on 2019/01/18 11:11:00 UTC, 1 replies.
- [jira] [Comment Edited] (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 "Juris Pavlyuchenkov (JIRA)" <ji...@apache.org> on 2019/01/18 11:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7840) Documentation for cleanup.policy is out of date - posted by "Josh Wiley (JIRA)" <ji...@apache.org> on 2019/01/18 16:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7024) Rocksdb state directory should be created before opening the DB - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/18 17:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7024) Rocksdb state directory should be created before opening the DB - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/18 17:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7841) KIP-419 Safely notify Kafka Connect SourceTask is stopped - posted by "Andrew Schofield (JIRA)" <ji...@apache.org> on 2019/01/18 18:09:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-3745) Consider adding join key to ValueJoiner interface - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:20:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-4726) ValueMapper should have (read) access to key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4218) Enable access to key in ValueTransformer - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4726) ValueMapper should have (read) access to key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-3745) Consider adding join key to ValueJoiner interface - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4726) ValueMapper should have (read) access to key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7842) Reducer should have (read) access to key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7842) Reducer should have (read) access to key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:37:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7843) Initializer should have (read) access to key - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:37:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-3745) Consider adding join key to ValueJoiner interface - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 18:40:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7837) maybeShrinkIsr may not reflect OfflinePartitions immediately - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2019/01/18 19:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7838) improve logging in Partition.maybeShrinkIsr() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/18 19:18:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7844) Fix "Cannot lock buildSrc build lock as it has already been locked by this process" error in jarAll - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/18 19:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7842) Reducer should have (read) access to key - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2019/01/18 20:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7843) Initializer should have (read) access to key - posted by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2019/01/18 20:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7844) Fix "Cannot lock buildSrc build lock as it has already been locked by this process" error in jarAll - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/18 20:57:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/18 21:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7845) NotLeaderForPartitionException error when publishing after a broker has died - posted by "Jennifer Thompson (JIRA)" <ji...@apache.org> on 2019/01/18 21:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7845) Kafka clients do not re-resolve ips when a broker is replaced. - posted by "Jennifer Thompson (JIRA)" <ji...@apache.org> on 2019/01/18 21:48:00 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-4730) Streams does not have an in-memory windowed store - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/19 01:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6970) Kafka streams lets the user call init() and close() on a state store, when inside Processors - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/19 01:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7502) Cleanup KTable materialization logic in a single place - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/19 11:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4453) add request prioritization - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/19 19:01:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/19 19:08:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7018) persist memberId for consumer restart - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/20 05:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6964) Add ability to print all internal topic names - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/20 08:14:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-6964) Add ability to print all internal topic names - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/20 08:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/20 08:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7841) KIP-419 Safely notify Kafka Connect SourceTask is stopped - posted by "Chris Bogan (JIRA)" <ji...@apache.org> on 2019/01/20 15:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7846) KIP-421: Support resolving externalized secrets in AbstractConfig - posted by "TEJAL ADSUL (JIRA)" <ji...@apache.org> on 2019/01/21 02:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7847) KIP-421: Support resolving externalized secrets in AbstractConfig - posted by "TEJAL ADSUL (JIRA)" <ji...@apache.org> on 2019/01/21 02:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7816) Windowed topic should have window size as part of the metadata - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/21 05:56:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7450) "Handshake message sequence violation" related ssl handshake failure leads to high cpu usage - posted by "Vladimir Berunenko (JIRA)" <ji...@apache.org> on 2019/01/21 06:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7848) Idempotence producer keep retry on OutOfOrderSequenceException - posted by "zwangbo (JIRA)" <ji...@apache.org> on 2019/01/21 09:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7848) Idempotence producer keep retry on OutOfOrderSequenceException - posted by "zwangbo (JIRA)" <ji...@apache.org> on 2019/01/21 09:08:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7840) Documentation for cleanup.policy is out of date - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/21 12:57:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-7840) Documentation for cleanup.policy is out of date - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/21 12:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7782) cleanup policy for offsets topic should be configurable - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/21 14:32:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-7849) Warning when adding GlobalKTable - posted by "Dmitry Minkovsky (JIRA)" <ji...@apache.org> on 2019/01/21 15:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow - posted by "guilherme gomes rocha (JIRA)" <ji...@apache.org> on 2019/01/21 16:33:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow - posted by "guilherme gomes rocha (JIRA)" <ji...@apache.org> on 2019/01/21 16:51:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7850) Remove deprecated KStreamTestDriver - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2019/01/22 03:50:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7850) Remove deprecated KStreamTestDriver - posted by "Richard Yu (JIRA)" <ji...@apache.org> on 2019/01/22 03:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7844) Fix "Cannot lock buildSrc build lock as it has already been locked by this process" error in jarAll - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2019/01/22 05:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7850) Remove deprecated KStreamTestDriver - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 07:44:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-6777) Wrong reaction on Out Of Memory situation - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2019/01/22 09:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7851) Continue data streaming while rebalancing - posted by "Christian Richter (JIRA)" <ji...@apache.org> on 2019/01/22 15:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7852) Add public version of EmbeddedKafkaCluster - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/22 16:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7853) Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor parameter list - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/22 16:42:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7853) Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor parameter list - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/22 16:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0 - posted by "Zhanxiang (Patrick) Huang (JIRA)" <ji...@apache.org> on 2019/01/22 17:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7851) Continue data streaming while rebalancing - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 17:47:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-7852) Add public version of EmbeddedKafkaCluster - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 17:49:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 17:53:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-7855) Kafka Streams Maven Archetype quickstart fails to compile out of the box - posted by "Michael Drogalis (JIRA)" <ji...@apache.org> on 2019/01/22 17:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7856) Cryptographic Issues by Insufficient Entropy - posted by "Victor Sartori (JIRA)" <ji...@apache.org> on 2019/01/22 17:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7856) Cryptographic Issues by Insufficient Entropy - posted by "Victor Sartori (JIRA)" <ji...@apache.org> on 2019/01/22 18:01:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7857) Add AbstractCoordinatorConfig class to consolidate consumer coordinator configs between Consumer and Connect - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/22 18:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7466) Implement KIP-339: Create a new IncrementalAlterConfigs API - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/22 18:44:02 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0 - posted by "Adem Efe Gencer (JIRA)" <ji...@apache.org> on 2019/01/22 19:23:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-7432) API Method on Kafka Streams for processing chunks/batches of data - posted by "Del Bao (JIRA)" <ji...@apache.org> on 2019/01/22 21:34:02 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7803) Kafka Streams internal topics config is not updated when the code is changed - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 22:23:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7821) Streams: default cache size can lose session windows in high-throughput deployment - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 22:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7777) Decouple topic serdes from materialized serdes - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 22:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7777) Decouple topic serdes from materialized serdes - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 22:30:01 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7775) [KStream] remove topic prefix from consumer configuration to resolve unnecessary warning - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/22 22:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2019/01/22 23:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2019/01/22 23:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7858) Replace JoinGroup request/response with automated protocol - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/23 00:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7859) Replace LeaveGroup request/response with automated protocol - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/23 00:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7848) Idempotence producer keep retry on OutOfOrderSequenceException - posted by "huxihx (JIRA)" <ji...@apache.org> on 2019/01/23 02:32:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7860) kafka broker restart isr lose - posted by "qinzl_1 (JIRA)" <ji...@apache.org> on 2019/01/23 08:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7492) Explain `null` handling for reduce and aggregate - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2019/01/23 08:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2019/01/23 08:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6708) Review Exception messages with regards to Serde Useage - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2019/01/23 08:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2019/01/23 08:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-2111) Command Line Standardization - Add Help Arguments & List Required Fields - posted by "Mariam John (JIRA)" <ji...@apache.org> on 2019/01/23 08:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2019/01/23 11:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2019/01/23 14:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2019/01/23 14:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2019/01/23 14:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7819) Trogdor - Improve RoundTripWorker - posted by "Stanislav Kozlovski (JIRA)" <ji...@apache.org> on 2019/01/23 14:21:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default - posted by "Edoardo Comar (JIRA)" <ji...@apache.org> on 2019/01/23 14:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7819) Trogdor - Improve RoundTripWorker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/23 14:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133) - posted by "Srinivas Reddy (JIRA)" <ji...@apache.org> on 2019/01/23 15:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5272) Improve validation for Alter Configs (KIP-133) - posted by "Srinivas Reddy (JIRA)" <ji...@apache.org> on 2019/01/23 15:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5272) Improve validation for Alter Configs (KIP-133) - posted by "Srinivas Reddy (JIRA)" <ji...@apache.org> on 2019/01/23 15:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-4680) min.insync.replicas can be set higher than replication factor - posted by "Srinivas Reddy (JIRA)" <ji...@apache.org> on 2019/01/23 16:00:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7852) Add public version of EmbeddedKafkaCluster - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/23 16:24:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-7852) Add public version of EmbeddedKafkaCluster - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/23 16:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2019/01/23 18:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4968) The NetworkClient should rate-limit its log messages about protocol downgrades - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/23 18:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/23 18:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7740) Kafka Admin Client should be able to manage configurations for users and clients - posted by "Yaodong Yang (JIRA)" <ji...@apache.org> on 2019/01/23 19:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7863) Kafka 1.1.1 JmxReporter doesn't remove old mbean(OOME as result) - posted by "Alexandr Minaev (JIRA)" <ji...@apache.org> on 2019/01/23 19:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/23 19:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values - posted by "Chris Egerton (JIRA)" <ji...@apache.org> on 2019/01/23 19:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7859) Replace LeaveGroup request/response with automated protocol - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/23 19:14:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7740) Kafka Admin Client should be able to manage quota configurations for users and clients - posted by "Yaodong Yang (JIRA)" <ji...@apache.org> on 2019/01/23 21:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7864) AdminZkClient.validateTopicCreate() should validate that partitions are 0-based - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/23 21:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7864) AdminZkClient.validateTopicCreate() should validate that partitions are 0-based - posted by "Sriharsha Chintalapani (JIRA)" <ji...@apache.org> on 2019/01/23 22:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6460) Add mocks for state stores used in Streams unit testing - posted by "Yishun Guan (JIRA)" <ji...@apache.org> on 2019/01/23 22:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7740) Kafka Admin Client should be able to manage user/client configurations for users and clients - posted by "Yaodong Yang (JIRA)" <ji...@apache.org> on 2019/01/24 00:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7740) Kafka Admin Client should be able to manage user/client configurations for users and clients - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/24 00:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6995) Make config "internal.leave.group.on.close" public - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/24 00:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7865) Kafka Constant Consumer Errors for ~30 min after Network Blip - posted by "Aravind Velamur Srinivasan (JIRA)" <ji...@apache.org> on 2019/01/24 00:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7849) Warning when adding GlobalKTable - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/24 00:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7855) Kafka Streams Maven Archetype quickstart fails to compile out of the box - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/24 01:01:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-7866) Duplicate offsets after transaction index append failure - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/24 01:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7440) Use leader epoch in consumer fetch requests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/24 02:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/24 02:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7837) maybeShrinkIsr may not reflect OfflinePartitions immediately - posted by "Dhruvil Shah (JIRA)" <ji...@apache.org> on 2019/01/24 07:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7867) Broker fails after corrupted page table - posted by "Maurits Hartman (JIRA)" <ji...@apache.org> on 2019/01/24 10:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7223) KIP-328: Add in-memory Suppression - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/24 13:48:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-7223) KIP-328: Add in-memory Suppression - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/24 13:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7855) Kafka Streams Maven Archetype quickstart fails to compile out of the box - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/24 14:38:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7868) Move __consumer_offsets schema to the clients - posted by "Charly Molter (JIRA)" <ji...@apache.org> on 2019/01/24 16:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7855) Kafka Streams Maven Archetype quickstart fails to compile out of the box - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/24 18:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7869) Refactor RocksDBConfigSetter API to separate DBOptions and CFOptions - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/24 19:00:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-7796) structured streaming fetched wrong current offset from kafka - posted by "Ryne Yang (JIRA)" <ji...@apache.org> on 2019/01/24 22:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7796) structured streaming fetched wrong current offset from kafka - posted by "Ryne Yang (JIRA)" <ji...@apache.org> on 2019/01/24 22:33:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7273) Converters should have access to headers. - posted by "Jeremy Custenborder (JIRA)" <ji...@apache.org> on 2019/01/24 22:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7856) Cryptographic Issues by Insufficient Entropy - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:47:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-7856) Cryptographic Issues by Insufficient Entropy - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7834) Extend collected logs in system test services to include heap dumps - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7741) Bad dependency via SBT - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:51:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:53:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:53:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:54:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7715) Connect should have a parameter to disable WADL output for OPTIONS method - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7693) "IllegalArgumentException: Invalid negative sequence number used" in Kafka Client - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 22:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2854) Make KerberosName implement PrincipalToLocal plugin so authorizer and authenticator can share this. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/24 22:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2145) An option to add topic owners. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/24 22:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7741) Bad dependency via SBT - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/24 23:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7866) Duplicate offsets after transaction index append failure - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/24 23:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7692) updateFirstUnstableOffset NPE due to sequenceId overflow in ProducerStateManager.append - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/25 00:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7693) "IllegalArgumentException: Invalid negative sequence number used" in Kafka Client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/25 00:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7692) updateFirstUnstableOffset NPE due to sequenceId overflow in ProducerStateManager.append - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/25 01:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. - posted by "Chakhsu Lau (JIRA)" <ji...@apache.org> on 2019/01/25 09:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. - posted by "Chakhsu Lau (JIRA)" <ji...@apache.org> on 2019/01/25 09:16:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7871) Getting TimeoutException in Kafka Producer when using batch size 0 - posted by "Pradeep Bansal (JIRA)" <ji...@apache.org> on 2019/01/25 10:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown - posted by "Wojtek Malinowski (JIRA)" <ji...@apache.org> on 2019/01/25 15:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7872) Consider allowing transformations on GlobalKTable before materialization - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/25 18:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7872) Consider allowing transformations on GlobalKTable before materialization - posted by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/01/25 18:57:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read. - posted by "Christoffer Hammarström (JIRA)" <ji...@apache.org> on 2019/01/25 20:08:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/25 22:07:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7838) improve logging in Partition.maybeShrinkIsr() - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/25 22:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7873) KafkaBasedLog's consumer should always seek to beginning when starting - posted by "Randall Hauch (JIRA)" <ji...@apache.org> on 2019/01/26 00:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7873) KafkaBasedLog's consumer should always seek to beginning when starting - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/26 00:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7837) maybeShrinkIsr may not reflect OfflinePartitions immediately - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2019/01/26 03:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6478) kafka-run-class.bat fails if CLASSPATH contains spaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/26 04:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7840) Documentation for cleanup.policy is out of date - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/26 15:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7840) Documentation for cleanup.policy is out of date - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/26 15:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7837) maybeShrinkIsr may not reflect OfflinePartitions immediately - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/27 01:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7874) NPE thrown while instantiating a KafkaStreams. object - posted by "Christopher S Lester (JIRA)" <ji...@apache.org> on 2019/01/27 03:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7874) NPE thrown while instantiating a KafkaStreams. object - posted by "Christopher S Lester (JIRA)" <ji...@apache.org> on 2019/01/27 03:30:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/27 05:39:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-4217) KStream.transform equivalent of flatMap - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/27 05:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4217) KStream.transform equivalent of flatMap - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/27 05:41:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-7875) Add KStream#flatTransformValues - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/27 05:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7875) Add KStream#flatTransformValues - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/27 05:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7875) Add KStream#flatTransformValues - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/27 05:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7874) NPE thrown while instantiating a KafkaStreams. object - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/27 20:23:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-7874) NPE thrown while instantiating a KafkaStreams. object - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/01/27 20:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7401) Broker fails to start when recovering a segment from before the log start offset - posted by "Anna Povzner (JIRA)" <ji...@apache.org> on 2019/01/28 05:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7244) Add note about memory map kernel limits to documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/28 06:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7874) NPE thrown while instantiating a KafkaStreams. object - posted by "Christopher S Lester (JIRA)" <ji...@apache.org> on 2019/01/28 06:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7876) Broker suddenly got disconnected - posted by "Anthony Lazam (JIRA)" <ji...@apache.org> on 2019/01/28 07:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7876) Broker suddenly got disconnected - posted by "Anthony Lazam (JIRA)" <ji...@apache.org> on 2019/01/28 07:40:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-217) Client test suite - posted by "Sönke Liebau (JIRA)" <ji...@apache.org> on 2019/01/28 09:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-659) Support request pipelining in the network server - posted by "Sönke Liebau (JIRA)" <ji...@apache.org> on 2019/01/28 09:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-817) Implement a zookeeper path-based controlled shutdown tool - posted by "Sönke Liebau (JIRA)" <ji...@apache.org> on 2019/01/28 09:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1021) Write a tool to check replica lag for individual topic partitions - posted by "Sönke Liebau (JIRA)" <ji...@apache.org> on 2019/01/28 09:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic - posted by "Tommy Becker (JIRA)" <ji...@apache.org> on 2019/01/28 13:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7397) Ability to apply DSL stateless transformation on a global table - posted by "Tommy Becker (JIRA)" <ji...@apache.org> on 2019/01/28 13:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7877) Connect DLQ not used in SinkTask put() - posted by "Andrew Bourgeois (JIRA)" <ji...@apache.org> on 2019/01/28 13:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7877) Connect DLQ not used in SinkTask put() - posted by "Andrew Bourgeois (JIRA)" <ji...@apache.org> on 2019/01/28 13:38:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7878) Connect Task already exists in this worker when failed to create consumer - posted by "Loïc Monney (JIRA)" <ji...@apache.org> on 2019/01/28 17:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2170) 10 LogTest cases failed for file.renameTo failed under windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/28 18:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7876) Broker suddenly got disconnected - posted by "Anthony Lazam (JIRA)" <ji...@apache.org> on 2019/01/29 03:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7876) Broker suddenly got disconnected - posted by "Anthony Lazam (JIRA)" <ji...@apache.org> on 2019/01/29 03:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7879) Data directory size decreases every few minutes when producer is sending large amount of data - posted by "Pradeep Bansal (JIRA)" <ji...@apache.org> on 2019/01/29 04:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7880) KafkaConnect should standardize worker thread name - posted by "YeLiang (JIRA)" <ji...@apache.org> on 2019/01/29 05:36:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-7880) KafkaConnect should standardize worker thread name - posted by "YeLiang (JIRA)" <ji...@apache.org> on 2019/01/29 05:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7879) Data directory size decreases every few minutes when producer is sending large amount of data - posted by "huxihx (JIRA)" <ji...@apache.org> on 2019/01/29 08:00:07 UTC, 2 replies.
- [jira] [Created] (KAFKA-7881) Inter.broker.procol.version is incorrect for Rolling Upgrade - posted by "M. Manna (JIRA)" <ji...@apache.org> on 2019/01/29 12:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7881) Inter.broker.procol.version is incorrect for Rolling Upgrade - posted by "M. Manna (JIRA)" <ji...@apache.org> on 2019/01/29 12:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7881) Inter.broker.procol.version is incorrect for Rolling Upgrade - posted by "M. Manna (JIRA)" <ji...@apache.org> on 2019/01/29 13:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7882) StateStores are frequently closed during the 'transform' method - posted by "Mateusz Owczarek (JIRA)" <ji...@apache.org> on 2019/01/29 16:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7883) Add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect - posted by "Jérémy Thulliez (JIRA)" <ji...@apache.org> on 2019/01/29 16:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7882) StateStores are frequently closed during the 'transform' method - posted by "Mateusz Owczarek (JIRA)" <ji...@apache.org> on 2019/01/29 16:34:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values" - posted by "James Cheng (JIRA)" <ji...@apache.org> on 2019/01/29 18:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/30 11:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values" - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/30 11:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7719) Improve fairness in SocketServer processors - posted by "Mark Thomas (JIRA)" <ji...@apache.org> on 2019/01/30 16:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7719) Improve fairness in SocketServer processors - posted by "Mark Thomas (JIRA)" <ji...@apache.org> on 2019/01/30 16:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7374) Tiered Storage - posted by "Mark Thomas (JIRA)" <ji...@apache.org> on 2019/01/30 16:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7374) Tiered Storage - posted by "Mark Thomas (JIRA)" <ji...@apache.org> on 2019/01/30 16:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7885) Streams: TopologyDescription violates equals-hashCode contract. - posted by "Piotr Fras (JIRA)" <ji...@apache.org> on 2019/01/30 19:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7885) Streams: TopologyDescription violates equals-hashCode contract. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/30 19:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7877) Connect DLQ not used in SinkTask put() - posted by "Arjun Satish (JIRA)" <ji...@apache.org> on 2019/01/30 19:57:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-7877) Connect DLQ not used in SinkTask put() - posted by "Andrew Bourgeois (JIRA)" <ji...@apache.org> on 2019/01/30 20:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6278) Allow multiple concurrent transactions on a single producer - posted by "Ask Solem (JIRA)" <ji...@apache.org> on 2019/01/30 21:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method - posted by "John Roesler (JIRA)" <ji...@apache.org> on 2019/01/31 01:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7886) Some partitions are fully truncated during recovery when log.message.format = 0.10.2 & inter.broker.protocol >= 0.11 - posted by "Hervé RIVIERE (JIRA)" <ji...@apache.org> on 2019/01/31 14:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7886) Some partitions are fully truncated during recovery when log.message.format = 0.10.2 & inter.broker.protocol >= 0.11 - posted by "Hervé RIVIERE (JIRA)" <ji...@apache.org> on 2019/01/31 15:01:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values" - posted by "Lee Dongjin (JIRA)" <ji...@apache.org> on 2019/01/31 15:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7887) Transaction Producer hanging when commiting/aborting transaction after a broker failure - posted by "Cameron (JIRA)" <ji...@apache.org> on 2019/01/31 16:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7887) Transaction Producer hanging when commiting/aborting transaction after a broker failure - posted by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2019/01/31 17:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7887) Transaction Producer hanging when commiting/aborting transaction after a broker failure - posted by "Cameron (JIRA)" <ji...@apache.org> on 2019/01/31 17:26:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-7887) Transaction Producer hanging when commiting/aborting transaction after a broker failure - posted by "Cameron (JIRA)" <ji...@apache.org> on 2019/01/31 17:28:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7792) Trogdor should have an uptime function - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/31 18:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7792) Trogdor should have an uptime function - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/31 18:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7790) Fix Bugs in Trogdor Task Expiration - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/31 18:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7793) Improve the Trogdor command-line - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/31 18:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7793) Improve the Trogdor command-line - posted by "Colin P. McCabe (JIRA)" <ji...@apache.org> on 2019/01/31 18:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7888) kafka cluster not recovering - Shrinking ISR from 14,13 to 13 (kafka.cluster.Partition) continously - posted by "Kemal ERDEN (JIRA)" <ji...@apache.org> on 2019/01/31 18:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7889) Kafka broker crashes on windows when log compaction is used - posted by "huzaifa kagazwala (JIRA)" <ji...@apache.org> on 2019/01/31 19:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7859) Replace LeaveGroup request/response with automated protocol - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/31 19:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7816) Windowed topic should have window size as part of the metadata - posted by "Boyang Chen (JIRA)" <ji...@apache.org> on 2019/01/31 19:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-7890) Invalidate ClusterConnectionState cache for a broker if the hostname of the broker changes. - posted by "Mark Cho (JIRA)" <ji...@apache.org> on 2019/01/31 21:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7890) Invalidate ClusterConnectionState cache for a broker if the hostname of the broker changes. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/01/31 21:38:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6460) Add mocks for state stores used in Streams unit testing - posted by "Yishun Guan (JIRA)" <ji...@apache.org> on 2019/01/31 23:33:00 UTC, 0 replies.