jira@kafka.apache.org, 2019-12

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

- [jira] [Commented] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/01 03:38:00 UTC, 5 replies.
- [jira] [Resolved] (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 "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/01 04:17:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9049) TopicCommandWithAdminClientTest should use mocks - posted by "Dhiraj Dwarapudi (Jira)" <ji...@apache.org> on 2019/12/01 06:21:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9254) Topic level configuration failed - posted by "fenghong (Jira)" <ji...@apache.org> on 2019/12/01 06:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9254) Topic level configuration failed - posted by "fenghong (Jira)" <ji...@apache.org> on 2019/12/01 06:26:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9254) Topic level configuration failed - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/01 11:56:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-9236) Confused log after using CLI scripts to produce messages - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/01 12:37:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9071) transactional.id.expiration.ms config value should be implemented as a Long - posted by "Mario Georgiev (Jira)" <ji...@apache.org> on 2019/12/01 12:56:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/01 14:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9071) transactional.id.expiration.ms config value should be implemented as a Long - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/01 20:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-1714) more better bootstrapping of the gradle-wrapper.jar - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/01 21:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7658) Add KStream#toTable to the Streams DSL - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/01 21:09:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/01 21:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9255) MessageSet v1 protocol wrong specification - posted by "Fábio Silva (Jira)" <ji...@apache.org> on 2019/12/01 21:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9255) MessageSet v1 protocol wrong specification - posted by "Fábio Silva (Jira)" <ji...@apache.org> on 2019/12/01 21:58:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9255) MessageSet v1 protocol wrong specification - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/01 22:10:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-9156) LazyTimeIndex & LazyOffsetIndex may cause niobufferoverflow in concurrent state - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/02 04:42:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-9213) BufferOverflowException on rolling new segment after upgrading Kafka from 1.1.0 to 2.3.1 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/02 04:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9213) BufferOverflowException on rolling new segment after upgrading Kafka from 1.1.0 to 2.3.1 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/02 04:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/02 06:38:00 UTC, 9 replies.
- [jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/12/02 11:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9256) mirrorMaker + kafka = java.lang.NoSuchMethodError: org.apache.kafka.common.requests.MetadataResponse.prepareResponse - posted by "Rudik (Jira)" <ji...@apache.org> on 2019/12/02 11:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9256) mirrorMaker + kafka = java.lang.NoSuchMethodError: org.apache.kafka.common.requests.MetadataResponse.prepareResponse - posted by "Rudik (Jira)" <ji...@apache.org> on 2019/12/02 11:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows - posted by "Wahid Gazzah (Jira)" <ji...@apache.org> on 2019/12/02 12:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9257) Allow listeners to bind on same port but different interfaces - posted by "Gérald Quintana (Jira)" <ji...@apache.org> on 2019/12/02 12:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9187) kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/12/02 12:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9254) Topic level configuration failed - posted by "fenghong (Jira)" <ji...@apache.org> on 2019/12/02 12:39:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-9255) MessageSet v1 protocol wrong specification - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2019/12/02 14:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9255) MessageSet v1 protocol wrong specification - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2019/12/02 14:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9164) Don't evict active topics' metadata from the producer's cache - posted by "Brian Byrne (Jira)" <ji...@apache.org> on 2019/12/02 17:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9156) LazyTimeIndex & LazyOffsetIndex may cause niobufferoverflow in concurrent state - posted by "Alex Mironov (Jira)" <ji...@apache.org> on 2019/12/02 18:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5034) Connect workers don't discover new Connector Plugins without Restart - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/02 18:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9156) LazyTimeIndex & LazyOffsetIndex may cause niobufferoverflow in concurrent state - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/02 20:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9071) transactional.id.expiration.ms config value should be implemented as a Long - posted by "Mario Georgiev (Jira)" <ji...@apache.org> on 2019/12/02 20:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9258) Connect ConnectorStatusMetricsGroup sometimes NPE - posted by "Cyrus Vafadari (Jira)" <ji...@apache.org> on 2019/12/02 21:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9258) Connect ConnectorStatusMetricsGroup sometimes NPE - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/02 21:29:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/02 23:24:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9260) Improve Serde "push down" and "wrapping" - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/02 23:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9225) kafka fail to run on linux-aarch64 - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/02 23:42:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/03 00:00:00 UTC, 17 replies.
- [jira] [Commented] (KAFKA-9210) kafka stream loss data - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/03 00:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9261) NPE when updating client metadata - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/03 00:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/03 02:36:00 UTC, 9 replies.
- [jira] [Assigned] (KAFKA-9258) Connect ConnectorStatusMetricsGroup sometimes NPE - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/12/03 02:41:01 UTC, 4 replies.
- [jira] [Updated] (KAFKA-9258) Connect ConnectorStatusMetricsGroup sometimes NPE - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/12/03 02:43:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/12/03 08:37:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/12/03 08:37:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-9252) Kafka Connect fails to create connector if single-broker Kafka cluster is configured for offsets.topic.replication.factor=3 - posted by "Robin Moffatt (Jira)" <ji...@apache.org> on 2019/12/03 09:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1 - posted by "David Watzke (Jira)" <ji...@apache.org> on 2019/12/03 09:58:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1 - posted by "David Watzke (Jira)" <ji...@apache.org> on 2019/12/03 10:02:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations - posted by "oulabas (Jira)" <ji...@apache.org> on 2019/12/03 11:52:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9262) kafka broker fails to response fetching request from consumer when quota limit is violated - posted by "Junqi Zhang (Jira)" <ji...@apache.org> on 2019/12/03 12:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/03 14:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/03 14:07:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-8937) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/03 16:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/03 16:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/03 16:15:00 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/03 16:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9264) Reocurrence: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/03 16:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9264) Reocurrence: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/03 16:21:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/03 16:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8937) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/03 16:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9154) ProducerId generation should be managed by the Controller - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2019/12/03 18:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9261) NPE when updating client metadata - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/03 19:42:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-9184) Redundant task creation and periodic rebalances after zombie worker rejoins the group - posted by "Konstantine Karantasis (Jira)" <ji...@apache.org> on 2019/12/03 21:36:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-9184) Redundant task creation and periodic rebalances after zombie worker rejoins the group - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/03 21:37:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-9265) kafka.log.Log instances are leaking on log delete - posted by "Vikas Singh (Jira)" <ji...@apache.org> on 2019/12/03 21:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9265) kafka.log.Log instances are leaking on log delete - posted by "Vikas Singh (Jira)" <ji...@apache.org> on 2019/12/03 21:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7016) Reconsider the "avoid the expensive and useless stack trace for api exceptions" practice - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/03 21:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9265) kafka.log.Log instances are leaking on log delete - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/03 22:05:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8948) Flaky Test StreamsEosTest#test_rebalance_complex is broken for multiple runs - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/03 22:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/04 00:51:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/04 00:56:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/04 01:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/04 02:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/04 03:20:00 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-9258) Connect ConnectorStatusMetricsGroup sometimes NPE - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/04 03:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9261) NPE when updating client metadata - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/04 04:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is invalid. (kafka.log.LogCleanerManager$) - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2019/12/04 05:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is invalid. (kafka.log.LogCleanerManager$) - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/04 05:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9265) kafka.log.Log instances are leaking on log delete - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/04 14:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9266) KafkaConsumer manual assignment does not reset group assignment - posted by "G G (Jira)" <ji...@apache.org> on 2019/12/04 14:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9233) Kafka consumer throws undocumented IllegalStateException - posted by "Andrew Olson (Jira)" <ji...@apache.org> on 2019/12/04 14:24:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-9195) Use Randomized State Directory Names in Streams System Tests - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2019/12/04 14:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64 - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/04 15:39:00 UTC, 6 replies.
- [jira] [Created] (KAFKA-9267) ZkSecurityMigrator should not create /controller node - posted by "NanerLee (Jira)" <ji...@apache.org> on 2019/12/04 15:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9267) ZkSecurityMigrator should not create /controller node - posted by "NanerLee (Jira)" <ji...@apache.org> on 2019/12/04 16:02:00 UTC, 5 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 "jfc (Jira)" <ji...@apache.org> on 2019/12/04 16:12:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6793) Unnecessary warning log message - posted by "Alex Mironov (Jira)" <ji...@apache.org> on 2019/12/04 16:19:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9267) ZkSecurityMigrator should not create /controller node - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/04 16:20:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/04 16:38:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/04 16:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9190) Server leaves connections with expired authentication sessions open - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/04 16:40:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/04 16:53:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/04 17:29:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-9190) Server leaves connections with expired authentication sessions open - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/04 17:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is invalid. (kafka.log.LogCleanerManager$) - posted by "Anna Povzner (Jira)" <ji...@apache.org> on 2019/12/04 18:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/04 21:13:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9250) Kafka streams stuck in rebalancing state after UnknownHostException - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/04 21:30:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9251) Describing a non consumer group with the Admin API hangs forever - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/04 21:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9251) Describing a non consumer group with the Admin API hangs forever - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/04 21:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9251) Describing a non consumer group with the Admin API hangs forever - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/04 22:01:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8904) Reduce metadata lookups when producing to a large number of topics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/04 22:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9219) NullPointerException when polling metrics from Kafka Connect - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/04 23:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9219) NullPointerException when polling metrics from Kafka Connect - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/04 23:39:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9269) Warn if security.protocol does not match security configuration - posted by "Richard Wise (Jira)" <ji...@apache.org> on 2019/12/05 01:30:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9184) Redundant task creation and periodic rebalances after zombie worker rejoins the group - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/05 02:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9241) SASL Clients are not forced to re-authenticate if they don't leverage SaslAuthenticateRequest - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/05 02:05:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-9123) Add system test with large number of partitions - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/05 02:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9123) Add system test with large number of partitions - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/05 02:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9270) KafkaStream crash on offset commit failure - posted by "Rohan Kulkarni (Jira)" <ji...@apache.org> on 2019/12/05 05:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9270) KafkaStream crash on offset commit failure - posted by "Rohan Kulkarni (Jira)" <ji...@apache.org> on 2019/12/05 06:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7982) ConcurrentModificationException and Continuous warnings "Attempting to send response via channel for which there is no open connection" - posted by "Pradeep Bansal (Jira)" <ji...@apache.org> on 2019/12/05 06:41: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/12/05 06:44:01 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown - posted by "Francisco Juan (Jira)" <ji...@apache.org> on 2019/12/05 10:09:01 UTC, 3 replies.
- [jira] [Commented] (KAFKA-8896) NoSuchElementException after coordinator move - posted by "Francisco Juan (Jira)" <ji...@apache.org> on 2019/12/05 10:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9271) Client hangs until timeout when SSL handshake fails - posted by "Richard Wise (Jira)" <ji...@apache.org> on 2019/12/05 10:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9272) Error when trying to connect to SSL port using PLAINTEXT is very confusing - posted by "Richard Wise (Jira)" <ji...@apache.org> on 2019/12/05 10:53:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-9261) NPE when updating client metadata - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/05 14:49:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/05 15:44:00 UTC, 7 replies.
- [jira] [Created] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/05 16:07:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9179) Flaky test kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/05 18:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9179) Flaky test kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/05 19:04:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9131) failed producer metadata updates result in the unrelated error message - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/05 20:45:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams - posted by "Boyang Chen (Jira)" <ji...@apache.org> on 2019/12/05 21:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/05 21:27:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-6989) Support Async Processing in Streams - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/05 21:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/05 21:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/05 21:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/05 22:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9260) Improve Serde "push down" and "wrapping" - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/05 22:37:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/05 23:07:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group - posted by "Badai Aqrandista (Jira)" <ji...@apache.org> on 2019/12/06 00:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9276) Unclear warning due to empty throttled fetch response - posted by "Bob Barrett (Jira)" <ji...@apache.org> on 2019/12/06 00:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group - posted by "Badai Aqrandista (Jira)" <ji...@apache.org> on 2019/12/06 00:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9179) Flaky test kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/06 00:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest - posted by "Michael Jaschob (Jira)" <ji...@apache.org> on 2019/12/06 01:00:13 UTC, 7 replies.
- [jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease - posted by "li xiangyuan (Jira)" <ji...@apache.org> on 2019/12/06 03:28:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease - posted by "li xiangyuan (Jira)" <ji...@apache.org> on 2019/12/06 03:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 may cause tcp delay ack(Congestion Control) - posted by "li xiangyuan (Jira)" <ji...@apache.org> on 2019/12/06 03:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9270) KafkaStream crash on offset commit failure - posted by "Rohan Kulkarni (Jira)" <ji...@apache.org> on 2019/12/06 05:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/06 06:36:00 UTC, 7 replies.
- [jira] [Issue Comment Deleted] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/06 07:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/06 07:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9277) move all group state transition rules into their states - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/06 07:39:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9267) ZkSecurityMigrator should not create /controller node - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/06 09:56:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9278) Avoid using static instance of DisconnectException - posted by "Qinghui Xu (Jira)" <ji...@apache.org> on 2019/12/06 12:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9278) Avoid using static instance of DisconnectException - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/06 12:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9279) Silent data loss in Kafka producer - posted by "Andrew Klopper (Jira)" <ji...@apache.org> on 2019/12/06 12:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9279) Silent data loss in Kafka producer - posted by "Mattia Barbon (Jira)" <ji...@apache.org> on 2019/12/06 12:47:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-9280) Duplicate messages are observed in ACK mode ALL - posted by "VIkram (Jira)" <ji...@apache.org> on 2019/12/06 13:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9280) Duplicate messages are observed in ACK mode ALL - posted by "Boyang Chen (Jira)" <ji...@apache.org> on 2019/12/06 15:53:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/06 16:38:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/06 16:38:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR - posted by "Cory (Jira)" <ji...@apache.org> on 2019/12/06 16:57:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR - posted by "Cory (Jira)" <ji...@apache.org> on 2019/12/06 16:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/06 18:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/06 18:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/06 18:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9282) Consider more flexible node grouping for Pattern subscription - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/06 19:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9091) KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/06 19:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7489) ConnectDistributedTest is always running broker with dev version - posted by "Randall Hauch (Jira)" <ji...@apache.org> on 2019/12/06 19:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7588) Rationalize configurations passed to pluggable APIs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/06 19:59:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/06 20:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9283) Flaky Test - kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2019/12/07 00:00:14 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9283) Flaky Test - kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2019/12/07 00:06:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-9284) Add documentation and system tests for TLS-encrypted Zookeeper connections - posted by "Ron Dagostino (Jira)" <ji...@apache.org> on 2019/12/07 00:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/07 01:43:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/07 02:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9285) Implement failed message topic to account for processing lag during failure - posted by "Richard Yu (Jira)" <ji...@apache.org> on 2019/12/07 03:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9285) Implement failed message topic to account for processing lag during failure - posted by "Richard Yu (Jira)" <ji...@apache.org> on 2019/12/07 03:38:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-9285) Implement failed message topic to account for processing lag during failure - posted by "Richard Yu (Jira)" <ji...@apache.org> on 2019/12/07 03:41:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-9285) Implement failed message topic to account for processing lag during failure - posted by "Richard Yu (Jira)" <ji...@apache.org> on 2019/12/07 03:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/07 07:19:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations - posted by "Manasvi Gupta (Jira)" <ji...@apache.org> on 2019/12/07 08:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space - posted by "Manasvi Gupta (Jira)" <ji...@apache.org> on 2019/12/07 09:00:04 UTC, 0 replies.
- [jira] [Created] (KAFKA-9286) Improve producer performance - posted by "YunlongLou (Jira)" <ji...@apache.org> on 2019/12/07 09:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9232) Coordinator new member heartbeat completion does not work for JoinGroup v3 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/07 18:50:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition - posted by "VinayKumar (Jira)" <ji...@apache.org> on 2019/12/07 19:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/08 00:44:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/08 01:26:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (KAFKA-9285) Implement failed message topic to account for processing lag during failure - posted by "Richard Yu (Jira)" <ji...@apache.org> on 2019/12/08 04:06:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9285) Implement failed message topic to account for processing lag during failure - posted by "Richard Yu (Jira)" <ji...@apache.org> on 2019/12/08 04:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9287) Transaction completion may block unnecessarily after abortable error - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/08 07:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9287) Transaction completion may block unnecessarily after abortable error - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/08 07:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9266) KafkaConsumer manual assignment does not reset group assignment - posted by "daile (Jira)" <ji...@apache.org> on 2019/12/08 11:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/08 17:43:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-9266) KafkaConsumer manual assignment does not reset group assignment - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/09 00:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/09 02:34:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/09 03:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8953) Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/09 03:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9220) TimeoutException when using kafka-preferred-replica-election - posted by "Or Shemesh (Jira)" <ji...@apache.org> on 2019/12/09 10:37:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7251) Add support for TLS 1.3 - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/09 10:41:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9279) Silent data loss in Kafka producer - posted by "Andrew Klopper (Jira)" <ji...@apache.org> on 2019/12/09 11:49:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-8733) Offline partitions occur when leader's disk is slow in reads while responding to follower fetch requests. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/09 11:56:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8059) Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/12/09 14:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9261) NPE when updating client metadata - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/09 16:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7251) Add support for TLS 1.3 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/09 16:54:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/09 17:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9241) SASL Clients are not forced to re-authenticate if they don't leverage SaslAuthenticateRequest - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/09 18:59:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9241) SASL Clients are not forced to re-authenticate if they don't leverage SaslAuthenticateRequest - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/09 18:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9230) Change User Customizable Metrics API in StreamsMetrics interface - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/09 20:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/09 22:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/09 22:05:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/09 22:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9159) Consumer.endOffsets Throw TimeoutException: Failed to get offsets by times in 30000ms after a leader change - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/09 23:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9288) Do not allow the same object to be inserted multiple times into ImplicitLinkedHashCollection - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2019/12/10 00:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9288) Do not allow the same object to be inserted multiple times into ImplicitLinkedHashCollection - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/10 00:50:00 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/10 03:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9064) Observing transient issue with kinit command - posted by "Pradeep Bansal (Jira)" <ji...@apache.org> on 2019/12/10 05:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9048) Improve scalability in number of partitions in replica fetcher - posted by "Pradeep Bansal (Jira)" <ji...@apache.org> on 2019/12/10 06:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7362) enable kafka broker to remove orphan partitions automatically - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/12/10 06:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7362) enable kafka broker to remove orphan partitions automatically - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/12/10 06:45:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/10 07:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9025) ZkSecurityMigrator not working with zookeeper chroot - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/10 08:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9025) ZkSecurityMigrator not working with zookeeper chroot - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/10 08:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9289) consolidate all the streams smoke system tests - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/10 15:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9289) consolidate all the streams smoke system tests - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/10 15:55:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9289) consolidate all the streams smoke system tests - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/10 15:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-4898) Add timeouts to streams integration tests - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/10 19:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9002) Flaky Test org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/10 19:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9002) Flaky Test org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/10 19:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9002) Flaky Test org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/10 19:54:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7698) Kafka Broker fail to start: ProducerFencedException thrown from producerstatemanager.scala!checkProducerEpoch - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/10 21:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9290) Update IQ related JavaDocs - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/11 08:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9291) remove the code of KAFKA-9288 which bring fatal bug - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/11 11:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9291) remove the code of KAFKA-9288 which bring fatal bug - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/11 12:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9291) remove the code of KAFKA-9288 which bring fatal bug - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/11 12:58:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-9291) seeor - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/11 15:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9291) error start consumer - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/11 15:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9291) error starting consumer - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/11 15:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9291) error starting consumer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/11 15:38:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-9292) KIP-551: Expose disk read and write metrics - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2019/12/11 17:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/11 17:45:01 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9138) Add system test covering Foreign Key joins (KIP-213) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/11 17:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9138) Add system test covering Foreign Key joins (KIP-213) - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/11 17:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9293) NPE in DumpLogSegments with --offsets-decoder - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/11 19:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9293) NPE in DumpLogSegments with --offsets-decoder - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/11 19:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9024) org.apache.kafka.connect.transforms.ValueToKey throws NPE - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/11 19:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9293) NPE in DumpLogSegments with --offsets-decoder - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/11 22:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9228) Reconfigured converters and clients may not be propagated to connector tasks - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/12/11 23:27:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8512) Looking into the Future: Assignor Version - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/12 00:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8511) Looking into the Future: Heartbeat Communicated Protocol - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/12 00:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9291) error starting consumer - posted by "dengziming (Jira)" <ji...@apache.org> on 2019/12/12 02:16:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/12 09:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/12 09:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9125) GroupMetadataManager and TransactionStateManager should query the controller instead of zkClient - posted by "ErKang QI (Jira)" <ji...@apache.org> on 2019/12/12 11:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7983) supporting replication.throttled.replicas in dynamic broker configuration - posted by "Alex Mironov (Jira)" <ji...@apache.org> on 2019/12/12 12:00:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9283) Flaky Test - kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker - posted by "Israel Ekpo (Jira)" <ji...@apache.org> on 2019/12/12 15:55:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-9294) Enhance DSL Naming Guide to Include All Naming Rules - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/12 15:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9283) Flaky Test - kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/12 16:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/12 18:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-5295) Allow Kafka Connect source connectors to specify topic-specific settings for new topics - posted by "Konstantine Karantasis (Jira)" <ji...@apache.org> on 2019/12/12 20:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5295) Allow Kafka Connect source connectors to specify topic-specific settings for new topics - posted by "Konstantine Karantasis (Jira)" <ji...@apache.org> on 2019/12/12 20:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/12 21:25:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8705) NullPointerException was thrown by topology optimization when two MergeNodes have common KeyChaingingNode - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/12 22:08:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9296) Correlation id for response () does not match request () - posted by "Enhon Bryant (Jira)" <ji...@apache.org> on 2019/12/13 06:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9296) Correlation id for response () does not match request () - posted by "Enhon Bryant (Jira)" <ji...@apache.org> on 2019/12/13 06:30:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-9297) CreateTopic API do not work with older version of the request/response - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/12/13 09:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9297) CreateTopic API do not work with older version of the request/response - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/13 09:18:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-9297) CreateTopic API do not work with older version of the request/response - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/12/13 09:25:00 UTC, 5 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/12/13 18:39:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2019/12/13 22:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2019/12/13 22:12:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9299) Over eager optimization - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2019/12/13 22:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology - posted by "Walker Carlson (Jira)" <ji...@apache.org> on 2019/12/13 22:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9299) Over eager optimization - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/13 22:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/13 22:53:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8250) Flaky Test DelegationTokenEndToEndAuthorizationTest#testProduceConsumeViaAssign - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/13 22:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9176) Flaky test failure: OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/13 23:00:07 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9113) Clean up task management - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/14 04:25:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-9167) Implement a broker to controller request channel - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2019/12/14 09:08:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/14 09:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9300) Create a topci based on the specified brokers - posted by "weiwei (Jira)" <ji...@apache.org> on 2019/12/14 10:08:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9300) Create a topic based on the specified brokers - posted by "weiwei (Jira)" <ji...@apache.org> on 2019/12/14 10:17:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes - posted by "Sujay Hegde (Jira)" <ji...@apache.org> on 2019/12/14 13:00:12 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9290) Update IQ related JavaDocs - posted by "Sujay Hegde (Jira)" <ji...@apache.org> on 2019/12/14 13:08:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-4094) Fix importance labels for Kafka Server config - posted by "Sujay Hegde (Jira)" <ji...@apache.org> on 2019/12/14 13:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-2865) Improve Request API Error Code Documention - posted by "Sujay Hegde (Jira)" <ji...@apache.org> on 2019/12/14 13:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-1983) TestEndToEndLatency can be unreliable after hard kill - posted by "Sujay Hegde (Jira)" <ji...@apache.org> on 2019/12/14 13:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8078) Flaky Test TableTableJoinIntegrationTest#testInnerInner - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/15 20:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/15 21:04:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9001) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/15 21:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9182) Flaky Test org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/15 21:09:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9176) Flaky test failure: OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/15 21:09:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9301) KafkaProducer#flush should block until all the sent records get completed - posted by "Tomoyuki Saito (Jira)" <ji...@apache.org> on 2019/12/16 03:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9301) KafkaProducer#flush should block until all the sent records get completed - posted by "Tomoyuki Saito (Jira)" <ji...@apache.org> on 2019/12/16 03:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes - posted by "Omkar Mestry (Jira)" <ji...@apache.org> on 2019/12/16 05:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9250) Kafka streams stuck in rebalancing state after UnknownHostException - posted by "Vijay (Jira)" <ji...@apache.org> on 2019/12/16 06:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9300) Create a topic based on the specified brokers - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/16 08:23:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-8855) Collect and Expose Client's Name and Version in the Brokers - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/12/16 09:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams - posted by "adam Retter (Jira)" <ji...@apache.org> on 2019/12/16 11:57:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-9148) Consider forking RocksDB for Streams - posted by "adam Retter (Jira)" <ji...@apache.org> on 2019/12/16 12:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9302) Allow custom partitioning in foreign-key joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/16 16:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9302) Allow custom partitioning in foreign-key joins - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/16 16:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9302) Allow custom partitioning in table-table joins - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/16 16:38:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore - posted by "Demitri Swan (Jira)" <ji...@apache.org> on 2019/12/16 17:48:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-9297) CreateTopic API do not work with older version of the request/response - posted by "David Jacot (Jira)" <ji...@apache.org> on 2019/12/16 18:41:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9243) Update the javadocs from KeyValueStore to TimestampKeyValueStore - posted by "Demitri Swan (Jira)" <ji...@apache.org> on 2019/12/16 18:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9303) Kafka 2.4.0 releaseTarGZ target produces kafka_2.12-2.4.1-SHAPSHOT.tgz instead of kafka_2.12-2.4.1.tgz - posted by "Philip Johnson (Jira)" <ji...@apache.org> on 2019/12/16 19:40:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9304) Image on Kafka docs shows incorrect message ID segments - posted by "Victoria Bialas (Jira)" <ji...@apache.org> on 2019/12/16 19:44:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9304) Image on Kafka docs shows incorrect message ID segments - posted by "Victoria Bialas (Jira)" <ji...@apache.org> on 2019/12/16 19:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9304) Image on Kafka docs shows incorrect message ID segments - posted by "Victoria Bialas (Jira)" <ji...@apache.org> on 2019/12/16 19:45:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-9303) Kafka 2.4.0 releaseTarGZ target produces kafka_2.12-2.4.1-SHAPSHOT.tgz instead of kafka_2.12-2.4.1.tgz - posted by "Philip Johnson (Jira)" <ji...@apache.org> on 2019/12/16 19:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/16 21:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9304) Image on Kafka docs shows incorrect message ID segments - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/16 22:32:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-9305) Add version 2.4 to streams system tests - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/16 23:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9305) Add version 2.4 to streams system tests - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/17 00:01:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8784) Remove default implementation of RocksDBConfigSetter#close - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/17 00:21:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-9161) Close gaps in Streams configs documentation - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/17 00:29:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9161) Close gaps in Streams configs documentation - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/17 00:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9161) Close gaps in Streams configs documentation - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/17 00:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9306) Kafka Consumer does not clean up all metrics after shutdown - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2019/12/17 01:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9306) Kafka Consumer does not clean up all metrics after shutdown - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/17 01:17:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9304) Image on Kafka docs shows incorrect message ID segments - posted by "Victoria Bialas (Jira)" <ji...@apache.org> on 2019/12/17 01:57:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9307) Transaction coordinator could be left in unknown state after ZK session timeout - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/12/17 04:22:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9307) Transaction coordinator could be left in unknown state after ZK session timeout - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/12/17 04:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9307) Transaction coordinator could be left in unknown state after ZK session timeout - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/12/17 04:33:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-9307) Transaction coordinator could be left in unknown state after ZK session timeout - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/12/17 04:36:00 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-9307) Transaction coordinator could be left in unknown state after ZK session timeout - posted by "Dhruvil Shah (Jira)" <ji...@apache.org> on 2019/12/17 04:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool - posted by "feyman (Jira)" <ji...@apache.org> on 2019/12/17 07:59:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-9305) Add version 2.4 to streams system tests - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/17 08:09:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9308) Misses SAN after certificate creation - posted by "Agostino Sarubbo (Jira)" <ji...@apache.org> on 2019/12/17 12:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9308) Misses SAN after certificate creation - posted by "Agostino Sarubbo (Jira)" <ji...@apache.org> on 2019/12/17 12:39:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9308) Misses SAN after certificate creation - posted by "Sönke Liebau (Jira)" <ji...@apache.org> on 2019/12/17 15:42:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9284) Add documentation and system tests for TLS-encrypted Zookeeper connections - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/17 16:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8744) Add Support to Scala API for KIP-307 and KIP-479 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/17 17:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9309) Add the ability to translate Message classes to and from JSON - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2019/12/17 19:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9309) Add the ability to translate Message classes to and from JSON - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/17 19:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/17 21:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/17 21:45:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/17 21:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9311) Jumbled table content for broker config doc - posted by "Joel Hamill (Jira)" <ji...@apache.org> on 2019/12/17 22:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9311) Jumbled table content for broker config doc - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/17 23:16:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-9311) Jumbled table content for broker config doc - posted by "Sönke Liebau (Jira)" <ji...@apache.org> on 2019/12/17 23:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/18 00:29:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9312) KafkaProducer flush behavior does not guarantee send completion under record batch splitting - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/12/18 02:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/12/18 02:18:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-9301) KafkaProducer#flush should block until all the sent records get completed - posted by "Tomoyuki Saito (Jira)" <ji...@apache.org> on 2019/12/18 13:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9301) KafkaProducer#flush should block until all the sent records get completed - posted by "Tomoyuki Saito (Jira)" <ji...@apache.org> on 2019/12/18 13:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB - posted by "Jendrik Poloczek (Jira)" <ji...@apache.org> on 2019/12/18 17:04:00 UTC, 2 replies.
- [jira] [Comment Edited] (KAFKA-9062) Handle stalled writes to RocksDB - posted by "Jendrik Poloczek (Jira)" <ji...@apache.org> on 2019/12/18 17:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9313) Set default for client.dns.lookup to use_all_dns_ips - posted by "Yeva Byzek (Jira)" <ji...@apache.org> on 2019/12/18 17:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9313) Set default for client.dns.lookup to use_all_dns_ips - posted by "Yeva Byzek (Jira)" <ji...@apache.org> on 2019/12/18 17:55:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-9314) Connect put() and poll() retries not conforming to KIP-298 - posted by "Nigel Liang (Jira)" <ji...@apache.org> on 2019/12/18 19:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9314) Connect put() and poll() retries not conforming to KIP-298 - posted by "Nigel Liang (Jira)" <ji...@apache.org> on 2019/12/18 19:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9315) The Kafka Metrics class should clear the mbeans map when closing - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2019/12/18 20:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9315) The Kafka Metrics class should clear the mbeans map when closing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/18 20:35:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-5756) Synchronization issue on flush - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/12/18 22:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-5756) Synchronization issue on flush - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2019/12/18 22:16:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API - posted by "Alex Kokachev (Jira)" <ji...@apache.org> on 2019/12/19 01:22:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-9316) ConsoleProducer help info not expose default properties - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/19 07:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9316) ConsoleProducer help info not expose default properties - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/19 07:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9317) Provide a group admin command to get group information or do some admin operation - posted by "maobaolong (Jira)" <ji...@apache.org> on 2019/12/19 08:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9317) Provide a group admin command to get group information or do some admin operation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/19 08:33:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9049) TopicCommandWithAdminClientTest should use mocks - posted by "Jono Morris (Jira)" <ji...@apache.org> on 2019/12/19 08:56:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-9049) TopicCommandWithAdminClientTest should use mocks - posted by "Jono Morris (Jira)" <ji...@apache.org> on 2019/12/19 09:07:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/12/19 11:03:00 UTC, 6 replies.
- [jira] [Comment Edited] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/12/19 11:04:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9318) Kafka Connect. Add map entry value extraction SMT - posted by "Piotr Smolinski (Jira)" <ji...@apache.org> on 2019/12/19 11:53:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9316) ConsoleProducer help info not expose default properties - posted by "Manikumar (Jira)" <ji...@apache.org> on 2019/12/19 13:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9318) Kafka Connect. Add map entry value extraction SMT - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/19 13:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9319) Run some system tests using TLSv1.3 - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/19 14:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9320) Enable TLSv1.3 by default and disable some of the older protocols - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/19 14:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7251) Add support for TLS 1.3 - posted by "Rajini Sivaram (Jira)" <ji...@apache.org> on 2019/12/19 14:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8079) Flaky Test EpochDrivenReplicationProtocolAcceptanceTest#shouldSurviveFastLeaderChange - posted by "Bill Bejeck (Jira)" <ji...@apache.org> on 2019/12/19 16:34:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter - posted by "Stefan Bocutiu (Jira)" <ji...@apache.org> on 2019/12/19 16:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter - posted by "Stefan Bocutiu (Jira)" <ji...@apache.org> on 2019/12/19 16:36:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata - posted by "Apurva Mehta (Jira)" <ji...@apache.org> on 2019/12/19 16:51:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/19 17:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9321) StreamsBuilder table method overwrites the materialized parameter - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/19 17:40:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9314) Connect put() and poll() retries not conforming to KIP-298 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/19 20:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7943) Add Suppress system test with caching disabled. - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/19 22:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/20 06:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/20 06:56:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9239) Extreme amounts of logging done by unauthorized Kafka clients - posted by "Anders Eknert (Jira)" <ji...@apache.org> on 2019/12/20 08:52:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9239) Extreme amounts of logging done by unauthorized Kafka clients - posted by "Anders Eknert (Jira)" <ji...@apache.org> on 2019/12/20 08:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6985) Error connection between cluster node - posted by "Radoslaw Gasiorek (Jira)" <ji...@apache.org> on 2019/12/20 09:55:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-6985) Error connection between cluster node - posted by "Radoslaw Gasiorek (Jira)" <ji...@apache.org> on 2019/12/20 09:56:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps - posted by "Roman Schmitz (Jira)" <ji...@apache.org> on 2019/12/20 12:48:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4134) Transparently notify users of "Connection Refused" for client to broker connections - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/20 19:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/20 22:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9323) Refactor Streams' upgrade system tests - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/20 23:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/21 09:46:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/21 19:27:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-8147) Add changelog topic configuration to KTable suppress - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/21 23:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/21 23:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9324) Drop support for Scala 2.11 (KIP-531) - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/22 05:10:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7267) KafkaStreams Scala DSL process method should accept a ProcessorSupplier - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/22 05:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9324) Drop support for Scala 2.11 (KIP-531) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/22 05:18:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker - posted by "Oleg Muravskiy (Jira)" <ji...@apache.org> on 2019/12/22 21:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9322) Add `tail -n` feature for ConsoleConsumer - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/23 03:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9320) Enable TLSv1.3 by default and disable some of the older protocols - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2019/12/23 06:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9325) Document Follower Fetch - posted by "Gwen Shapira (Jira)" <ji...@apache.org> on 2019/12/23 08:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9246) Update Heartbeat timeout when ConsumerCoordinator commit offset - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/23 09:51:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9326) Kafka Connect JSON Converter results in data loss when additional fields apart from provided JSON schema is present in the payload - posted by "rameshkrishnan muthusamy (Jira)" <ji...@apache.org> on 2019/12/23 12:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9327) GroupMetadata metrics are not documented - posted by "Gwen Shapira (Jira)" <ji...@apache.org> on 2019/12/23 14:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9328) Move MirrorMaker 2.0 documentation to site-docs - posted by "Gwen Shapira (Jira)" <ji...@apache.org> on 2019/12/23 15:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9326) Kafka Connect JSON Converter results in data loss when additional fields apart from provided JSON schema is present in the payload - posted by "rameshkrishnan muthusamy (Jira)" <ji...@apache.org> on 2019/12/23 17:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9329) KafkaController::replicasAreValid should return error - posted by "Vikas Singh (Jira)" <ji...@apache.org> on 2019/12/23 18:25:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9329) KafkaController::replicasAreValid should return error - posted by "Vikas Singh (Jira)" <ji...@apache.org> on 2019/12/23 18:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9326) Kafka Connect JSON Converter results in data loss when additional fields apart from provided JSON schema is present in the payload - posted by "rameshkrishnan muthusamy (Jira)" <ji...@apache.org> on 2019/12/23 18:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9329) KafkaController::replicasAreValid should return error - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/23 21:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9330) Calling AdminClient.close in the AdminClient completion callback causes deadlock - posted by "Vikas Singh (Jira)" <ji...@apache.org> on 2019/12/23 22:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/23 23:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9330) Calling AdminClient.close in the AdminClient completion callback causes deadlock - posted by "Vikas Singh (Jira)" <ji...@apache.org> on 2019/12/23 23:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9331) Add option to terminate application when StreamThread(s) die - posted by "Michael Bingham (Jira)" <ji...@apache.org> on 2019/12/23 23:36:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9277) move all group state transition rules into their states - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/23 23:37:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9307) Transaction coordinator could be left in unknown state after ZK session timeout - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/23 23:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9232) Coordinator new member heartbeat completion does not work for JoinGroup v3 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/23 23:56:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9330) Calling AdminClient.close in the AdminClient completion callback causes deadlock - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/23 23:56:03 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9232) Coordinator new member heartbeat completion does not work for JoinGroup v3 - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/24 01:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6144) Allow serving interactive queries from in-sync Standbys - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/24 02:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9254) Topic level configuration failed - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/24 09:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9332) change how to get joinGroupTimeoutMs - posted by "qianrui (Jira)" <ji...@apache.org> on 2019/12/24 11:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9332) change how to get joinGroupTimeoutMs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/24 12:11:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9320) Enable TLSv1.3 by default and disable some of the older protocols - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2019/12/24 15:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9320) Enable TLSv1.3 by default and disable some of the older protocols - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2019/12/24 15:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-4149) java.lang.NoSuchMethodError when running streams tests - posted by "sdhalex (Jira)" <ji...@apache.org> on 2019/12/24 21:23:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException - posted by "Fangbin Sun (Jira)" <ji...@apache.org> on 2019/12/25 06:29:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting - posted by "Jonathan Santilli (Jira)" <ji...@apache.org> on 2019/12/25 11:18:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9333) Shim `core` module that targets default scala version (KIP-531) - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/25 13:41:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9334) Add more unit tests for Materialized class - posted by "Sainath Batthala (Jira)" <ji...@apache.org> on 2019/12/25 19:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9334) Add more unit tests for Materialized class - posted by "Sainath Batthala (Jira)" <ji...@apache.org> on 2019/12/25 19:32:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-9277) move all group state transition rules into their states - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/26 01:38:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-9236) Confused log after using CLI scripts to produce messages - posted by "Xiang Zhang (Jira)" <ji...@apache.org> on 2019/12/26 01:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9334) Add more unit tests for Materialized class - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/26 02:40:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1. - posted by "Nitay Kufert (Jira)" <ji...@apache.org> on 2019/12/26 10:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1. - posted by "Nitay Kufert (Jira)" <ji...@apache.org> on 2019/12/26 17:54:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-9334) Add more unit tests for Materialized class - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/26 20:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9336) Connecting to Kafka using forwarded Kerberos credentials - posted by "Grzegorz Kokosinski (Jira)" <ji...@apache.org> on 2019/12/26 21:49:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9331) Add option to terminate application when StreamThread(s) die - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/26 23:17:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9331) Add option to terminate application when StreamThread(s) die - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/26 23:17:00 UTC, 2 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/12/27 08:11:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9337) Simplifying standalone mm2-connect config - posted by "karan kumar (Jira)" <ji...@apache.org> on 2019/12/27 10:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9337) Simplifying standalone mm2-connect config - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/27 10:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/27 18:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6607) Consumer Client and Kafka Streams lag not zero when input topic transactional - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/27 18:40:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-9338) Incremental fetch sessions do not maintain or use leader epoch for fencing purposes - posted by "Lucas Bradstreet (Jira)" <ji...@apache.org> on 2019/12/27 19:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9338) Incremental fetch sessions do not maintain or use leader epoch for fencing purposes - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/27 19:17:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9339) Increased CPU utilization in brokers in 2.4.0 - posted by "James Brown (Jira)" <ji...@apache.org> on 2019/12/27 23:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9339) Increased CPU utilization in brokers in 2.4.0 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2019/12/28 06:46:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9340) Potential race condition in AbstractConfig - posted by "Roman Leventov (Jira)" <ji...@apache.org> on 2019/12/28 08:35:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9340) Potential race condition in AbstractConfig - posted by "Roman Leventov (Jira)" <ji...@apache.org> on 2019/12/28 08:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9202) serde in ConsoleConsumer with access to headers - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/28 23:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9202) serde in ConsoleConsumer with access to headers - posted by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/12/28 23:44:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9341) Flaky Test TopicCommandWithAdminClientTest#testCreateWithReplicaAssignment - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/29 19:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9342) Consider making all Kafka Streams DSL configuration classes immutable - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/12/29 20:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9342) Consider making all Kafka Streams DSL configuration classes immutable - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2019/12/29 20:03:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9294) Enhance DSL Naming Guide to Include All Naming Rules - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/30 00:16:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9343) Make Kafka shell runnable on z/OS - posted by "Shuo Zhang (Jira)" <ji...@apache.org> on 2019/12/30 01:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9343) Make Kafka shell runnable on z/OS - posted by "Shuo Zhang (Jira)" <ji...@apache.org> on 2019/12/30 01:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9344) Logged consumer config does not always match actual config values - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/30 03:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9344) Logged consumer config does not always match actual config values - posted by "huxihx (Jira)" <ji...@apache.org> on 2019/12/30 03:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8534) retention.bytes does not work as documented - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/30 05:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9345) Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API - posted by "yzhou (Jira)" <ji...@apache.org> on 2019/12/30 09:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9344) Logged consumer config does not always match actual config values - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/30 09:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9345) Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API - posted by "yzhou (Jira)" <ji...@apache.org> on 2019/12/30 13:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6621) Update Streams docs with details for UncaughtExceptionHandler - posted by "Antony Stubbs (Jira)" <ji...@apache.org> on 2019/12/30 13:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9343) Make Kafka shell runnable on z/OS - posted by "Dongjin Lee (Jira)" <ji...@apache.org> on 2019/12/30 15:08:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9345) Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API - posted by "Ryanne Dolan (Jira)" <ji...@apache.org> on 2019/12/30 15:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/30 16:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9331) Add option to terminate application when StreamThread(s) die - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/30 18:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9294) Enhance DSL Naming Guide to Include All Naming Rules - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/30 19:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-8587) One producer per thread for Kafka Streams EOS - posted by "Boyang Chen (Jira)" <ji...@apache.org> on 2019/12/30 20:03:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-9346) Consumer fetch offset back-off with pending transactions - posted by "Boyang Chen (Jira)" <ji...@apache.org> on 2019/12/30 20:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9346) Consumer fetch offset back-off with pending transactions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/12/30 20:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/30 20:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7640) Kafka stream interactive query not returning data when state is backed by rocksdb - posted by "John Roesler (Jira)" <ji...@apache.org> on 2019/12/30 21:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/30 22:20:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3944) After the broker restart, fetchers stopped due to a delayed controlled shutdown message - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/30 22:22:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9347) Detect deleted log directory before becoming leader - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/30 22:45:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed" - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/30 22:46:01 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-661) Prevent a shutting down broker from re-entering the ISR - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/30 22:55:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9348) Broker shutdown during controller initialization can lead to zombie broker - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/30 23:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9349) Investigate new member timeout for dynamic v4 JoinGroup - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/30 23:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1 - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/31 00:59:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9350) IllegalStateException when materializing transactional offset commits - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/31 01:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/31 02:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7293) Merge followed by groupByKey/join might violate co-partioning - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/31 02:50:00 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-7994) Improve Stream-Time for rebalances and restarts - posted by "Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2019/12/31 03:20:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9351) Higher count in destination cluster using Kafka MM2 - posted by "Nitish Goyal (Jira)" <ji...@apache.org> on 2019/12/31 05:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-7994) Improve Stream-Time for rebalances and restarts - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/31 20:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-7994) Improve Stream-Time for rebalances and restarts - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/31 20:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/31 20:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9334) Add more unit tests for Materialized class - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/12/31 20:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-9352) unbalanced assignment of topic-partition to tasks - posted by "Ning Zhang (Jira)" <ji...@apache.org> on 2019/12/31 22:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9352) unbalanced assignment of topic-partition to tasks - posted by "Ning Zhang (Jira)" <ji...@apache.org> on 2019/12/31 22:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9352) unbalanced assignment of topic-partition to tasks - posted by "Ning Zhang (Jira)" <ji...@apache.org> on 2019/12/31 22:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9233) Kafka consumer throws undocumented IllegalStateException - posted by "Andrew Olson (Jira)" <ji...@apache.org> on 2019/12/31 22:45:00 UTC, 0 replies.