You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Commented] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/01 16:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8825) Add option to reset consumer offset by relative time - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/01 19:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8854) Optimize bulk loading of RocksDB during state restoration of Streams - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/02 03:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8719) kafka-console-consumer bypassing sentry evaluations while specifying --partition option - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/02 06:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8855) Collect and Expose Client's Name and Version in the Brokers - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/09/02 08:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode - posted by "Reynir Hübner (Jira)" <ji...@apache.org> on 2019/09/02 11:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/02 11:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/02 11:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8032) Flaky Test UserQuotaTest#testQuotaOverrideDelete - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/02 12:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8857) Config describe should not return isReadOnly=false based on synonyms - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/02 12:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8857) Config describe should not return isReadOnly=false based on synonyms - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/02 12:44:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8858) Kafka Streams - Failed to Rebalance Error and stream consumer stuck for some reason - posted by "Ante B. (Jira)" <ji...@apache.org> on 2019/09/02 13:26:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-8858) Kafka Streams - Failed to Rebalance Error and stream consumer stuck for some reason - posted by "Ante B. (Jira)" <ji...@apache.org> on 2019/09/02 13:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/02 13:27:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-8760) KIP-504: Add new Java Authorizer API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/02 13:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8859) Refactor Cache-level Streams Metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/02 14:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8859) Refactor Cache-level Streams Metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/02 14:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8860) SslPrincipalMapper should handle distinguished names with spaces - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/09/02 17:28:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8860) SslPrincipalMapper should handle distinguished names with spaces - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/09/02 17:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8860) SslPrincipalMapper should handle distinguished names with spaces - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/09/02 17:31:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8860) SslPrincipalMapper should handle distinguished names with spaces - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/09/02 18:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8854) Optimize bulk loading of RocksDB during state restoration of Streams - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/03 03:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception - posted by "Harsh Singh (Jira)" <ji...@apache.org> on 2019/09/03 07:00:05 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8611) Add KStream#repartition operation - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/09/03 07:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2019/09/03 10:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic - posted by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2019/09/03 10:24:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/03 10:43:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8862) Misleading exception message for non-existant partition - posted by "Tom Bentley (Jira)" <ji...@apache.org> on 2019/09/03 12:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8862) Misleading exception message for non-existant partition - posted by "Tom Bentley (Jira)" <ji...@apache.org> on 2019/09/03 13:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8862) Misleading exception message for non-existant partition - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/03 13:06:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145 - posted by "Albert Lozano (Jira)" <ji...@apache.org> on 2019/09/03 14:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145 - posted by "Albert Lozano (Jira)" <ji...@apache.org> on 2019/09/03 14:10:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-8558) KIP-479 - Add Materialized Overload to KStream#Join - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/03 15:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145 - posted by "Albert Lozano (Jira)" <ji...@apache.org> on 2019/09/03 15:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8820) Use Admin API of Replica Reassignment in CLI tools - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/03 15:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future - posted by "alex gabriel (Jira)" <ji...@apache.org> on 2019/09/03 17:40:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8676) Avoid Stopping Unnecessary Connectors and Tasks - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/03 18:40:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7931) Java Client: if all ephemeral brokers fail, client can never reconnect to brokers - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/03 20:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8853) Create sustained connections test for Trogdor - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/03 21:14:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8813) Race condition when creating topics and changing their configuration - posted by "Vikas Singh (Jira)" <ji...@apache.org> on 2019/09/03 21:54:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-8846) Unexpected results joining a KStream to a KTable after repartitioning - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/03 22:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8864) Kafka Producer deadlocked on flush call - posted by "Shaan Appel (Jira)" <ji...@apache.org> on 2019/09/03 23:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8864) Kafka Producer deadlocked on flush call - posted by "Shaan Appel (Jira)" <ji...@apache.org> on 2019/09/03 23:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7849) Warning when adding GlobalKTable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/04 06:28:44 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed - posted by "jack handey (Jira)" <ji...@apache.org> on 2019/09/04 09:01:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8738) Cleaning thread blocked when more than one ALTER_REPLICA_LOG_DIRS requests sent - posted by "dingsainan (Jira)" <ji...@apache.org> on 2019/09/04 10:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8738) Cleaning thread blocked when more than one ALTER_REPLICA_LOG_DIRS requests sent - posted by "dingsainan (Jira)" <ji...@apache.org> on 2019/09/04 10:31:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8738) Cleaning thread blocked when more than one ALTER_REPLICA_LOG_DIRS requests sent - posted by "dingsainan (Jira)" <ji...@apache.org> on 2019/09/04 10:35:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6745) kafka consumer rebalancing takes long time (from 3 secs to 5 minutes) - posted by "Xin (Jira)" <ji...@apache.org> on 2019/09/04 10:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8865) KIP-504: New Java Authorizer API - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/04 11:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8865) KIP-504: New Java Authorizer API - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/04 11:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8847) Deprecate and remove usage of supporting classes in kafka.security.auth - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/04 11:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8848) Update system test to use new authorizer - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/04 11:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8760) KIP-504: Add new Java Authorizer API - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/04 11:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8760) KIP-504: Add new Java Authorizer API - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/04 11:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8866) Make Authorizer create/delete exceptions Optional - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/04 11:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8866) Make Authorizer create/delete exceptions Optional - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/04 12:27:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8676) Avoid Stopping Unnecessary Connectors and Tasks - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/04 14:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8867) Kafka Connect JDBC fails to create PostgreSQL table with default boolean value - posted by "Tudor-Alexandru Voicu (Jira)" <ji...@apache.org> on 2019/09/04 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8867) Kafka Connect JDBC fails to create PostgreSQL table with default boolean value - posted by "Tudor-Alexandru Voicu (Jira)" <ji...@apache.org> on 2019/09/04 14:53:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-8868) Consider auto-generating Streams binary protocol messages - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/04 15:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8867) Kafka Connect JDBC fails to create PostgreSQL table with default boolean value in schema - posted by "Tudor (Jira)" <ji...@apache.org> on 2019/09/04 16:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8869) Map taskConfigs in KafkaConfigBackingStore grows monotonically despite of task removals - posted by "Konstantine Karantasis (Jira)" <ji...@apache.org> on 2019/09/04 16:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8870) Prevent dirty reads of Streams state store from Interactive queries - posted by "Vinoth Chandar (Jira)" <ji...@apache.org> on 2019/09/04 17:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8871) Allow timestamp manipulation in ValueTransformerWithKey - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/09/04 17:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8870) Prevent dirty reads of Streams state store from Interactive queries - posted by "Vinoth Chandar (Jira)" <ji...@apache.org> on 2019/09/04 17:40:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-8870) Prevent dirty reads of Streams state store from Interactive queries - posted by "Vinoth Chandar (Jira)" <ji...@apache.org> on 2019/09/04 17:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8871) Allow timestamp manipulation in ValueTransformerWithKey - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/09/04 17:47:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8872) Improvements to controller "deleting" state / topic Identifiers - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/09/04 18:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8729) Augment ProduceResponse error messaging for specific culprit records - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/04 19:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/04 22:19:00 UTC, 12 replies.
- [jira] [Resolved] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/04 22:20:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/04 22:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/04 22:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/04 22:29:00 UTC, 2 replies.
- [jira] [Reopened] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/04 22:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/04 22:41:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/04 22:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382) - posted by "Ryanne Dolan (Jira)" <ji...@apache.org> on 2019/09/04 22:52:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-8568) MirrorMaker 2.0 resource leak - posted by "Ryanne Dolan (Jira)" <ji...@apache.org> on 2019/09/04 23:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8568) MirrorMaker 2.0 resource leak - posted by "Ryanne Dolan (Jira)" <ji...@apache.org> on 2019/09/04 23:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8873) Implement timeout for Alter/List PartitionReassignment APIs - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/05 00:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8874) KIP-517: Add consumer metric indicating time between poll calls - posted by "Kevin Lu (Jira)" <ji...@apache.org> on 2019/09/05 01:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8874) KIP-517: Add consumer metric indicating time between poll calls - posted by "Kevin Lu (Jira)" <ji...@apache.org> on 2019/09/05 01:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8875) CreateTopic API should check topic existence before replication factor - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/05 02:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8876) KafkaBasedLog does not throw exception when some partitions of the topic is offline - posted by "Boquan Tang (Jira)" <ji...@apache.org> on 2019/09/05 03:07:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-8876) KafkaBasedLog does not throw exception when some partitions of the topic is offline - posted by "Boquan Tang (Jira)" <ji...@apache.org> on 2019/09/05 03:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8875) CreateTopic API should check topic existence before replication factor - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/05 03:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8875) CreateTopic API should check topic existence before replication factor - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/05 06:18:03 UTC, 1 replies.
- [jira] [Created] (KAFKA-8877) Race condition on partition counter - posted by "Oleg Kuznetsov (Jira)" <ji...@apache.org> on 2019/09/05 08:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8877) Race condition on partition counter - posted by "Oleg Kuznetsov (Jira)" <ji...@apache.org> on 2019/09/05 08:15:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8857) Config describe should not return isReadOnly=false based on synonyms - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/05 08:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8866) Make Authorizer create/delete exceptions Optional - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/05 08:26:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8876) KafkaBasedLog does not throw exception when some partitions of the topic is offline - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/05 09:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8876) KafkaBasedLog does not throw exception when some partitions of the topic is offline - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/05 09:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8877) Race condition on partition counter - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/05 11:49:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/05 12:23:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-8877) Race condition on partition counter - posted by "Oleg Kuznetsov (Jira)" <ji...@apache.org> on 2019/09/05 12:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8724) log cleaner thread dies when attempting to clean a __consumer_offsets partition after upgrade from 2.0->2.3 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/05 16:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8724) log cleaner thread dies when attempting to clean a __consumer_offsets partition after upgrade from 2.0->2.3 - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/05 16:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 16:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 16:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8800) Flaky Test SaslScramSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 16:52:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-8853) Create sustained connections test for Trogdor - posted by "Scott Hendricks (Jira)" <ji...@apache.org> on 2019/09/05 19:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8879) GlobalStateUpdateTask uses wrong javaType to deserialize value - posted by "Vlad Olevsky (Jira)" <ji...@apache.org> on 2019/09/05 19:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8879) GlobalStateUpdateTask uses wrong javaType to deserialize value - posted by "Vlad Olevsky (Jira)" <ji...@apache.org> on 2019/09/05 19:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/05 20:26:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/05 20:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8879) GlobalStateUpdateTask uses wrong javaType to deserialize value - posted by "Vlad Olevsky (Jira)" <ji...@apache.org> on 2019/09/05 22:18:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/05 22:43:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 22:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 22:57:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-6460) Add mocks for state stores used in Streams unit testing - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 23:01:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 23:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 23:14:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/05 23:17:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 23:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/05 23:33:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/05 23:49:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1 - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/06 00:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8813) Race condition when creating topics and changing their configuration - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/06 00:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8818) CreatePartitions Request protocol documentation - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/06 03:47:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/06 04:13:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8822) Remove CompletedFetch type from Fetcher - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/06 06:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8590) Replace TxnOffsetCommitRequest request/response with automated protocol - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/06 06:08:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8590) Replace TxnOffsetCommitRequest request/response with automated protocol - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/06 06:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8881) Measure thread running time precisely - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/06 07:29:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-8881) Measure thread running time precisely - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/06 07:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8882) It's not possible to restart Kafka Streams using StateListener - posted by "Jakub (Jira)" <ji...@apache.org> on 2019/09/06 08:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8660) Make ValueToKey SMT work only on a whitelist of topics - posted by "Marc Löhe (Jira)" <ji...@apache.org> on 2019/09/06 11:11:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown - posted by "Valentin Florea (Jira)" <ji...@apache.org> on 2019/09/06 11:14:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown - posted by "Valentin Florea (Jira)" <ji...@apache.org> on 2019/09/06 11:14:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6745) kafka consumer rebalancing takes long time (from 3 secs to 5 minutes) - posted by "Xin (Jira)" <ji...@apache.org> on 2019/09/06 11:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8883) Kafka Consumer continuously displaying info message Seeking to offset 0 for partition - posted by "Veerabhadra Rao Mallavarapu (Jira)" <ji...@apache.org> on 2019/09/06 13:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8883) Kafka Consumer continuously echoing INFO messages Seeking to offset 0 for partition - posted by "Veerabhadra Rao Mallavarapu (Jira)" <ji...@apache.org> on 2019/09/06 13:30:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes - posted by "Antony Stubbs (Jira)" <ji...@apache.org> on 2019/09/06 13:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes - posted by "Antony Stubbs (Jira)" <ji...@apache.org> on 2019/09/06 13:54:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/06 13:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8660) Make ValueToKey SMT work only on a whitelist of topics - posted by "Marc Löhe (Jira)" <ji...@apache.org> on 2019/09/06 13:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8884) Improve streams errors on class cast exception in ProcessorsNodes - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/06 16:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7500) MirrorMaker 2.0 (KIP-382) - posted by "Ryanne Dolan (Jira)" <ji...@apache.org> on 2019/09/06 18:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8885) The Kafka Protocol should Support Optional Tagged Fields - posted by "Colin P. McCabe (Jira)" <ji...@apache.org> on 2019/09/06 22:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/07 05:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8817) Flaky Test KafkaProducerTest.testCloseIsForcedOnPendingAddOffsetRequest - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/07 05:25:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-6304) The controller should allow updating the partition reassignment for the partitions being reassigned - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/07 23:19:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6304) The controller should allow updating the partition reassignment for the partitions being reassigned - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/07 23:19:00 UTC, 1 replies.
- [jira] [Closed] (KAFKA-8218) IllegalStateException while accessing context in Transformer - posted by "Bartłomiej Kępa (Jira)" <ji...@apache.org> on 2019/09/08 11:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8886) Make Authorizer create/delete methods asynchronous - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/08 17:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8887) Use purgatory for CreateAcls and DeleteAcls if implementation is async - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/08 17:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed - posted by "prehistoricpenguin (Jira)" <ji...@apache.org> on 2019/09/09 02:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2019/09/09 12:38:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/09/09 13:45:00 UTC, 7 replies.
- [jira] [Assigned] (KAFKA-8784) Remove default implementation of RocksDBConfigSetter#close - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2019/09/09 14:06:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7878) Connect Task already exists in this worker when failed to create consumer - posted by "Goltseva Taisiia (Jira)" <ji...@apache.org> on 2019/09/09 14:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8826) Improve logging for SSL ciphers and principals - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/09 14:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8853) Create sustained connections test for Trogdor - posted by "Gwen Shapira (Jira)" <ji...@apache.org> on 2019/09/09 15:39:14 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8723) flaky test LeaderElectionCommandTest#testAllTopicPartition - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/09 15:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8723) flaky test LeaderElectionCommandTest#testAllTopicPartition - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/09 15:45:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8340) ServiceLoader fails when used from isolated plugin path directory - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/09 16:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8888) Possible to get null IQ value if partition migrates - posted by "Chris Pettitt (Jira)" <ji...@apache.org> on 2019/09/09 16:30:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2019/09/09 16:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8871) Allow timestamp manipulation in ValueTransformerWithKey - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/09 17:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8886) Make Authorizer create/delete methods asynchronous - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/09 17:45:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8888) Possible to get null IQ value if reading from wrong instance - posted by "Chris Pettitt (Jira)" <ji...@apache.org> on 2019/09/09 19:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8888) Possible to get null IQ value if reading from wrong instance - posted by "Chris Pettitt (Jira)" <ji...@apache.org> on 2019/09/09 19:03:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-8870) Prevent dirty reads of Streams state store from Interactive queries - posted by "Vinoth Chandar (Jira)" <ji...@apache.org> on 2019/09/09 20:06:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8222) Admin client changes to add ability to batch remove static members - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/09 20:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8889) Root cause is lost for FetchSessionHandler.handleError - posted by "Qinghui Xu (Jira)" <ji...@apache.org> on 2019/09/09 21:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8340) ServiceLoader fails when used from isolated plugin path directory - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/09/09 21:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8889) Root cause is lost for FetchSessionHandler.handleError - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/09 21:56:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8890) KIP-519: Make SSL context/engine configuration extensible - posted by "Maulin Vasavada (Jira)" <ji...@apache.org> on 2019/09/09 22:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8816) RecordCollector offsets updated indirectly by StreamTask - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/09 23:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/09 23:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8889) Root cause is lost for FetchSessionHandler.handleError - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/10 05:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8889) Root cause is lost for FetchSessionHandler.handleError - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/10 05:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8891) invalid assignment protocol - posted by "SAIRAM KODURU (Jira)" <ji...@apache.org> on 2019/09/10 09:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8891) invalid assignment protocol - posted by "SAIRAM KODURU (Jira)" <ji...@apache.org> on 2019/09/10 09:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8891) invalid assignment protocoljava.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null - posted by "SAIRAM KODURU (Jira)" <ji...@apache.org> on 2019/09/10 09:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8891) invalid assignment protocol java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null - posted by "SAIRAM KODURU (Jira)" <ji...@apache.org> on 2019/09/10 09:13:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-8892) Display the sorted configs in Kafka Configs Help Command. - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2019/09/10 12:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8892) Display the sorted configs in Kafka Configs Help Command. - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2019/09/10 12:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8892) Display the sorted configs in Kafka Configs Help Command. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/10 12:44:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8747) Flaky Test ControllerEventManagerTest#testEventQueueTime - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/10 17:45:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL - posted by "Aishwarya Pradeep Kumar (Jira)" <ji...@apache.org> on 2019/09/10 18:01:00 UTC, 7 replies.
- [jira] [Updated] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/09/10 20:40:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/09/10 20:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8893) Flaky ResetIntegrationTest. testReprocessingFromScratchAfterResetWithIntermediateUserTopic - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/10 22:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8894) Flaky org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromFileAfterResetWithoutIntermediateUserTopic - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/10 22:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8895) Flaky org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromDateTimeAfterResetWithoutIntermediateUserTopic - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/10 22:38:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8747) Flaky Test ControllerEventManagerTest#testEventQueueTime - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/10 22:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/10 22:42:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8896) NoSuchElementException after coordinator move - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/10 23:22:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8222) Admin client changes to add ability to batch remove static members - posted by "Boyang Chen (Jira)" <ji...@apache.org> on 2019/09/11 00:12:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7018) persist memberId for consumer restart - posted by "Boyang Chen (Jira)" <ji...@apache.org> on 2019/09/11 00:12:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8747) Flaky Test ControllerEventManagerTest#testEventQueueTime - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/11 00:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8817) Flaky Test KafkaProducerTest.testCloseIsForcedOnPendingAddOffsetRequest - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/11 02:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/11 02:33:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-8552) Use SASL authentication in ConfigCommand for connection to zookeeper - posted by "Liu (Jira)" <ji...@apache.org> on 2019/09/11 04:20:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8552) Use SASL authentication in ConfigCommand for connection to zookeeper - posted by "Liu (Jira)" <ji...@apache.org> on 2019/09/11 04:35:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-8552) Use SASL authentication in ConfigCommand for connection to zookeeper - posted by "Liu (Jira)" <ji...@apache.org> on 2019/09/11 04:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8345) Create an Administrative API for Replica Reassignment - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/11 05:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8855) Collect and Expose Client's Name and Version in the Brokers - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/09/11 07:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8897) Increase Version of RocksDB - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/11 08:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8898) if there is no message for poll, kafka consumer apply memory - posted by "linking12 (Jira)" <ji...@apache.org> on 2019/09/11 09:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8898) if there is no message for poll, kafka consumer also apply memory - posted by "linking12 (Jira)" <ji...@apache.org> on 2019/09/11 09:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8883) Kafka Consumer continuously echoing INFO messages Seeking to offset 0 for partition - posted by "Veerabhadra Rao Mallavarapu (Jira)" <ji...@apache.org> on 2019/09/11 13:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8883) Kafka Consumer continuously echoing INFO messages Seeking to offset 0 for partition - posted by "Veerabhadra Rao Mallavarapu (Jira)" <ji...@apache.org> on 2019/09/11 13:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8229) Connect Sink Task updates nextCommit when commitRequest is true - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/11 14:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8570) Downconversion could fail when log contains out of order message formats - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/11 14:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4893) async topic deletion conflicts with max topic length - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/11 14:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7941) Connect KafkaBasedLog work thread terminates when getting offsets fails because broker is unavailable - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/11 14:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8882) It's not possible to restart Kafka Streams using StateListener - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/11 16:38:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8898) if there is no message for poll, kafka consumer also apply memory - posted by "Rachana Prajapati (Jira)" <ji...@apache.org> on 2019/09/11 17:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8886) Make Authorizer create/delete methods asynchronous - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/11 17:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382) - posted by "Qihong Chen (Jira)" <ji...@apache.org> on 2019/09/11 17:57:00 UTC, 10 replies.
- [jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382) - posted by "Qihong Chen (Jira)" <ji...@apache.org> on 2019/09/11 18:14:00 UTC, 11 replies.
- [jira] [Comment Edited] (KAFKA-7658) Add KStream#toTable to the Streams DSL - posted by "Aishwarya Pradeep Kumar (Jira)" <ji...@apache.org> on 2019/09/11 18:19:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/11 19:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8859) Refactor Cache-level Streams Metrics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/11 20:11:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-8869) Map taskConfigs in KafkaConfigBackingStore grows monotonically despite of task removals - posted by "Konstantine Karantasis (Jira)" <ji...@apache.org> on 2019/09/11 20:36:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8875) CreateTopic API should check topic existence before replication factor - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/11 21:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8899) Optimize Partition.maybeIncrementLeaderHW - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/09/11 21:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8899) Optimize Partition.maybeIncrementLeaderHW - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/11 21:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8875) CreateTopic API should check topic existence before replication factor - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/11 21:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8885) The Kafka Protocol should Support Optional Tagged Fields - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/11 21:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8900) Stalled partitions - posted by "Luke Stephenson (Jira)" <ji...@apache.org> on 2019/09/12 04:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8900) Stalled partition for a consumer group - posted by "Luke Stephenson (Jira)" <ji...@apache.org> on 2019/09/12 04:24:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups - posted by "Patrik Kleindl (Jira)" <ji...@apache.org> on 2019/09/12 09:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups - posted by "Patrik Kleindl (Jira)" <ji...@apache.org> on 2019/09/12 09:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8682) Add meter for group rebalance rate - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/09/12 09:51:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8901) Extend consumer group command to use the new Admin API to delete consumer offsets - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/09/12 11:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8661) Flaky Test RebalanceSourceConnectorsIntegrationTest#testStartTwoConnectors - posted by "David Arthur (Jira)" <ji...@apache.org> on 2019/09/12 12:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector - posted by "David Arthur (Jira)" <ji...@apache.org> on 2019/09/12 12:59:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-8800) Flaky Test SaslScramSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "David Arthur (Jira)" <ji...@apache.org> on 2019/09/12 13:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6895) Schema Inferencing for JsonConverter - posted by "Oliver Weiler (Jira)" <ji...@apache.org> on 2019/09/12 13:53:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/09/12 14:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/09/12 14:40:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-8047) remove KafkaMbean when network close - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8047) remove KafkaMbean when network close - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8003) Flaky Test TransactionsTest #testFencingOnTransactionExpiration - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8003) Flaky Test TransactionsTest #testFencingOnTransactionExpiration - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8055) Flaky Test LogCleanerParameterizedIntegrationTest#cleanerTest - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8055) Flaky Test LogCleanerParameterizedIntegrationTest#cleanerTest - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:13:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8119) KafkaConfig listener accessors may fail during dynamic update - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8119) KafkaConfig listener accessors may fail during dynamic update - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/12 15:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8355) Add static membership to Range assignor - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/12 16:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8355) Add static membership to Range assignor - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/12 16:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/12 17:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8902) Benchmark cooperative vs eager rebalancing - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/12 17:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7658) Add KStream#toTable to the Streams DSL - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/12 19:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6098) Delete and Re-create topic operation could result in race condition - posted by "Brian Byrne (Jira)" <ji...@apache.org> on 2019/09/12 19:40:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-6098) Delete and Re-create topic operation could result in race condition - posted by "Brian Byrne (Jira)" <ji...@apache.org> on 2019/09/12 19:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction - posted by "zhangzhisheng (Jira)" <ji...@apache.org> on 2019/09/12 19:56:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8427) Error while cleanup under windows for EmbeddedKafkaCluster - posted by "Evan Nelson (Jira)" <ji...@apache.org> on 2019/09/12 20:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8903) allow the new replica (offset 0) to catch up with current leader using latest offset - posted by "GEORGE LI (Jira)" <ji...@apache.org> on 2019/09/12 21:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8903) allow the new replica (offset 0) to catch up with current leader using latest offset - posted by "GEORGE LI (Jira)" <ji...@apache.org> on 2019/09/12 22:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8903) allow the new replica (offset 0) to catch up with current leader using latest offset - posted by "GEORGE LI (Jira)" <ji...@apache.org> on 2019/09/12 22:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8904) Reduce metadata lookups when producting to a large number of topics - posted by "Brian Byrne (Jira)" <ji...@apache.org> on 2019/09/12 22:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8904) Reduce metadata lookups when producing to a large number of topics - posted by "Brian Byrne (Jira)" <ji...@apache.org> on 2019/09/12 22:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8841) Optimize Partition.maybeIncrementLeaderHW - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/09/12 23:18:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8899) Optimize Partition.maybeIncrementLeaderHW - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/09/12 23:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8841) Optimize Partition.maybeIncrementLeaderHW - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/12 23:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8897) Increase Version of RocksDB - posted by "Rachana Prajapati (Jira)" <ji...@apache.org> on 2019/09/13 07:35:00 UTC, 15 replies.
- [jira] [Created] (KAFKA-8905) Stream DSL: tasks should take serdes from upstream tasks - posted by "Eduard Wirch (Jira)" <ji...@apache.org> on 2019/09/13 07:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8906) Metrics for Key-Value, Window, and Session Stores are Inconsistent - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/13 09:33:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8835) Update documentation for URP changes in KIP-352 - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/09/13 09:49:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8897) Increase Version of RocksDB - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/13 11:39:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins - posted by "Aishwarya Pradeep Kumar (Jira)" <ji...@apache.org> on 2019/09/13 14:30:00 UTC, 5 replies.
- [jira] [Commented] (KAFKA-8905) Stream DSL: tasks should take serdes from upstream tasks - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/13 14:54:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup - posted by "Sri Vishnu (Jira)" <ji...@apache.org> on 2019/09/13 15:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8906) Metrics for Key-Value, Window, and Session Stores are Inconsistent - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/13 16:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-3705) Support non-key joining in KTable - posted by "satyanarayan komandur (Jira)" <ji...@apache.org> on 2019/09/13 17:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins - posted by "Aishwarya Pradeep Kumar (Jira)" <ji...@apache.org> on 2019/09/13 17:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8810) Add mechanism to detect topology mismatch between streams instances - posted by "Vinoth Chandar (Jira)" <ji...@apache.org> on 2019/09/13 19:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8894) Flaky org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromFileAfterResetWithoutIntermediateUserTopic - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/13 19:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8907) Return topic configs in CreateTopics response - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/13 21:01:01 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8897) Increase Version of RocksDB - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/13 21:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/13 22:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/13 22:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/13 22:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8474) Improve configuration layout on website - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/13 22:49:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8474) Improve configuration layout on website - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/13 22:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8730) Add API to delete consumer offsets (KIP-496) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/13 23:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8905) Stream DSL: tasks should take serdes from upstream tasks - posted by "Eduard Wirch (Jira)" <ji...@apache.org> on 2019/09/14 06:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8908) Use ApiVersion API for inter-broker communication - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/14 17:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8908) Use ApiVersion API for inter-broker communication - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/14 18:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8587) EOS producer should understand consumer group assignment semantics - posted by "Noam Berman (Jira)" <ji...@apache.org> on 2019/09/15 12:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8587) EOS producer should understand consumer group assignment semantics - posted by "Noam Berman (Jira)" <ji...@apache.org> on 2019/09/15 12:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/16 05:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8909) Flaky Test ReassignPartitionsClusterTest#shouldPerformMultipleReassignmentOperationsOverVariousTopics - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/16 05:21:00 UTC, 0 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 "Fangbin Sun (Jira)" <ji...@apache.org> on 2019/09/16 06:55:00 UTC, 1 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 "Fangbin Sun (Jira)" <ji...@apache.org> on 2019/09/16 06:55:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.Callback - posted by "Sergey Ushakov (Jira)" <ji...@apache.org> on 2019/09/16 08:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.Callback - posted by "Sergey Ushakov (Jira)" <ji...@apache.org> on 2019/09/16 08:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7981) Add Replica Fetcher and Log Cleaner Count Metrics - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/09/16 09:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7689) Add Commit/List Offsets Operations to AdminClient - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/09/16 10:09:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/16 10:30:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/09/16 11:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/16 12:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8911) Implicit TimeWindowedSerde creates Serde with null inner serializer - posted by "Michał (Jira)" <ji...@apache.org> on 2019/09/16 12:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8911) Implicit TimeWindowedSerde creates Serde with null inner serializer - posted by "Michał (Jira)" <ji...@apache.org> on 2019/09/16 12:43:00 UTC, 6 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 "Ayusman Dikshit (Jira)" <ji...@apache.org> on 2019/09/16 14:28:00 UTC, 0 replies.
- [jira] [Comment Edited] (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 "Ayusman Dikshit (Jira)" <ji...@apache.org> on 2019/09/16 14:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.Callback - posted by "Lee Dongjin (Jira)" <ji...@apache.org> on 2019/09/16 14:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.KafkaProducer.InterceptorCallback#onCompletion - posted by "Lee Dongjin (Jira)" <ji...@apache.org> on 2019/09/16 14:46:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-8910) Incorrect javadoc at org.apache.kafka.clients.producer.KafkaProducer.InterceptorCallback#onCompletion - posted by "Lee Dongjin (Jira)" <ji...@apache.org> on 2019/09/16 14:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8910) Incorrect javadoc at KafkaProducer.InterceptorCallback#onCompletion - posted by "Lee Dongjin (Jira)" <ji...@apache.org> on 2019/09/16 14:49:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-8910) Incorrect javadoc at KafkaProducer.InterceptorCallback#onCompletion - posted by "Lee Dongjin (Jira)" <ji...@apache.org> on 2019/09/16 14:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8910) Incorrect javadoc at KafkaProducer.InterceptorCallback#onCompletion - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/16 14:50:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7061) Enhanced log compaction - posted by "Ning Liu (Jira)" <ji...@apache.org> on 2019/09/16 16:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7061) Enhanced log compaction - posted by "Ning Liu (Jira)" <ji...@apache.org> on 2019/09/16 16:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7061) Enhanced log compaction - posted by "Ning Liu (Jira)" <ji...@apache.org> on 2019/09/16 16:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8584) Allow "bytes" type to generated a ByteBuffer rather than byte arrays - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2019/09/16 16:54:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-8584) Allow "bytes" type to generated a ByteBuffer rather than byte arrays - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2019/09/16 16:54:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8842) Reading/Writing confused in Connect QuickStart Guide - posted by "Alaa Zbair (Jira)" <ji...@apache.org> on 2019/09/16 18:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8842) Reading/Writing confused in Connect QuickStart Guide - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/16 18:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8912) TimeoutException cause is insufficiently articulated for the KafkProducer - posted by "Ramkishan (Jira)" <ji...@apache.org> on 2019/09/16 20:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8912) TimeoutException cause is insufficiently documented for the KafkProducer - posted by "Ramkishan (Jira)" <ji...@apache.org> on 2019/09/16 20:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8912) TimeoutException cause is insufficiently documented for the KafkaProducer - posted by "Ramkishan (Jira)" <ji...@apache.org> on 2019/09/16 20:47:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-8913) Document topic based configs & ISR settings for Streams apps - posted by "Vinoth Chandar (Jira)" <ji...@apache.org> on 2019/09/16 22:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8913) Document topic based configs & ISR settings for Streams apps - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/16 22:20:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-8911) Implicit TimeWindowedSerde creates Serde with null inner serializer - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/16 23:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8609) Add consumer metrics for rebalances (part 9) - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/16 23:41:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8609) Add consumer metrics for rebalances (part 9) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/16 23:43:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7538) Improve locking model used to update ISRs and HW - posted by "lithiumlee-_- (Jira)" <ji...@apache.org> on 2019/09/17 03:08:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7538) Improve locking model used to update ISRs and HW - posted by "lithiumlee-_- (Jira)" <ji...@apache.org> on 2019/09/17 03:11:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8914) Setting GROUP_INSTANCE_ID_CONFIG leads to a protobuf error - posted by "Igamr Palsenberg (Jira)" <ji...@apache.org> on 2019/09/17 06:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8915) 无法修改partition - posted by "lingyi.zhong (Jira)" <ji...@apache.org> on 2019/09/17 08:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8523) InsertField transformation fails when encountering tombstone event - posted by "Frederic Tardif (Jira)" <ji...@apache.org> on 2019/09/17 12:22:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-8577) Flaky Test `DistributedHerderTest.testJoinLeaderCatchUpFails` - posted by "Warren Marivel (Jira)" <ji...@apache.org> on 2019/09/17 14:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8471) Replace control requests/responses with automated protocol - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/17 14:43:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8916) Unreliable kafka-reassign-partitions.sh affecting performance - posted by "VinayKumar (Jira)" <ji...@apache.org> on 2019/09/17 14:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8917) When performing a Left/Right-Join, pick the headers of the same side - posted by "Pascal Büttiker (Jira)" <ji...@apache.org> on 2019/09/17 16:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8917) When performing a Left/Right-Join, pick the headers of the same side - posted by "Pascal Büttiker (Jira)" <ji...@apache.org> on 2019/09/17 16:35:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8839) Improve logging in Kafka Streams around debugging task lifecycle - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/17 16:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8523) InsertField transformation fails when encountering tombstone event - posted by "Gunnar Morling (Jira)" <ji...@apache.org> on 2019/09/17 17:09:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7052) ExtractField SMT throws NPE - needs clearer error message - posted by "Gunnar Morling (Jira)" <ji...@apache.org> on 2019/09/17 17:19:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8914) Setting GROUP_INSTANCE_ID_CONFIG leads to a protobuf error - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/17 17:26:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-8523) InsertField transformation fails when encountering tombstone event - posted by "Frederic Tardif (Jira)" <ji...@apache.org> on 2019/09/17 19:54:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-8609) Add consumer metrics for rebalances (part 9) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/17 20:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8496) Add system test for compatibility and upgrade path (part 6) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/17 20:23:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-8496) Add system test for compatibility and upgrade path (part 6) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/17 20:24:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8902) Benchmark cooperative vs eager rebalancing - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/17 20:50:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-8902) Benchmark cooperative vs eager rebalancing - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/17 20:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8918) Flaky Test org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskCancellation - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/17 21:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8918) Flaky Test org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskCancellation - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/17 21:12:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-8603) Document upgrade path - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/17 21:48:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-5635) KIP-181 Kafka-Connect integrate with kafka ReST Proxy - posted by "Ewen Cheslack-Postava (Jira)" <ji...@apache.org> on 2019/09/17 21:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8575) Investigate cleaning up task suspension (part 8) - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/17 21:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8919) Flaky Test kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithOffsetLookupAndNoGroupAccess - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/17 22:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8595) Support SerDe of Decimals in JSON that are not HEX encoded - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/17 23:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8086) Flaky Test GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTopicAndGroupRead - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/18 01:24:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-8919) Flaky Test kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithOffsetLookupAndNoGroupAccess - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/18 01:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing - posted by "Charles Qian (Jira)" <ji...@apache.org> on 2019/09/18 02:46:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0 - posted by "leibo (Jira)" <ji...@apache.org> on 2019/09/18 03:10:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0 - posted by "leibo (Jira)" <ji...@apache.org> on 2019/09/18 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8915) Unable to modify partition - posted by "Lee Dongjin (Jira)" <ji...@apache.org> on 2019/09/18 04:16:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0 - posted by "leibo (Jira)" <ji...@apache.org> on 2019/09/18 04:25:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-8901) Extend consumer group command to use the new Admin API to delete consumer offsets - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/09/18 07:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8920) Provide a new properties to enable/disable expired-token-cleaner scheduler - posted by "Chatchavit Nitipongpun (Jira)" <ji...@apache.org> on 2019/09/18 09:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8920) Provide a new properties to enable/disable expired-token-cleaner scheduler - posted by "Chatchavit Nitipongpun (Jira)" <ji...@apache.org> on 2019/09/18 09:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8920) Provide a new properties to enable/disable expired-token-cleaner scheduler - posted by "Chatchavit Nitipongpun (Jira)" <ji...@apache.org> on 2019/09/18 09:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8920) Provide a new property to enable/disable expired-token-cleaner scheduler - posted by "Chatchavit Nitipongpun (Jira)" <ji...@apache.org> on 2019/09/18 09:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8920) Provide a new properties to enable/disable expired-token-cleaner scheduler - posted by "Chatchavit Nitipongpun (Jira)" <ji...@apache.org> on 2019/09/18 09:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8920) Provide a new property to enable/disable expired-token-cleaner scheduler - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/18 13:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8492) Modify ConsumerCoordinator Algorithm with incremental protocol (part 2) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8512) Looking into the Future: Assignor Version - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8511) Looking into the Future: Heartbeat Communicated Protocol - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8491) Bump up Consumer Protocol to v2 (part 1) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8493) Add PartitionsLost API in RebalanceListener (part 3) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:51:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8704) Add PartitionAssignor adapter for backwards compatibility - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:51:01 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8494) Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8703) Move PartitionAssignor to public API - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8495) Make Round-robin / RangeAssignor to be "sticky" (part 5) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8767) Optimize StickyAssignor for Cooperative mode - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/18 14:52:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-8522) Tombstones can survive forever - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/18 15:48:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8841) Optimize Partition.maybeIncrementLeaderHW - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/18 16:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/18 16:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8901) Extend consumer group command to use the new Admin API to delete consumer offsets - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/18 16:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null - posted by "James Cheng (Jira)" <ji...@apache.org> on 2019/09/18 16:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/18 17:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8686) Flaky test ExampleConnectIntegrationTest#testSinkConnector - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/18 17:02:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8913) Document topic based configs & ISR settings for Streams apps - posted by "Vinoth Chandar (Jira)" <ji...@apache.org> on 2019/09/18 17:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8921) Avoid excessive info logs in the client side for incremental fetch - posted by "Zhanxiang (Patrick) Huang (Jira)" <ji...@apache.org> on 2019/09/18 17:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8922) Failed to get end offsets for topic partitions of global store - posted by "Raman Gupta (Jira)" <ji...@apache.org> on 2019/09/18 17:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8922) Failed to get end offsets for topic partitions of global store - posted by "Raman Gupta (Jira)" <ji...@apache.org> on 2019/09/18 18:00:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8923) Revisit OnlineReplica state change in reassignments - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2019/09/18 19:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8922) Failed to get end offsets for topic partitions of global store - posted by "Raman Gupta (Jira)" <ji...@apache.org> on 2019/09/18 20:21:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-8587) EOS producer should understand consumer group assignment semantics - posted by "Noam Berman (Jira)" <ji...@apache.org> on 2019/09/18 23:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341) - posted by "redbrick9 (Jira)" <ji...@apache.org> on 2019/09/19 01:20:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341) - posted by "redbrick9 (Jira)" <ji...@apache.org> on 2019/09/19 01:20:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events - posted by "Michał (Jira)" <ji...@apache.org> on 2019/09/19 10:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events - posted by "Michał (Jira)" <ji...@apache.org> on 2019/09/19 10:37:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-8893) Flaky ResetIntegrationTest. testReprocessingFromScratchAfterResetWithIntermediateUserTopic - posted by "Rabi Kumar K C (Jira)" <ji...@apache.org> on 2019/09/19 14:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8925) Flaky Test kafka.api.AuthorizerIntegrationTest.testIdempotentProducerNoIdempotentWriteAclInProduce - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/19 16:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8455) Add NothingSerde to Serdes - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2019/09/19 16:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2019/09/19 16:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6290) Kafka Connect cast transformation should support logical types - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/19 17:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/19 18:20:00 UTC, 11 replies.
- [jira] [Created] (KAFKA-8926) Log Cleaner thread dies when log.cleaner.min.cleanable.ratio is set to 0 - posted by "Jordan Mcmillan (Jira)" <ji...@apache.org> on 2019/09/19 20:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8927) Remove config `partition.grouper` and interface `PartitionGrouper` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/19 23:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8927) Remove config `partition.grouper` and interface `PartitionGrouper` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/19 23:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8927) Remove config `partition.grouper` and interface `PartitionGrouper` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/19 23:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/20 01:07:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-1641) Log cleaner exits if last cleaned offset is lower than earliest offset - posted by "Yogesh YADAV (Jira)" <ji...@apache.org> on 2019/09/20 01:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8915) Unable to modify partition - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/20 02:32:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8915) Unable to modify partition - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/20 02:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8915) Unable to modify partition - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/20 02:35:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to never emit events - posted by "Michał (Jira)" <ji...@apache.org> on 2019/09/20 07:43:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6393) Add tool to view active brokers - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/09/20 09:23:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6393) Add tool to view active brokers - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/09/20 09:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8848) Update system test to use new authorizer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/20 10:43:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8742) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectResults_NO_OPTIMIZATION - posted by "Rabi Kumar K C (Jira)" <ji...@apache.org> on 2019/09/20 13:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/20 15:06:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8928) Logged producer config does not always match actual config values - posted by "Chris Pettitt (Jira)" <ji...@apache.org> on 2019/09/20 16:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8929) MM2 system tests - posted by "Ryanne Dolan (Jira)" <ji...@apache.org> on 2019/09/20 16:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8930) MM2 documentation - posted by "Ryanne Dolan (Jira)" <ji...@apache.org> on 2019/09/20 16:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8928) Logged producer config does not always match actual config values - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/20 16:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8613) Set default grace period to 0 - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/20 17:04:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7785) Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/20 17:05:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7785) Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper to internal package - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/20 17:06:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-8927) Remove config `partition.grouper` and interface `PartitionGrouper` - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/20 18:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8926) Log Cleaner thread dies when log.cleaner.min.cleanable.ratio is set to 0 - posted by "Jordan Mcmillan (Jira)" <ji...@apache.org> on 2019/09/20 18:15:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8892) Display the sorted configs in Kafka Configs Help Command. - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/09/20 18:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h - posted by "Michał (Jira)" <ji...@apache.org> on 2019/09/21 00:47:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/21 01:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/21 01:25:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/21 01:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8327) Connection to Node2 was disconnected - posted by "Mohit Shukla (Jira)" <ji...@apache.org> on 2019/09/21 17:26:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-8327) Connection to Node2 was disconnected - posted by "Mohit Shukla (Jira)" <ji...@apache.org> on 2019/09/21 17:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8931) PR '#6850' fix issue 'KAFKA-8449', but lead to restart all cached tasks, which conflict to the motivation of incremental cooperative rebalancing. - posted by "HeryLong (Jira)" <ji...@apache.org> on 2019/09/22 11:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8931) PR '#6850' fix issue 'KAFKA-8449', but lead to restart all cached tasks, which conflict to the motivation of incremental cooperative rebalancing. - posted by "HeryLong (Jira)" <ji...@apache.org> on 2019/09/22 11:44:00 UTC, 13 replies.
- [jira] [Comment Edited] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction - posted by "fenghong (Jira)" <ji...@apache.org> on 2019/09/23 12:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7888) kafka cluster not recovering - Shrinking ISR from 14,13 to 13 (kafka.cluster.Partition) continously - posted by "Stoyan Stoyanov (Jira)" <ji...@apache.org> on 2019/09/23 12:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8859) Refactor Cache-level Streams Metrics - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/09/23 14:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8859) Refactor Cache-level Streams Metrics - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/09/23 14:15:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8896) NoSuchElementException after coordinator move - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/23 16:08:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8086) Flaky Test GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTopicAndGroupRead - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/23 16:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6958) Allow to define custom processor names with KStreams DSL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/23 17:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8613) Set default grace period to 0 - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/09/23 20:31:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-8931) PR '#6850' fix issue 'KAFKA-8449', but lead to restart all cached tasks, which conflict to the motivation of incremental cooperative rebalancing. - posted by "Konstantine Karantasis (Jira)" <ji...@apache.org> on 2019/09/23 23:28:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver - posted by "Jukka Karvanen (Jira)" <ji...@apache.org> on 2019/09/24 02:35:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/24 02:53:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/24 03:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/24 05:04:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-8848) Update system test to use new authorizer - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/24 09:38:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8932) Add tag for TopicConfigErrorCode in CreateTopics response when KIP-482 is merged - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/24 09:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0 - posted by "Suyash Garg (Jira)" <ji...@apache.org> on 2019/09/24 10:07:00 UTC, 8 replies.
- [jira] [Created] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic - posted by "Remigius (Jira)" <ji...@apache.org> on 2019/09/24 10:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8907) Return topic configs in CreateTopics response - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/24 11:05:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-8934) Introduce Instance-level Metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/24 11:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8934) Introduce Instance-level Metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/24 11:16:00 UTC, 0 replies.
- [jira] [Moved] (KAFKA-8935) Please update zookeeper in the next release - posted by "Enrico Olivelli (Jira)" <ji...@apache.org> on 2019/09/24 11:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8936) Connect metrics have a chance to disappear on rebalance - posted by "Steven Blumenthal (Jira)" <ji...@apache.org> on 2019/09/24 13:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8936) Connect metrics have a chance to disappear on rebalance - posted by "Steven Blumenthal (Jira)" <ji...@apache.org> on 2019/09/24 13:48:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-6958) Allow to define custom processor names with KStreams DSL - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/09/24 14:33:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6958) Allow to define custom processor names with KStreams DSL - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/09/24 14:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8855) Collect and Expose Client's Name and Version in the Brokers - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/24 16:34:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8937) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/24 18:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/24 18:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8938) Connect - Improve Memory Allocations During Struct Validation - posted by "Auston McReynolds (Jira)" <ji...@apache.org> on 2019/09/24 18:11:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/24 18:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/24 18:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8938) Connect - Improve Memory Allocations During Struct Validation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/24 18:17:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-8938) Connect - Improve Memory Allocations During Struct Validation - posted by "Auston McReynolds (Jira)" <ji...@apache.org> on 2019/09/24 18:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/24 18:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-4449) Add Serializer/Deserializer for POJO - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/24 18:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4449) Add Serializer/Deserializer for POJO - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/24 18:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8940) Flaky SmokeTestDriverIntegrationTest.shouldWorkWithRebalance - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/24 18:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/24 20:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8580) Compute RocksDB Metrics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/24 20:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8100) kafka consumer not refresh metadata for dynamic topic deletion - posted by "Shengnan YU (Jira)" <ji...@apache.org> on 2019/09/25 03:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic - posted by "Remigius (Jira)" <ji...@apache.org> on 2019/09/25 04:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8398) NPE when unmapping files after moving log directories using AlterReplicaLogDirs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/25 05:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8580) Compute RocksDB Metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/25 06:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8941) Add RocksDB Metrics that Could not be Added due to RocksDB Version - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/25 06:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8942) Document RocksDB metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/25 06:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers - posted by "Pradeep Bansal (Jira)" <ji...@apache.org> on 2019/09/25 06:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8942) Document RocksDB metrics - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/25 06:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8941) Add RocksDB Metrics that Could not be Added due to RocksDB Version - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/25 06:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8943) Move SecurityProviderCreator to a public package - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/09/25 13:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8943) Move SecurityProviderCreator to a public package - posted by "Rabi Kumar K C (Jira)" <ji...@apache.org> on 2019/09/25 14:20:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/25 15:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7273) Converters should have access to headers. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/25 16:24:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7689) Add Commit/List Offsets Operations to AdminClient - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2019/09/25 16:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7273) Converters should have access to headers. - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/09/25 17:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8804) Internal Connect REST endpoints are insecure - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/09/25 17:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4113) Allow KTable bootstrap - posted by "Robert L Brooks Jr (Jira)" <ji...@apache.org> on 2019/09/25 17:38:00 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-8943) Move SecurityProviderCreator to a public package - posted by "Sai Sandeep (Jira)" <ji...@apache.org> on 2019/09/25 18:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8896) NoSuchElementException after coordinator move - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/09/25 19:54:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps - posted by "Alessandro Tagliapietra (Jira)" <ji...@apache.org> on 2019/09/25 20:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8944) Compiler Warning - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/25 22:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState - posted by "Sanjana Kaundinya (Jira)" <ji...@apache.org> on 2019/09/25 23:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/09/25 23:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/25 23:57:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8944) Compiler Warning - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/09/26 02:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8944) Compiler Warning - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/26 02:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8874) KIP-517: Add consumer metric indicating time between poll calls - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/26 05:47:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h - posted by "Michał (Jira)" <ji...@apache.org> on 2019/09/26 09:23:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8946) Single byte header breaks parsing - posted by "Henning Treu (Jira)" <ji...@apache.org> on 2019/09/26 09:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8946) Single byte header issues WARn logging - posted by "Henning Treu (Jira)" <ji...@apache.org> on 2019/09/26 09:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8946) Single byte header issues WARN logging - posted by "Henning Treu (Jira)" <ji...@apache.org> on 2019/09/26 09:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8666) Improve Documentation on usage of Materialized config object - posted by "bibin sebastian (Jira)" <ji...@apache.org> on 2019/09/26 15:25:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8807) Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/26 16:58:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/09/26 17:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8504) Update Docs to explain how to use suppress() in more details - posted by "bibin sebastian (Jira)" <ji...@apache.org> on 2019/09/26 18:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8948) StreamsEosTest#test_rebalance_complex is broken for multiple runs - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/26 18:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8948) StreamsEosTest#test_rebalance_complex is broken for multiple runs - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/26 18:48:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/09/26 20:55:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8949) MockConsumer.assign and ConsumerRebalanceListener - posted by "David Hay (Jira)" <ji...@apache.org> on 2019/09/26 22:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8949) MockConsumer.assign and ConsumerRebalanceListener - posted by "David Hay (Jira)" <ji...@apache.org> on 2019/09/26 22:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8950) KafkaConsumer stops fetching - posted by "Will James (Jira)" <ji...@apache.org> on 2019/09/26 22:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8950) KafkaConsumer stops fetching - posted by "Will James (Jira)" <ji...@apache.org> on 2019/09/26 22:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8951) Avoid unnecessary rebalances and downtime for "safe" partitions - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/26 23:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/09/27 01:44:00 UTC, 1 replies.
- Vulnerabilities found for jackson-databind-2.9.9.jar and guava-20.0.jar in latest Apache-kafka latest version 2.3.0 - posted by namrata kokate <n....@gmail.com> on 2019/09/27 06:11:54 UTC, 0 replies.
- [jira] [Created] (KAFKA-8952) Vulnerabilities found for jackson-databind-2.9.9.jar and guava-20.0.jar in latest Apache-kafka latest version 2.3.0 - posted by "Namrata Kokate (Jira)" <ji...@apache.org> on 2019/09/27 06:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7772) Dynamically adjust log level in Connect workers - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/27 07:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/27 07:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor - posted by "Rabi Kumar K C (Jira)" <ji...@apache.org> on 2019/09/27 07:20:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-8954) Topic existence check is wrongly implemented in the DeleteOffset API - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/09/27 08:00:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8954) Topic existence check is wrongly implemented in the DeleteOffset API - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/09/27 08:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8887) Use purgatory for CreateAcls and DeleteAcls if implementation is async - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/27 12:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8954) Topic existence check is wrongly implemented in the DeleteOffset API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/27 14:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8950) KafkaConsumer stops fetching - posted by "Will James (Jira)" <ji...@apache.org> on 2019/09/27 15:25:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8955) Add an AbstractResponse#errorCounts method that takes a stream or iterable - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2019/09/27 17:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8956) Refactor DelayedCreatePartitions#updateWaiting to avoid modifying collection in foreach - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2019/09/27 18:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-6883) KafkaShortnamer should allow to convert Kerberos principal name to upper case user name - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/09/27 18:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8957) Improve docs about `min.isr.` and `acks=all` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/27 18:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8957) Improve docs about `min.isr` and `acks=all` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/27 18:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7921) Instable KafkaStreamsTest - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/27 19:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7921) Instable KafkaStreamsTest - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/27 19:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6215) KafkaStreamsTest fails in trunk - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/27 19:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/27 19:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/27 19:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/27 19:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8427) Error while cleanup under windows for EmbeddedKafkaCluster - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/09/27 19:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8934) Introduce Instance-level Metrics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/27 19:13:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7263) Container exception java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null - posted by "Larry Li (Jira)" <ji...@apache.org> on 2019/09/27 20:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8958) Fix Kafka Streams JavaDocs with regard to used Serdes - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/28 01:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8059) Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota - posted by "xujianhai (Jira)" <ji...@apache.org> on 2019/09/28 03:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8700) Flaky Test QueryableStateIntegrationTest#queryOnRebalance - posted by "xujianhai (Jira)" <ji...@apache.org> on 2019/09/28 03:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0 - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/09/28 06:08:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1 - posted by "Vasiliy (Jira)" <ji...@apache.org> on 2019/09/28 06:32:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1 - posted by "Vasiliy (Jira)" <ji...@apache.org> on 2019/09/28 06:33:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop - posted by "Sergiu Pantiru (Jira)" <ji...@apache.org> on 2019/09/28 11:00:03 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-8807) Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/09/28 16:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8952) Vulnerabilities found for jackson-databind-2.9.9.jar and guava-20.0.jar in latest Apache-kafka latest version 2.3.0 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/28 17:52:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/09/28 17:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8471) Replace control requests/responses with automated protocol - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 03:05:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8956) Refactor DelayedCreatePartitions#updateWaiting to avoid modifying collection in foreach - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 03:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8952) Vulnerabilities found for jackson-databind-2.9.9.jar and guava-20.0.jar in latest Apache-kafka latest version 2.3.0 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 04:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer - posted by "Dulvin Witharane (Jira)" <ji...@apache.org> on 2019/09/29 09:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer - posted by "Dulvin Witharane (Jira)" <ji...@apache.org> on 2019/09/29 09:10:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8952) Vulnerabilities found for jackson-databind-2.9.9.jar and guava-20.0.jar in latest Apache-kafka latest version 2.3.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/29 15:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8952) Vulnerabilities found for jackson-databind-2.9.9 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 16:03:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8959) Update Guava to 24 (or newer) or remove dependency - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 17:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8959) Update Guava to 24 (or newer) or remove dependency - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 17:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8952) Vulnerabilities found for jackson-databind-2.9.9 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 17:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8952) Vulnerabilities found for jackson-databind-2.9.9 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 17:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8959) Update Guava to 24 (or newer) or remove dependency - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/09/29 17:29:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-8960) Move Task {{determineCommitId}} in {{gradle.build}} to Project Level - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/29 18:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8960) Move Task determineCommitId in gradle.build to Project Level - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/29 18:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor - posted by "Rabi Kumar K C (Jira)" <ji...@apache.org> on 2019/09/30 07:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8961) Unable to create secure JDBC connection through Kafka Connect - posted by "Monika Bainsala (Jira)" <ji...@apache.org> on 2019/09/30 07:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change - posted by "Di Campo (Jira)" <ji...@apache.org> on 2019/09/30 09:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8960) Move Task determineCommitId in gradle.build to Project Level - posted by "Rabi Kumar K C (Jira)" <ji...@apache.org> on 2019/09/30 15:03:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-8960) Move Task determineCommitId in gradle.build to Project Level - posted by "Rabi Kumar K C (Jira)" <ji...@apache.org> on 2019/09/30 16:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8962) KafkaAdminClient#describeTopics always goes through the controller - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/09/30 17:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8962) KafkaAdminClient#describeTopics always goes through the controller - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/30 17:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-8963) Benchmark and optimize incremental fetch session handler - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/09/30 18:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8963) Benchmark and optimize incremental fetch session handler - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/09/30 18:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8785) Flakey test LeaderElectionCommandTest#testPathToJsonFile - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/09/30 19:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8911) Implicit TimeWindowedSerde creates Serde with null inner serializer - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/09/30 22:55:00 UTC, 0 replies.