jira  

Messages by Date

• 2018/11/19 [jira] [Commented] (KAFKA-7566) Add sidecar job to leader (or a random single follower) only Boyang Chen (JIRA)
• 2018/11/19 [jira] [Comment Edited] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes. Mark Tranter (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache Adam Bellemare (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog Matthias J. Sax (JIRA)
• 2018/11/19 [jira] [Updated] (KAFKA-7192) State-store can desynchronise with changelog Matthias J. Sax (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog ASF GitHub Bot (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7638) Trogdor - Support mass task creation endpoint ASF GitHub Bot (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction JIRA
• 2018/11/19 [jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction JIRA
• 2018/11/19 [jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction Jason Gustafson (JIRA)
• 2018/11/19 [jira] [Updated] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow Patrick Haas (JIRA)
• 2018/11/19 [jira] [Updated] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow Patrick Haas (JIRA)
• 2018/11/19 [jira] [Updated] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow Patrick Haas (JIRA)
• 2018/11/19 [jira] [Created] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow Patrick Haas (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-4277) creating ephemeral node already exist Jonathan Santilli (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods. Bruno Bieth (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect Daren Thomas (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes. Michael Noll (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect Daren Thomas (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-6585) Consolidate duplicated logic on reset tools Samuel Hawker (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-6585) Consolidate duplicated logic on reset tools Samuel Hawker (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Jason Gustafson (JIRA)
• 2018/11/19 [jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup Jason Gustafson (JIRA)
• 2018/11/19 [jira] [Comment Edited] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• 2018/11/19 [jira] [Resolved] (KAFKA-764) Race Condition in Broker Registration after ZooKeeper disconnect Manikumar (JIRA)
• 2018/11/19 [jira] [Comment Edited] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• 2018/11/19 [jira] [Comment Edited] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow ASF GitHub Bot (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect Matthias J. Sax (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods. Matthias J. Sax (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-4277) creating ephemeral node already exist Jun Rao (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7361) Kafka wont reconnect after NoRouteToHostException Manikumar (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7654) Relax requirements on serializing-only methods. Bill Bejeck (JIRA)
• 2018/11/19 [jira] [Resolved] (KAFKA-7323) add replication factor doesn't work Manikumar (JIRA)
• 2018/11/19 [jira] [Resolved] (KAFKA-7554) zookeeper.session.timeout.ms Value Manikumar (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7655) Metadata spamming requests from Kafka Streams under some circumstances, potential DOS ASF GitHub Bot (JIRA)
• 2018/11/19 [jira] [Created] (KAFKA-7655) Metadata spamming requests from Kafka Streams under some circumstances, potential DOS Pasquale Vazzana (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect Daren Thomas (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-7397) Ability to apply DSL stateless transformation on a global table Frederic Tardif (JIRA)
• 2018/11/19 [jira] [Comment Edited] (KAFKA-4493) Connections to Kafka brokers should be validated Stanislav Kozlovski (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-4493) Connections to Kafka brokers should be validated Stanislav Kozlovski (JIRA)
• 2018/11/19 [jira] [Created] (KAFKA-7654) Relax requirements on serializing-only methods. Bruno Bieth (JIRA)
• 2018/11/19 [jira] [Commented] (KAFKA-4277) creating ephemeral node already exist Birger Brunswiek (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition" Steven Aerts (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Matthias J. Sax (JIRA)
• 2018/11/18 [jira] [Assigned] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Matthias J. Sax (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Guozhang Wang (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Guozhang Wang (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7566) Add sidecar job to leader (or a random single follower) only Guozhang Wang (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Guozhang Wang (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes. Mark Tranter (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable Guozhang Wang (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes. Guozhang Wang (JIRA)
• 2018/11/18 [jira] [Comment Edited] (KAFKA-7523) TransformerSupplier/ProcessorSupplier enhancements Guozhang Wang (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7523) TransformerSupplier/ProcessorSupplier enhancements Guozhang Wang (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7632) Add producer option to adjust compression level ASF GitHub Bot (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable Matthias J. Sax (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support Junyu Chen (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client ASF GitHub Bot (JIRA)
• 2018/11/18 [jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support Andras Beni (JIRA)
• 2018/11/18 [jira] [Assigned] (KAFKA-6987) Reimplement KafkaFuture with CopletableFuture Andras Beni (JIRA)
• 2018/11/18 [jira] [Assigned] (KAFKA-3362) Update protocol schema and field doc strings Andras Beni (JIRA)
• 2018/11/18 [jira] [Assigned] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support Andras Beni (JIRA)
• 2018/11/18 [jira] [Created] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes. Mark Tranter (JIRA)
• 2018/11/17 [jira] [Assigned] (KAFKA-7527) Enable Dependency Injection for Kafka Streams handlers (KIP-378) Guozhang Wang (JIRA)
• 2018/11/17 [jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable ASF GitHub Bot (JIRA)
• 2018/11/17 [jira] [Commented] (KAFKA-7536) TopologyTestDriver cannot pre-populate KTable or GlobalKTable Guozhang Wang (JIRA)
• 2018/11/17 [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Guozhang Wang (JIRA)
• 2018/11/17 [jira] [Commented] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized ASF GitHub Bot (JIRA)
• 2018/11/17 [jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support Junyu Chen (JIRA)
• 2018/11/17 [jira] [Updated] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0 Jonathan Gordon (JIRA)
• 2018/11/17 [jira] [Created] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0 Jonathan Gordon (JIRA)
• 2018/11/17 [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Stanislav Kozlovski (JIRA)
• 2018/11/17 [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Ozgur (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7632) Add producer option to adjust compression level Lee Dongjin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7632) Add producer option to adjust compression level Lee Dongjin (JIRA)
• 2018/11/16 [jira] [Resolved] (KAFKA-7402) Kafka Streams should implement AutoCloseable where appropriate Matthias J. Sax (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
• 2018/11/16 [jira] [Assigned] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Lee Dongjin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7578) Kafka streams: add possibility to choose multiple output topics Guozhang Wang (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe Dong Lin (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect Guozhang Wang (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• 2018/11/16 [jira] [Issue Comment Deleted] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• 2018/11/16 [jira] [Comment Edited] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl Dong Lin (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7402) Kafka Streams should implement AutoCloseable where appropriate ASF GitHub Bot (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction Guozhang Wang (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7650) make "auto.create.topics.enable" dynamically configurable. xiongqi wu (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• 2018/11/16 [jira] [Comment Edited] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore Guozhang Wang (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Guozhang Wang (JIRA)
• 2018/11/16 [jira] [Comment Edited] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic` Dong Lin (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow Guozhang Wang (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable Dong Lin (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Guozhang Wang (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Guozhang Wang (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic` Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable Dong Lin (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl Dong Lin (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic Dong Lin (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe Dong Lin (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic` Dong Lin (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7645) Fix flaky unit test for 2.1 branch Dong Lin (JIRA)
• 2018/11/16 [jira] [Comment Edited] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic` Dong Lin (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7644) Worker Re balance enhancements satya (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7642) Kafka Connect - graceful shutdown of distributed worker satya (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-5946) Give connector method parameter better name Samuel Hawker (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7643) Connectors do not unload even when tasks fail in kafka connect satya (JIRA)
• 2018/11/16 [jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name Samuel Hawker (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate John Roesler (JIRA)
• 2018/11/16 [jira] [Comment Edited] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Samuel Hawker (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Stanislav Kozlovski (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• 2018/11/16 [jira] [Assigned] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate Samuel Hawker (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-4453) add request prioritization ASF GitHub Bot (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker Boyang Chen (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7641) Add `group.max.size` to cap group metadata on broker Boyang Chen (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7640) Kafka stream interactive query not returning data when state is backed by rocksdb hitesh gollahalli bachanna (JIRA)
• 2018/11/16 [jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup Jason Gustafson (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Jason Gustafson (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7595) Kafka Streams: KTrable to KTable join introduces duplicates in downstream KTable Matthias J. Sax (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-4453) add request prioritization ASF GitHub Bot (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7639) Read one request at a time from socket to reduce broker memory usage ASF GitHub Bot (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7639) Read one request at a time from socket to reduce broker memory usage Rajini Sivaram (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7637) Error while writing to checkpoint file due to too many open files Ismael Juma (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition" Steven Aerts (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7638) Trogdor - Support mass task creation endpoint Stanislav Kozlovski (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7637) Error while writing to checkpoint file due to too many open files Sander van Loo (JIRA)
• 2018/11/16 [jira] [Updated] (KAFKA-7636) Allow consumer to update maxPollRecords value Kcirtap Seven (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7636) Allow consumer to update maxPollRecords value ASF GitHub Bot (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7637) ERROR Error while writing to checkpoint file due to too many open files Sander van Loo (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7636) Allow consumer to update maxPollRecords value Kcirtap Seven (JIRA)
• 2018/11/16 [jira] [Resolved] (KAFKA-7565) NPE in KafkaConsumer Rajini Sivaram (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception. ASF GitHub Bot (JIRA)
• 2018/11/16 [jira] [Resolved] (KAFKA-7576) Dynamic update of replica fetcher threads may fail to start/close fetchers Rajini Sivaram (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception. ASF GitHub Bot (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition" Steven Aerts (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7280) ConcurrentModificationException in FetchSessionHandler in heartbeat thread Sachin Upadhyay (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer Alexey Vakhrenev (JIRA)
• 2018/11/16 [jira] [Created] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition" Steven Aerts (JIRA)
• 2018/11/16 [jira] [Resolved] (KAFKA-6774) Improve default groupId behavior in consumer Jason Gustafson (JIRA)
• 2018/11/16 [jira] [Commented] (KAFKA-6774) Improve default groupId behavior in consumer ASF GitHub Bot (JIRA)
• 2018/11/15 [jira] [Resolved] (KAFKA-7628) KafkaStream is not closing Ozgur (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Ozgur (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7628) KafkaStream is not closing Guozhang Wang (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Guozhang Wang (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog ASF GitHub Bot (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7595) Kafka Streams: KTrable to KTable join introduces duplicates in downstream KTable Vik Gamov (JIRA)
• 2018/11/15 [jira] [Created] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin() Eugen Feller (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7576) Dynamic update of replica fetcher threads may fail to start/close fetchers ASF GitHub Bot (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic John Roesler (JIRA)
• 2018/11/15 [jira] [Updated] (KAFKA-7584) StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String Guozhang Wang (JIRA)
• 2018/11/15 [jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist Arabelle Hou (JIRA)
• 2018/11/15 [jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist Arabelle Hou (JIRA)
• 2018/11/15 [jira] [Updated] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist Arabelle Hou (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist ASF GitHub Bot (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition Andy Bryant (JIRA)
• 2018/11/15 [jira] [Created] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist Arabelle Hou (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7584) StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String ASF GitHub Bot (JIRA)
• 2018/11/15 [jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition Bill Bejeck (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup Boyang Chen (JIRA)
• 2018/11/15 [jira] [Created] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd Dave Waters (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Kobi Hikri (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Kobi Hikri (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Stephane Maarek (JIRA)
• 2018/11/15 [jira] [Comment Edited] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Kobi Hikri (JIRA)
• 2018/11/15 [jira] [Assigned] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf Attila Sasvari (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Kobi Hikri (JIRA)
• 2018/11/15 [jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time Kobi Hikri (JIRA)

• Earlier messages