| KIP | Description | Status | +1 | 0 | -1 | Created by | Age | More Info |
|---|---|---|---|---|---|---|---|---|
| 1278 | Configurable Retry Mechanism for KafkaStatusBackingStore |
Mentioned within the last 28 days
|
0 | 0 | 0 | Said BOUDJELDA | 1 days | info |
| 1277 | Support Delayed Message in Kafka |
Mentioned within the last 28 days
|
0 | 0 | 0 | Henry Cai | 4 days | info |
| 1276 | CIDR-based Host Patterns for ACLs |
Mentioned within the last 0 days
|
0 | 0 | 0 | Maroš Orsák | 2 weeks | info |
| 1275 | New command line tool for unclean recovery |
Mentioned within the last 28 days
|
0 | 0 | 0 | Jonah Hooper | 2 weeks | info |
| 1274 | Deprecate and remove support for Classic rebalance protocol in KafkaConsumer |
Mentioned within the last 0 days
|
0 | 0 | 0 | Lianet Magrans | 2 weeks | info |
| 1273 | Improve Connect configurable components discoverability |
Mentioned within the last 28 days
|
0 | 0 | 0 | Mario Fiore Vitale | 2 weeks | info |
| 1272 | Support compacted topic in tiered storage |
Mentioned within the last 0 days
|
0 | 0 | 0 | Henry Cai | 3 weeks | info |
| 1271 | Allow to Store Record Headers in State Stores |
Mentioned within the last 28 days
|
0 | 0 | 0 | Alieh Saeedi | 4 weeks | info |
| 1270 | Introduce ProcessExceptionalHandler for GlobalThread |
Mentioned within the last 28 days
|
0 | 0 | 0 | Arpit Goyal | 4 weeks | info |
| 1269 | Configurable number of batches to retain in broker |
Mentioned within the last 0 days
|
0 | 0 | 0 | PoAn Yang | 4 weeks | info |
| 1268 | Prevent Dynamic Partition Expansion of Internal Topics |
Mentioned within the last 0 days
|
0 | 0 | 0 | sanghyeok an | 4 weeks | info |
| 1267 | Tiered Storage Cost Attribution Metrics |
Mentioned within the last 28 days
|
0 | 0 | 0 | ViquarKhan | 4 weeks | info |
| 1266 | Bounding The Number Of RemoteLogMetadata Messages via Compacted Topic |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Lijun Tong | 4 weeks | info |
| 1265 | Mechanism for automatic detection of internal API usage |
Mentioned within the last 28 days
|
0 | 0 | 0 | Ashwin Pankaj | 4 weeks | info |
| 1264 | Configurable TTL for Tiered Storage Index Cache |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nandini Singhal | 4 weeks | info |
| 1263 | Group Coordinator Assignment Batching and Offload |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sean Quah | 6 weeks | info |
| 1262 | Enable auto-formatting directories |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Kevin Wu | 5 weeks | info |
| 1261 | Extend Share Group Dynamic Configurations |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jimmy Wang | 5 weeks | info |
| 1260 | Enable ProducerPerformance to abort transactions |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Lan Ding | 6 weeks | info |
| 1259 | Add configuration to wipe Kafka Streams local state on startup |
Mentioned within the last 84 days
|
0 | 0 | 0 | Uladzislau Blok | 6 weeks | info |
| 1258 | Add Support for OAuth Client Assertion to client_credentials Grant Type |
Mentioned within the last 28 days
|
0 | 0 | 0 | Prabhash Kumar | 7 weeks | info |
| 1257 | Partition Size Percentage Metrics for Storage Monitoring |
Mentioned within the last 28 days
|
2
Kamal Chandraprakash
Satish Duggana |
0 | 0 | Manan Gupta | 7 weeks | info |
| 1256 | Align broker and controller behavior for the Admin.incrementalAlterConfigs API |
Mentioned within the last 28 days
|
0 | 0 | 0 | Jiunn Yang Huang | 7 weeks | info |
| 1255 | Remote Read Replicas for Kafka Tiered Storage |
Mentioned within the last 84 days
|
0 | 0 | 0 | Manan Gupta | 8 weeks | info |
| 1254 | Kafka Consumer Support for Remote Tiered Storage Fetch |
Mentioned within the last 84 days
|
0 | 0 | 0 | Tom Thornton | 8 weeks | info |
| 1253 | Add TopologyValidator Utility for Kafka Streams Topology Compatibility |
Mentioned within the last 106751 days
|
0 | 0 | 0 | sanghyeok an | 8 weeks | info |
| 1251 | Assignment epochs for consumer groups |
Mentioned within the last 84 days
|
0 | 0 | 0 | Lucas Brutschy | 9 weeks | info |
| 1250 | Add metric to track size of in-memory state stores |
Mentioned within the last 84 days
|
0 | 0 | 0 | Evan Zhou | 9 weeks | info |
| 1248 | Broker support for remote tiered storage fetch from consumer |
Mentioned within the last 84 days
|
0 | 0 | 0 | Henry Cai | 9 weeks | info |
| 1247 | Make Bytes utils class part of the public API |
Mentioned within the last 84 days
|
0 | 0 | 0 | Siddhartha Devineni | 9 weeks | info |
| 1246 | Deprecate backdoor that allows any client to produce to internal topics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | TaiJuWu | 9 weeks | info |
| 1245 | Enforce 'application.server' |
|
Mentioned within the last 84 days
0 |
0 |
0 |
sanghyeok an |
10 weeks |
info |
|
| 1243 | Consistent Metadata Reads |
Mentioned within the last 106751 days
|
0 | 0 | 0 | José Armando García Sancio | 14 weeks | info |
| 1242 | Detection and handling of misrouted connections |
Mentioned within the last 84 days
|
0 | 0 | 0 | Andrew Schofield | 11 weeks | info |
| 1241 | Reduce tiered storage redundancy with delayed upload |
Mentioned within the last 28 days
|
1
Kamal Chandraprakash
|
0 | 0 | fu.jian | 11 weeks | info |
| 1240 | Additional group configurations for share groups |
Mentioned within the last 28 days
|
0 | 0 | 0 | Andrew Schofield | 11 weeks | info |
| 1239 | Batch offset translation in RemoteClusterUtils |
Mentioned within the last 84 days
|
0 | 0 | 0 | Mickael Maison | 11 weeks | info |
| 1238 | Multipartition for TopologyTestDriver in Kafka Streams |
Mentioned within the last 84 days
|
0 | 0 | 0 | Marie-Laure Momplot | 17 weeks | info |
| 1237 | Deprecate group.coordinator.rebalance.protocols config |
Mentioned within the last 84 days
|
4
David Jacot
Andrew Schofield Matthias J. Sax Chia-Ping Tsai |
0 | 0 | Ming-Yen Chung | 13 weeks | info |
| 1236 | Adjust quorum-related config lower bounds |
Mentioned within the last 84 days
|
0 | 0 | 0 | TaiJuWu | 13 weeks | info |
| 1234 | Move and Add Arguments to version-mapping Commands |
Mentioned within the last 84 days
|
0 | 0 | 0 | Chang-Yu Huang | 14 weeks | info |
| 1233 | Maximum lengths for resource names and IDs |
Mentioned within the last 84 days
|
0 | 0 | 0 | Andrew Schofield | 14 weeks | info |
| 1232 | Deprecate 'boker.id' |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ming-Yen Chung | 15 weeks | info |
| 1225 | Add Optional TTL Support to Kafka Streams State Stores |
Mentioned within the last 365 days
|
0 | 0 | 0 | Ankur Ankur | 17 weeks | info |
| 1223 | Add user tag to DeprecatedRequestsMetric |
Mentioned within the last 365 days
|
0 | 0 | 0 | Gaurav Narula | 18 weeks | info |
| 1220 | kafka-broker-api-versions tool support bootstrap controllers |
Mentioned within the last 84 days
|
0 | 0 | 0 | TaiJuWu | 19 weeks | info |
| 1218 | Expose consumer CorruptRecordException |
Mentioned within the last 365 days
|
0 | 0 | 0 | Uladzislau Blok | 21 weeks | info |
| 1214 | Change log.segment.bytes configuration type from int to long to support segments larger than 2GB |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mikhail Fesenko | 22 weeks | info |
| 1213 | Deprecated the configurations that provide the same functionality. |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jiunn Yang Huang | 22 weeks | info |
| 1210 | Disallow Configurations at the Broker Level |
Mentioned within the last 365 days
|
0 | 0 | 0 | Jhen-Yung Hsu | 24 weeks | info |
| 1209 | Add configuration to control internal topic creation in Kafka Connect |
Mentioned within the last 365 days
|
3
Anton Liauchuk
Chris Egerton Yash Mayya |
0 | 0 | Anton Liauchuk | 23 weeks | info |
| 1204 | MetadataQuorumCommand describe to include CommittedVoters |
Mentioned within the last 106751 days
|
0 | 0 | 0 | TaiJuWu | 25 weeks | info |
| 1203 | Allow to configure custom `ReplicaPlacer` implementation |
Mentioned within the last 84 days
|
0 | 0 | 0 | Jiunn Yang Huang | 26 weeks | info |
| 1202 | Align broker and controller "advertised.listeners" and "listeners" behaviour |
Mentioned within the last 365 days
|
0 | 0 | 0 | Jiunn Yang Huang | 29 weeks | info |
| 1201 | Add disk threshold strategy to prevent disk full failure |
Mentioned within the last 365 days
|
0 | 0 | 0 | mapan | 28 weeks | info |
| 1200 | Deprecate ClientQuotaCallback#updateClusterMetadata |
Mentioned within the last 365 days
|
1
Chia-Ping Tsai
|
0 | 0 | Kuan Po Tseng | 27 weeks | info |
| 1199 | Add max record count limit to FetchRequest |
Mentioned within the last 365 days
|
0 | 0 | 0 | Corki Tse | 27 weeks | info |
| 1194 | Optimize Replica Assignment for Broker Load Balance in Uneven Rack Configurations |
Mentioned within the last 365 days
|
0 | 0 | 0 | pengjialun | 29 weeks | info |
| 1191 | Dead-letter queues for share groups |
Mentioned within the last 28 days
|
0 | 0 | 0 | Andrew Schofield | 31 weeks | info |
| 1189 | Allow custom topic configurations for RemoteStorageManager |
Mentioned within the last 365 days
|
0 | 0 | 0 | Ivan Yurchenko | 31 weeks | info |
| 1187 | Support to retrieve remote log size via DescribeLogDirs RPC |
Mentioned within the last 84 days
|
1
Kamal Chandraprakash
|
0 | 0 | PoAn Yang | 33 weeks | info |
| 1184 | Add connector name and task index tags to MirrorMaker tasks' metrics |
Mentioned within the last 365 days
|
0 | 0 | 0 | Jhen-Yung Hsu | 37 weeks | info |
| 1183 | Unified Shared Storage |
Mentioned within the last 84 days
|
0 | 0 | 0 | Xinyu Zhou | 38 weeks | info |
| 1178 | Introduce remote.max.partition.fetch.bytes config in Consumer |
Mentioned within the last 365 days
|
0 | 0 | 0 | Kamal Chandraprakash | 39 weeks | info |
| 1177 | Consider renaming org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jiunn Yang Huang | 39 weeks | info |
| 1174 | Expose addReadOnlyStateStore in DSL (StreamsBuilder) |
Mentioned within the last 365 days
|
0 | 0 | 0 | Siddhartha Devineni | 40 weeks | info |
| 1173 | Connect Storage Topics Sharing Across Clusters |
Mentioned within the last 365 days
|
0 | 0 | 0 | Pritam Kumar Mishra | 40 weeks | info |
| 1171 | Majority replication and leader election |
Mentioned within the last 106751 days
|
0 | 0 | 0 | José Armando García Sancio | 41 weeks | info |
| 1164 | Diskless Coordinator |
Mentioned within the last 365 days
|
0 | 0 | 0 | Giuseppe Lillo | 42 weeks | info |
| 1163 | Diskless Core |
Mentioned within the last 365 days
|
0 | 0 | 0 | Ivan Yurchenko | 42 weeks | info |
| 1162 | Redesign ClientQuotaCallback#updateClusterMetadata |
Mentioned within the last 365 days
|
0 | 0 | 0 | Kuan Po Tseng | 42 weeks | info |
| 1161 | Unifying LIST-Type Configuration Validation and Default Values |
Mentioned within the last 84 days
|
3
Chia-Ping Tsai
TengYao Chi Chia-Ping Tsai |
0 | 0 | Jiunn Yang Huang | 42 weeks | info |
| 1159 | Large message reference based Serializer |
Mentioned within the last 365 days
|
0 | 0 | 0 | Omnia Ibrahim | 43 weeks | info |
| 1158 | Improve Connect SourceTask commit() |
Mentioned within the last 365 days
|
0 | 0 | 0 | Sudesh Wasnik | 43 weeks | info |
| 1156 | Define an official backward compatibility contract |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Matthias J. Sax | 43 weeks | info |
| 1155 | Metadata Version Downgrades |
Mentioned within the last 365 days
|
0 | 0 | 0 | Colin McCabe | 43 weeks | info |
| 1154 | Extending support for Microsecond/Nanosecond Precision for Kafka Connect |
Mentioned within the last 365 days
|
0 | 0 | 0 | Pritam Kumar Mishra | 43 weeks | info |
| 1151 | Minimal movement replica balancing algorithm for reassignment |
Mentioned within the last 365 days
|
0 | 0 | 0 | pengjialun | 45 weeks | info |
| 1150 | Diskless Topics |
Mentioned within the last 84 days
|
0 | 0 |
1
Colin McCabe
|
Josep Prat | 45 weeks | info |
| 1149 | Helm Chart for Apache Kafka |
Mentioned within the last 365 days
|
0 | 0 | 0 | Steve A | 45 weeks | info |
| 1145 | Kafka Streams `CloseOptions` should not have a public constructor |
Mentioned within the last 106751 days
|
0 | 0 | 0 | TengYao Chi | 47 weeks | info |
| 1144 | Exposing a new public REST API for MirrorMaker 2 |
Mentioned within the last 365 days
|
0 | 0 | 0 | Bertlan Kondrat | 47 weeks | info |
| 1141 | Simplifying Add/Remove Voter in MetadataQuorumCommand |
Mentioned within the last 365 days
|
0 | 0 | 0 | Kuan Po Tseng | 47 weeks | info |
| 1137 | Standardize Configuration Precedence for Tool Scripts |
Mentioned within the last 365 days
|
0 | 0 | 0 | Jhen-Yung Hsu | 49 weeks | info |
| 1134 | Multi-tenancy in Kafka: Virtual Clusters |
Mentioned within the last 365 days
|
0 | 0 | 0 | Viktor Somogyi | 51 weeks | info |
| 1130 | Add metrics indicating the connection count exceeds |
Mentioned within the last 365 days
|
0 | 0 | 0 | TengYao Chi | 1 years 1 weeks | info |
| 1129 | Update ConfigException constructors |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Gaurav Narula | 1 years 1 weeks | info |
| 1128 | Replace KTable.transformValues with KTable.processValues and add new KStreams.process |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Matthias J. Sax | 1 years 2 weeks | info |
| 1127 | Flexible Windows for Late Arriving Data |
Mentioned within the last 365 days
|
3
Lucas Brutschy
Matthias J. Sax Sophie Blee-Goldman |
0 | 0 | Almog Gavra | 1 years 2 weeks | info |
| 1122 | Create a dedicated data module for Kafka Connect data classes |
Mentioned within the last 365 days
|
0 | 0 | 0 | Mario Fiore Vitale | 1 years 7 weeks | info |
| 1121 | Compression acceleration in Kafka |
Mentioned within the last 365 days
|
0 | 0 | 0 | Olasoji Denloye | 1 years 7 weeks | info |
| 1120 | AppInfo metrics don't contain the client-id |
Mentioned within the last 365 days
|
3
TengYao Chi
PoAn Yang Chia-Ping Tsai |
0 | 0 | Jiunn Yang Huang | 1 years 8 weeks | info |
| 1119 | Add support for SSL auto reload |
Mentioned within the last 365 days
|
0 | 0 | 0 | Moncef Abboud | 1 years 9 weeks | info |
| 1115 | Bazel Builds |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Vince Rose | 1 years 11 weeks | info |
| 1114 | Introducing Chunk in Partition |
Mentioned within the last 365 days
|
0 | 0 | 0 | De Gao | 1 years 11 weeks | info |
| 1113 | Enhancements to Rack-Aware Partition Assignor for Improved Client-Side Independence and Load Balancing |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jerry Cai | 1 years 11 weeks | info |
| 1110 | Metadata of sensitive configuration |
Mentioned within the last 365 days
|
0 | 0 | 0 | Luke Chen | 1 years 12 weeks | info |
| 1108 | Publish metrics for skipped records in Kafka Connect |
Mentioned within the last 365 days
|
0 | 0 | 0 | Hector Geraldino | 1 years 13 weeks | info |
| 1107 | Adding topic-level acks and compressions for producers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | TaiJuWu | 1 years 13 weeks | info |
| 1098 | Reverse Checkpointing in MirrorMaker |
Mentioned within the last 365 days
|
1
Viktor Somogyi-Vass
|
0 | 0 | Daniel Urban | 1 years 16 weeks | info |
| 1097 | Add Kafka Connect exception handler |
Mentioned within the last 365 days
|
0 | 0 | 0 | Anton Liauchuk | 1 years 17 weeks | info |
| 1096 | Add ability to pass headers to ProducerPerformance |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Max | 1 years 17 weeks | info |
| 1095 | Kafka Canary Isolation |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Zhifeng Chen | 1 years 20 weeks | info |
| 1093 | Add more observability for MirrorMaker2 |
Mentioned within the last 106751 days
|
0 | 0 | 0 | PoAn Yang | 1 years 20 weeks | info |
| 1091 | Improved Kafka Streams operator metrics |
Mentioned within the last 84 days
|
3
Lucas Brutschy
Matthias J. Sax Sophie Blee-Goldman |
0 | 0 | Bill Bejeck | 1 years 20 weeks | info |
| 1088 | Replace KafkaClientSupplier with KafkaClientInterceptor |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Matthias J. Sax | 1 years 22 weeks | info |
| 1086 | Add ability to specify a custom produce request parser. |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Max | 1 years 23 weeks | info |
| 1083 | Increase default value of task.shutdown.graceful.timeout.ms in Connect |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sagar Rao | 1 years 25 weeks | info |
| 1081 | Graduation Steps for KIPs |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Josep Prat | 1 years 25 weeks | info |
| 1072 | Add @FunctionalInterface annotation to Kafka Streams SAM methods |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Bill Bejeck | 1 years 29 weeks | info |
| 1067 | Remove ReplicaVerificationTool in 5.0 (deprecate in 3.9) |
Mentioned within the last 106751 days
|
2
Luke Chen
Justine Olshan |
0 | 0 | Dongjin Lee | 1 years 30 weeks | info |
| 1064 | Upgrade slf4j to 2.x |
Mentioned within the last 365 days
|
1
Chia-Ping Tsai
|
0 | 0 | Muralidhar Basani | 1 years 32 weeks | info |
| 1063 | Drop inconsistent casing in Selector metrics tags |
Mentioned within the last 106751 days
|
0 | 0 | 0 | PoAn Yang | 1 years 32 weeks | info |
| 1062 | Introduce Pagination for some requests used by Admin API |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Omnia Ibrahim | 1 years 32 weeks | info |
| 1061 | Allow exporting SCRAM credentials |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Gaurav Narula | 1 years 32 weeks | info |
| 1059 | Enable Producer to resolve send() method errors |
Mentioned within the last 106751 days
|
1
Matthias J. Sax
|
0 | 0 | Alieh Saeedi | 1 years 33 weeks | info |
| 1055 | Introducing Round-Robin Assignment Strategy to ConnectorUtils |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Fan Yang | 1 years 34 weeks | info |
| 1051 | Statically configured log replication throttling |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Harry Fallows | 1 years 35 weeks | info |
| 1048 | Improve kafka-consumer-perf-test to benchmark single partition |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Harsh Panchal | 1 years 37 weeks | info |
| 1046 | Expose producer.id.expiration.check.interval.ms as dynamic broker configuration |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jorge Esteban Quilcate Otoya | 1 years 38 weeks | info |
| 1045 | Move MockAdminClient to public api |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Muralidhar Basani | 1 years 38 weeks | info |
| 1044 | A proposal to change idempotent producer -- server implementation |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Claude Warren | 1 years 38 weeks | info |
| 1042 | Implementation of a GLOB Pattern type for ACL pattern matching. |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Muralidhar Basani | 1 years 40 weeks | info |
| 1039 | Disable automatic topic creation for MirrorMaker2 consumers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Yangkun Ai | 1 years 42 weeks | info |
| 1038 | Add Custom Error Handler to Producer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Alieh Saeedi | 1 years 42 weeks | info |
| 1027 | Add MockFixedKeyProcessorContext and TestFixedKeyRecordFactory |
Mentioned within the last 365 days
|
0 | 0 | 0 | Matthias J. Sax | 1 years 47 weeks | info |
| 1026 | Handling producer snapshot when upgrading from < v2.8.0 for Tiered Storage |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Divij Vaidya | 1 years 48 weeks | info |
| 1024 | Make the restore behavior of GlobalKTables with custom processors configureable |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Walker Carlson | 1 years 49 weeks | info |
| 1021 | Allow to get last stable offset (LSO) in kafka-get-offsets.sh |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ahmed Sobeh | 1 years 49 weeks | info |
| 1016 | Make MM2 heartbeats topic name configurable |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Bertlan Kondrat | 2 years 3 weeks | info |
| 1015 | Limit number of ssl connections in brokers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jimmy Wang | 2 years 4 weeks | info |
| 1014 | Managing Unstable Features in Apache Kafka |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Proven Provenzano | 2 years 5 weeks | info |
| 1010 | Topic Partition Quota |
Mentioned within the last 365 days
|
0 | 0 | 0 | Afshin Moazami | 2 years 8 weeks | info |
| 1009 | Add Broker-level Throttle Configurations |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ria Pradeep | 2 years 11 weeks | info |
| 1008 | ParKa - the Marriage of Parquet and Kafka |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Xinli Shang | 2 years 11 weeks | info |
| 1006 | Remove SecurityManager Support |
Mentioned within the last 106751 days
|
1
Luke Chen
|
0 | 0 | Greg Harris | 2 years 11 weeks | info |
| 1003 | Signal next segment when remote fetching |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jorge Esteban Quilcate Otoya | 2 years 13 weeks | info |
| 1002 | Fetch remote segment indexes at once |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jorge Esteban Quilcate Otoya | 2 years 13 weeks | info |
| 998 | Give ProducerConfig(props, doLog) constructor protected access |
Mentioned within the last 106751 days
|
3
Bruno Cadonna
Chris Egerton Matthias J. Sax |
0 | 0 | A. Sophie Blee-Goldman | 2 years 14 weeks | info |
| 997 | update WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery |
Mentioned within the last 365 days
|
3
Vahid Hashemian
Satish Duggana Divij Vaidya |
0 | 0 | Pengcheng Zheng | 2 years 14 weeks | info |
| 991 | Allow DropHeaders SMT to drop headers by wildcard/regexp |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Roman Schmitz | 2 years 16 weeks | info |
| 990 | Capability to PAUSE Tasks on DeserializationException |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nicholas Telford | 2 years 17 weeks | info |
| 987 | Connect Static Assignments |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Greg Harris | 2 years 18 weeks | info |
| 986 | Cross-Cluster Replication |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Greg Harris | 2 years 18 weeks | info |
| 984 | Add pluggable compression interface to Kafka |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Assane Diop | 2 years 18 weeks | info |
| 983 | Full speed async processing during rebalance |
Mentioned within the last 365 days
|
0 | 0 | 0 | Erik van Oosten | 2 years 19 weeks | info |
| 982 | Access SslPrincipalMapper and kerberosShortNamer in Custom KafkaPrincipalBuilder |
Mentioned within the last 106751 days
|
1
Manikumar
|
0 | 0 | Raghu Baddam | 2 years 20 weeks | info |
| 981 | Manage Connect topics with custom implementation of Admin |
Mentioned within the last 106751 days
|
1
Mickael Maison
|
0 | 0 | Omnia Ibrahim | 2 years 20 weeks | info |
| 973 | Expose per topic replication rate metrics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nelson B. | 2 years 23 weeks | info |
| 972 | Add the metric of the current running version of kafka |
Mentioned within the last 106751 days
|
0 | 0 | 0 | hudeqi | 2 years 23 weeks | info |
| 969 | Support range interactive queries (IQv2) for versioned state stores |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Alieh Saeedi | 2 years 25 weeks | info |
| 967 | Support custom SSL configuration for Kafka Connect RestServer |
Mentioned within the last 106751 days
|
1
Greg Harris
|
0 | 0 | Taras Ledkov | 2 years 26 weeks | info |
| 965 | Support disaster recovery between clusters by MirrorMaker |
Mentioned within the last 106751 days
|
0 | 0 | 0 | hudeqi | 2 years 26 weeks | info |
| 964 | Have visibility when produce requests become "async" |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sergio Troiano | 2 years 26 weeks | info |
| 958 | Tiered Storage Metrics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Abhijeet Kumar | 2 years 28 weeks | info |
| 953 | partition method to be overloaded to accept headers as well. |
Mentioned within the last 106751 days
|
1
Chris Egerton
|
0 | 0 | Jacob Tomy | 2 years 29 weeks | info |
| 952 | Regenerate segment-aligned producer snapshots when upgrading to a Kafka version supporting Tiered Storage |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Christo Lolov | 2 years 30 weeks | info |
| 948 | Allow custom prefix for internal topic names in Kafka Streams |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Igor Buzatović | 2 years 31 weeks | info |
| 945 | Update threading model for Consumer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Kirk True | 2 years 32 weeks | info |
| 943 | Add independent “offset.storage.segment.bytes” for connect-distributed.properties |
Mentioned within the last 106751 days
|
0 | 0 | 0 | hudeqi | 2 years 32 weeks | info |
| 940 | Broker extension point for validating record contents at produce time |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Edoardo Comar | 2 years 35 weeks | info |
| 936 | Throttle number of active PIDs |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Omnia Ibrahim | 2 years 37 weeks | info |
| 935 | Extend AlterConfigPolicy with existing configurations |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jorge Esteban Quilcate Otoya | 2 years 38 weeks | info |
| 934 | Add DeleteTopicPolicy |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jorge Esteban Quilcate Otoya | 2 years 38 weeks | info |
| 933 | Publish metrics when source connector fails to poll data |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ravindranath | 2 years 37 weeks | info |
| 928 | Making Kafka resilient to log directories becoming full |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Christo Lolov | 2 years 39 weeks | info |
| 922 | Add the traffic metric of the partition dimension |
Mentioned within the last 106751 days
|
0 | 0 | 0 | hudeqi | 2 years 41 weeks | info |
| 921 | OpenJDK CRaC support |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Radim Vansa | 2 years 42 weeks | info |
| 920 | Support upgrading KRaft MetadataVersion based on a static config |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Colin McCabe | 2 years 42 weeks | info |
| 918 | MM2 Topic And Group Listener |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Daniel Urban | 2 years 43 weeks | info |
| 916 | MM2 distributed mode flow log context |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Daniel Urban | 2 years 45 weeks | info |
| 913 | add new method to provide possibility for accelerate first record's sending |
Mentioned within the last 106751 days
|
0 | 0 | 0 | fu.jian | 2 years 48 weeks | info |
| 912 | Support decreasing send's max block time without worrying about metadata's fetch |
Mentioned within the last 106751 days
|
0 | 0 | 0 | fu.jian | 2 years 48 weeks | info |
| 910 | Update Source offsets for Source Connectors without producing records |
Mentioned within the last 106751 days
|
1
Yash Mayya
|
0 | 0 | Sagar Rao | 2 years 50 weeks | info |
| 905 | Broker interceptors |
Mentioned within the last 106751 days
|
0 | 0 | 0 | David Mariassy | 2 years 52 weeks | info |
| 901 | Add connectorDeleted flag when stopping tasks |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Hector Geraldino | 3 years 2 weeks | info |
| 895 | Dynamically refresh partition count of __consumer_offsets |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Christo Lolov | 3 years 6 weeks | info |
| 888 | Batch describe ACLs and describe client quotas |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mickael Maison | 3 years 12 weeks | info |
| 886 | Add Client Producer and Consumer Builders |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Daniel Scanteianu | 3 years 13 weeks | info |
| 885 | Expose Broker's Name and Version to Clients |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Travis Bischel | 3 years 13 weeks | info |
| 883 | Add isDeleted flag when stopping a connector |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Hector Geraldino | 3 years 14 weeks | info |
| 882 | Kafka Connect REST API configuration validation timeout improvements |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Yash Mayya | 3 years 15 weeks | info |
| 880 | X509 SAN based SPIFFE URI ACL within mTLS Client Certificates |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Bart Van Bos | 3 years 14 weeks | info |
| 879 | Multi-level Rack Awareness |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Viktor Somogyi | 3 years 18 weeks | info |
| 874 | TopicRoundRobinAssignor |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mathieu Amblard | 3 years 18 weeks | info |
| 873 | ExceptionHandlingDeserializer, RetryDeserializer, PipeSerializer, PipeDeserializer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Alex Collins | 3 years 19 weeks | info |
| 870 | Retention policy based on record event time |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nikolay Izhikov | 3 years 20 weeks | info |
| 864 | Add End-To-End Latency Metrics to Connectors |
Mentioned within the last 106751 days
|
2
Mickael Maison
Chris Egerton |
0 | 0 | Jorge Esteban Quilcate Otoya | 3 years 23 weeks | info |
| 861 | Add BytesIn/BytesOut per listener metrics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Luke Chen | 3 years 27 weeks | info |
| 857 | Streaming recursion in Kafka Streams |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nicholas Telford | 3 years 28 weeks | info |
| 855 | Add schema.namespace parameter to SetSchemaMetadata SMT in Kafka Connect |
Mentioned within the last 106751 days
|
1
Mickael Maison
|
0 | 0 | Michael Negodaev | 3 years 29 weeks | info |
| 849 | Expose logdirs total and usable space via kafka-log-dirs.sh |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Deng Ziming | 3 years 33 weeks | info |
| 842 | Add richer group offset reset mechanisms |
Mentioned within the last 106751 days
|
0 | 0 | 0 | hudeqi | 3 years 37 weeks | info |
| 839 | Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Francois Rosiere | 3 years 38 weeks | info |
| 832 | Allow creating a producer/consumer using a producer/consumer config |
Mentioned within the last 106751 days
|
3
Bruno Cadonna
Bill Bejeck John Roesler |
0 | 0 | Francois Rosiere | 3 years 40 weeks | info |
| 829 | (console-consumer) add print.topic property |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Evans Jahja | 3 years 43 weeks | info |
| 828 | Add the corresponding validator to the configuration where the validator is missing |
Mentioned within the last 106751 days
|
0 | 0 | 0 | RivenSun | 3 years 44 weeks | info |
| 826 | Define platforms supported |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mickael Maison | 3 years 45 weeks | info |
| 823 | Update Admin::describeConfigs to allow fetching specific configurations |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Vikas Singh | 3 years 50 weeks | info |
| 822 | Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols |
Mentioned within the last 106751 days
|
0 | 0 | 0 | RivenSun | 3 years 51 weeks | info |
| 821 | Connect Transforms support for nested structures |
Mentioned within the last 106751 days
|
4
Mickael Maison
Bill Bejeck John Roesler Chris Egerton |
0 | 0 | Jorge Esteban Quilcate Otoya | 3 years 0 weeks | info |
| 819 | Merge multiple KStreams in one operation |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nicholas Telford | 4 years 1 weeks | info |
| 818 | Introduce cache-size-bytes-total Task Level Metric |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sagar Rao | 4 years 1 weeks | info |
| 817 | Fix inconsistency in dynamic application log levels |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dongjin Lee | 4 years 2 weeks | info |
| 816 | Topology changes without local state reset |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nicholas Telford | 4 years 2 weeks | info |
| 809 | Support live upgrades with dynamic addition/removal of modular topologies |
Mentioned within the last 106751 days
|
0 | 0 | 0 | A. Sophie Blee-Goldman | 4 years 8 weeks | info |
| 807 | Refactor KafkaStreams exposed metadata hierarchy |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Josep Prat | 4 years 10 weeks | info |
| 804 | OfflinePartitionsCount Tagged by Topic |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mason Joseph Legere | 4 years 11 weeks | info |
| 803 | Add Task ID and Connector Name to Connect Task Context |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sarah Story | 4 years 11 weeks | info |
| 802 | Validation Support for Kafka Connect SMT and Converter Options |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Gunnar Morling | 4 years 11 weeks | info |
| 799 | Align behaviour for producer callbacks with documented behaviour |
Mentioned within the last 106751 days
|
2
Mickael Maison
John Roesler |
0 | 0 | Seamus O Ceanainn | 4 years 13 weeks | info |
| 786 | Emit Metric Client Quota Values |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mason Joseph Legere | 4 years 16 weeks | info |
| 785 | Automatic storage formatting |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Igor Soarez | 4 years 16 weeks | info |
| 782 | Expandable batch size in producer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Luke Chen | 4 years 16 weeks | info |
| 781 | Improve MirrorMaker2's client configuration |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dongjin Lee | 4 years 17 weeks | info |
| 780 | Support fine-grained compression options |
Mentioned within the last 365 days
|
0 | 0 | 0 | Dongjin Lee | 4 years 17 weeks | info |
| 777 | Improved testability for Admin client |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 4 years 20 weeks | info |
| 776 | Add Consumer#peek for debugging/tuning |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Luke Chen | 4 years 20 weeks | info |
| 774 | Deprecate public access to Admin client's *Result constructors |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 4 years 22 weeks | info |
| 772 | Encrypt KRaft Metadata Secrets at Rest |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Colin McCabe | 4 years 23 weeks | info |
| 767 | Connect Latency Metrics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jordan Bull | 4 years 26 weeks | info |
| 765 | Introduce new SlidingWindow type for [start,end] time |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Luke Chen | 4 years 29 weeks | info |
| 762 | Delete Committed Connect Records |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ryanne Dolan | 4 years 30 weeks | info |
| 760 | Minimum value for segment.ms and segment.bytes |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Badai Aqrandista | 4 years 31 weeks | info |
| 758 | Remove list of latest producer append information for broker |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Yi Ding | 4 years 33 weeks | info |
| 755 | Add new AUTO_CREATE ACL for auto topic creation |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Christopher L. Shannon | 4 years 35 weeks | info |
| 754 | Make Scala case class's final |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Matthew de Detrich | 4 years 35 weeks | info |
| 753 | ACL authentication, Host field support IP network segment |
Mentioned within the last 106751 days
|
0 | 0 | 0 | loboxu | 4 years 35 weeks | info |
| 749 | Add --files and --file-separator options to the ConsoleProducer |
Mentioned within the last 106751 days
|
1
Boyang Chen
|
0 | 0 | Wenbing Shen | 4 years 36 weeks | info |
| 743 | Remove config value 0.10.0-2.4 of Streams built-in metrics version config |
Mentioned within the last 106751 days
|
2
Sophie Blee-Goldman
John Roesler |
0 | 0 | Bruno Cadonna | 4 years 38 weeks | info |
| 739 | Block Less on KafkaProducer#send |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Moses Nakamura | 4 years 39 weeks | info |
| 737 | Add canTrackSource to ReplicationPolicy |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Matthew de Detrich | 4 years 39 weeks | info |
| 736 | Report the true end to end fetch latency |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ming Liu | 4 years 41 weeks | info |
| 731 | Record Rate Limiting for Kafka Connect |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ryanne Dolan | 4 years 44 weeks | info |
| 729 | Custom validation of records on the broker prior to log append |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Soumyajit Sahu | 4 years 45 weeks | info |
| 728 | Introduce the RESTORING state to the KafkaStreams state machine |
Mentioned within the last 106751 days
|
0 | 0 | 0 | A. Sophie Blee-Goldman | 4 years 45 weeks | info |
| 727 | Add --under-preferred-replica-partitions option to describe topics command |
Mentioned within the last 106751 days
|
1
Tom Bentley
|
0 | 0 | Wenbing Shen | 4 years 46 weeks | info |
| 723 | Add socket.tcp.no.delay property to Kafka Config |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Andrei Iatsuk | 4 years 47 weeks | info |
| 718 | Make KTable Join on Foreign key unopinionated |
Mentioned within the last 106751 days
|
1
John Roesler
|
0 | 0 | Marco Lotz | 4 years 49 weeks | info |
| 713 | Validation of Enums in configuration |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jeremy Custenborder | 4 years 1 weeks | info |
| 712 | Shallow Mirroring |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Henry Cai | 4 years 1 weeks | info |
| 706 | Add method "Producer#send" to return CompletionStage instead of Future |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ismael Juma | 7 years 3 weeks | info |
| 705 | Selectively Disable Topology Optimizations |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Almog Gavra | 5 years 4 weeks | info |
| 703 | Add a metrics for reporting idle connections closed |
Mentioned within the last 84 days
|
0 | 0 | 0 | Pere Urbon | 5 years 5 weeks | info |
| 702 | The control plane needs to force the validation of requests from the controller |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Wenbing Shen | 5 years 5 weeks | info |
| 701 | Add--override option to bin/connect-distributed.sh |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Akitoshi Yoshida | 5 years 7 weeks | info |
| 697 | Stricter parsing of addresses in configs |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 5 years 9 weeks | info |
| 694 | Support Reducing Partitions for Topics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | George Shu | 5 years 10 weeks | info |
| 693 | Client-side Circuit Breaker for Partition Write Errors |
Mentioned within the last 106751 days
|
0 | 0 | 0 | George Shu | 5 years 10 weeks | info |
| 692 | Make AdminClient value object constructors public |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Noa Resare | 5 years 10 weeks | info |
| 688 | Support dynamic update of delete.topic.enable config |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Prateek Agarwal | 5 years 11 weeks | info |
| 686 | API to ensure Records policy on the broker |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nikolay Izhikov | 5 years 12 weeks | info |
| 685 | Loosen permission for listing reassignments |
Mentioned within the last 106751 days
|
0 | 0 | 0 | David Jacot | 5 years 13 weeks | info |
| 683 | Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSON string |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Joshua Grisham | 5 years 13 weeks | info |
| 682 | Connect TimestampConverter support for multiple fields and multiple input formats |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Joshua Grisham | 5 years 14 weeks | info |
| 681 | Rename master key in delegation token feature |
Mentioned within the last 106751 days
|
2
Manikumar
Mickael Maison |
0 | 0 | Tom Bentley | 5 years 14 weeks | info |
| 678 | New Kafka Connect SMT for plainText => Struct(or Map) with Regex |
Mentioned within the last 106751 days
|
1
Chris Egerton
|
0 | 0 | whsoul82 | 5 years 16 weeks | info |
| 674 | Metric Reporter to Aggregate Metrics in Kafka Streams |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Bruno Cadonna | 5 years 19 weeks | info |
| 672 | Introduce Kafka Streams Specific Uncaught Exception Handler |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Walker Carlson | 5 years 21 weeks | info |
| 670 | Add ConsumerGroupCommand to delete static members |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sandeep Kumar | 5 years 23 weeks | info |
| 669 | Preserve Source Partition in Kafka Streams from context |
Mentioned within the last 106751 days
|
0 | 0 | 0 | satya k | 5 years 23 weeks | info |
| 668 | Expose REST endpoint to list converter plugins |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Rupesh Kumar Patel | 5 years 23 weeks | info |
| 665 | Kafka Connect Hash SMT |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Brandon Brown | 5 years 24 weeks | info |
| 658 | [DISCARD] KIP-658 Deprecate all setters of Headers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Chia-Ping Tsai | 5 years 25 weeks | info |
| 657 | Add Customized Kafka Streams Logo |
Mentioned within the last 106751 days
|
1
Bill Bejeck
|
0 | 0 | Boyang Chen | 5 years 26 weeks | info |
| 656 | MirrorMaker2 Exactly-once Semantics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ning Zhang | 5 years 27 weeks | info |
| 655 | Windowed Distinct Operation for Kafka Streams API |
Mentioned within the last 106751 days
|
3
Bill Bejeck
Lucas Brutschy Matthias J. Sax |
0 | 0 | Ivan Ponomarev | 5 years 27 weeks | info |
| 650 | Enhance Kafkaesque Raft semantics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Boyang Chen | 5 years 28 weeks | info |
| 649 | Dynamic Client Configuration |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ryan Dielhenn | 5 years 28 weeks | info |
| 647 | Add ability to handle late messages in streams-aggregation |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Igor Piddubnyi | 5 years 29 weeks | info |
| 646 | Serializer API should support ByteBuffer |
Mentioned within the last 365 days
|
0 | 0 | 0 | Chia-Ping Tsai | 5 years 29 weeks | info |
| 644 | Support sources which can't give out changed data in kafka connect |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Nikhil Kumar | 5 years 30 weeks | info |
| 640 | Add log compression analysis tool |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Christopher Beard | 5 years 33 weeks | info |
| 639 | Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | mohamed chebbi | 5 years 31 weeks | info |
| 637 | Include min.insync.replicas in MetadataResponse to make Producer smarter in partitioning events |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Arvin Zheng | 5 years 32 weeks | info |
| 636 | Make RPC error codes and messages tagged fields |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 5 years 32 weeks | info |
| 631 | The Quorum-based Kafka Controller |
Mentioned within the last 106751 days
|
3
Ismael Juma
Boyang Chen David Jacot |
0 | 0 | Colin McCabe | 5 years 33 weeks | info |
| 628 | ConsumerPerformance's multi-thread implementation |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jiamei.xie | 5 years 34 weeks | info |
| 625 | Richer encodings for integral-typed protocol fields |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 5 years 34 weeks | info |
| 624 | Consolidate Offset Validation into Fetch Protocol |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Boyang Chen | 5 years 34 weeks | info |
| 619 | Add internal topic creation support |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Cheng Tan | 5 years 37 weeks | info |
| 609 | Use Pre-registration and Blocking Calls for Better Transaction Efficiency |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Boyang Chen | 5 years 40 weeks | info |
| 603 | Change `ConfigEntry` value to use optional fields |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Wang Ge | 5 years 41 weeks | info |
| 598 | Augment TopologyDescription with store and source / sink serde information |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Guozhang Wang | 5 years 42 weeks | info |
| 596 | Safely abort Producer transactions during application shutdown |
Mentioned within the last 106751 days
|
2
Matthias J. Sax
John Roesler |
0 | 0 | Xiang Zhang | 5 years 43 weeks | info |
| 592 | MirrorMaker 1.0 should replicate topics from earliest |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jeff Widman | 5 years 43 weeks | info |
| 587 | Suppress detailed responses for handled exceptions in security-sensitive environments |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Connor Penhale | 5 years 45 weeks | info |
| 583 | add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on the same broker |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Chia-Ping Tsai | 5 years 47 weeks | info |
| 582 | Add a "continue" option for Kafka Connect error handling |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Zihan Li | 5 years 47 weeks | info |
| 579 | new exception on min.insync.replicas > replication.factor |
Mentioned within the last 106751 days
|
1
M. Manna
|
0 | 0 | Paolo Moriello | 5 years 48 weeks | info |
| 578 | Add configuration to limit number of partitions |
Mentioned within the last 106751 days
|
2
Harsha Chintalapani
Harsha Ch |
0 | 0 | Gokul Ramanan Subramanian | 5 years 48 weeks | info |
| 576 | Support dynamic update of more broker configs related to replication |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Cheng Tan | 5 years 48 weeks | info |
| 575 | build a Kafka-Exporter by Java |
Mentioned within the last 106751 days
|
0 | 0 | 0 | francis lee | 5 years 49 weeks | info |
| 568 | Support RPC message type 'double' |
Mentioned within the last 106751 days
|
4
Guozhang Wang
Bill Bejeck John Roesler Navinder Brar |
0 | 0 | Brian Byrne | 6 years 3 weeks | info |
| 567 | Kafka Cluster Audit |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Igor Martemyanov | 6 years 3 weeks | info |
| 566 | Add rebalance callbacks to ConsumerInterceptor |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tommy Becker | 6 years 3 weeks | info |
| 563 | Add 'tail -n' feature for ConsoleConsumer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | huxihx | 6 years 3 weeks | info |
| 561 | Regex Support for ConsumerGroupCommand |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Alex Dunayevsky | 6 years 7 weeks | info |
| 560 | Auto infer external topic partitions in stream reset tool |
Mentioned within the last 106751 days
|
0 | 0 | 0 | high.lee | 6 years 4 weeks | info |
| 550 | Mechanism to Delete Stray Partitions on Broker |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dhruvil Shah | 6 years 9 weeks | info |
| 549 | Surface Consumer's Metadata in KafkaAdminClient#describeConsumerGroups |
Mentioned within the last 106751 days
|
0 | 0 | 0 | David Jacot | 6 years 11 weeks | info |
| 548 | Add Option to enforce rack-aware custom partition reassignment execution |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Satish Bellapu | 6 years 12 weeks | info |
| 547 | Extend ConsumerInterceptor to allow modification of Consumer Commits |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Eric Azama | 6 years 12 weeks | info |
| 542 | Partition Reassignment Throttling |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Viktor Somogyi | 6 years 16 weeks | info |
| 540 | Implement per key stream time tracking |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Richard Yu | 6 years 16 weeks | info |
| 539 | Implement mechanism to flush out records in low traffic suppression buffers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Richard Yu | 6 years 17 weeks | info |
| 536 | Propagate broker start time to Admin API |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Noa Resare | 6 years 17 weeks | info |
| 532 | Broker Consumer Lag metrics in size and time |
Mentioned within the last 106751 days
|
0 | 0 | 0 | NIKHIL BHATIA | 6 years 24 weeks | info |
| 526 | Reduce Producer Metadata Lookups for Large Number of Topics |
Mentioned within the last 106751 days
|
1
Rajini Sivaram
|
0 | 0 | Brian Byrne | 6 years 21 weeks | info |
| 514 | Add a bounded flush() API to Kafka Producer |
Mentioned within the last 106751 days
|
1
Harsha Chintalapani
|
0 | 0 | kun du | 6 years 24 weeks | info |
| 513 | Distinguish between Key and Value serdes in scala wrapper library for kafka streams |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mykhailo Yeromenko | 6 years 25 weeks | info |
| 510 | Metrics library upgrade |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mario Molina | 6 years 25 weeks | info |
| 509 | Rebalance and restart Producers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Werner Dähn | 6 years 25 weeks | info |
| 508 | Make Suppression State Queriable |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dongjin Lee | 6 years 26 weeks | info |
| 506 | Allow setting SCRAM password via Admin interface |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 6 years 27 weeks | info |
| 505 | Add new public method to only update assignment metadata in consumer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jungtaek Lim | 6 years 27 weeks | info |
| 503 | Add metric for number of topics marked for deletion |
Mentioned within the last 106751 days
|
3
Manikumar
Harsha Chintalapani Gwen Shapira |
0 | 0 | David Arthur | 6 years 27 weeks | info |
| 502 | Connect Task Method Signature to be More Specific for Developers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Cyrus Vafadari | 6 years 27 weeks | info |
| 501 | Avoid out-of-sync or offline partitions when follower fetch requests are not processed in time |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Satish Duggana | 6 years 28 weeks | info |
| 498 | Add client-side configuration for maximum response size to protect against OOM |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Alexandre Dupriez | 6 years 28 weeks | info |
| 494 | Connect REST Endpoint to get Transformations (SMTs) |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Cyrus Vafadari | 6 years 29 weeks | info |
| 491 | Preferred Leader Deprioritized List (Temporary Blacklist) |
Mentioned within the last 106751 days
|
0 | 0 | 0 | George Li | 6 years 30 weeks | info |
| 490 | New metric to count offsets expired without being consumed by a consumer group |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jose Morales Aragon | 6 years 31 weeks | info |
| 487 | Client-side Automatic Topic Creation on Producer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Justine Olshan | 6 years 31 weeks | info |
| 483 | Add Broker Version API in Admin Client |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Boyang Chen | 6 years 33 weeks | info |
| 473 | Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ryan Pridgeon | 6 years 38 weeks | info |
| 469 | Pre-registration support for static members |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Boyang Chen | 6 years 39 weeks | info |
| 468 | Avoid decompression of record when validate record at server in the scene of inPlaceAssignment . |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Flowermin | 6 years 39 weeks | info |
| 463 | Auto-configure non-default Serdes passed alongside the TopologyBuilder |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Richard Yu | 6 years 42 weeks | info |
| 459 | Improve KafkaStreams#close |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dongjin Lee | 6 years 42 weeks | info |
| 457 | Add DISCONNECTED status to Kafka Streams |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Richard Yu | 6 years 43 weeks | info |
| 452 | Tool to view cluster status |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Łukasz Antoniak | 6 years 44 weeks | info |
| 448 | Add State Stores Unit Test Support to Kafka Streams Test Utils |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Yishun Guan | 6 years 45 weeks | info |
| 439 | Cleanup built-in Store interfaces |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Matthias J. Sax | 6 years 48 weeks | info |
| 438 | Expose task, connector IDs in Connect API |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ryanne Dolan | 6 years 49 weeks | info |
| 435 | Internal Partition Reassignment Batching |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Viktor Somogyi | 6 years 51 weeks | info |
| 433 | Block old clients on brokers |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ying Zheng | 6 years 51 weeks | info |
| 426 | Persist Broker Id to Zookeeper |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Kan Li | 7 years 1 weeks | info |
| 424 | Allow suppression of intermediate events based on wall clock time |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jonathan Gordon | 7 years 3 weeks | info |
| 423 | Add JoinReason to Consumer Join Group Protocol |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Boyang Chen | 7 years 2 weeks | info |
| 419 | Safely notify Kafka Connect SourceTask is stopped |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Andrew Schofield | 7 years 4 weeks | info |
| 410 | Add metric for request handler thread pool utilization by request type |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mayuresh Gharat | 7 years 8 weeks | info |
| 409 | Allow creating under-replicated topics and partitions |
Mentioned within the last 106751 days
|
1
M. Manna
|
0 | 0 | Mickael Maison | 7 years 8 weeks | info |
| 408 | Add Asynchronous Processing To Kafka Streams |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Richard Yu | 7 years 8 weeks | info |
| 406 | GlobalStreamThread should honor custom reset policy |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Richard Yu | 7 years 8 weeks | info |
| 403 | Increase ProducerPerformance precision by using nanoTime |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Kevin Lu | 7 years 9 weeks | info |
| 400 | Improve exit status in case of errors in ConsoleProducer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Kamal Kang | 7 years 13 weeks | info |
| 398 | Support reading trust store from classpath |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Noa Resare | 7 years 11 weeks | info |
| 397 | Add methods to override fetch offsets based on timestamp |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Brandon Kirchner | 7 years 11 weeks | info |
| 395 | Encypt-then-MAC Delegation token metadata |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Attila Sasvári | 7 years 11 weeks | info |
| 388 | Add observer interface to record request and response |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Lincong Li | 7 years 14 weeks | info |
| 387 | Fair Message Consumption Across Partitions in KafkaConsumer |
Mentioned within the last 106751 days
|
0 | 0 | 0 | CHIENHSING WU | 7 years 14 weeks | info |
| 385 | Avoid throwing away prefetched data |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Zahari Dichev | 7 years 16 weeks | info |
| 384 | Add config for incompatible changes to persistent metadata |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jason Gustafson | 7 years 16 weeks | info |
| 381 | Connect: Tell about records that had their offsets flushed in callback |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Per Steffensen | 7 years 18 weeks | info |
| 375 | Kafka Clients - make Metadata#TOPIC_EXPIRY_MS configurable |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Pavel Moukhataev | 7 years 20 weeks | info |
| 370 | Remove Orphan Partitions |
Mentioned within the last 106751 days
|
0 | 0 | 0 | xiongqi wu | 7 years 23 weeks | info |
| 363 | Allow performance tools to print final results to output file |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Attila Sasvári | 7 years 26 weeks | info |
| 362 | Support dynamic gap session window |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Lei Chen | 7 years 25 weeks | info |
| 350 | Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ratish Ravindran | 7 years 28 weeks | info |
| 349 | Priorities for Source Topics |
Mentioned within the last 106751 days
|
1
Matthias J. Sax
|
0 |
1
Colin McCabe
|
Nick Afshartous | 7 years 28 weeks | info |
| 348 | Deprecate null from SourceTask#poll() |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Chia-Ping Tsai | 7 years 28 weeks | info |
| 343 | Add a Controller Heartbeat Mechanism |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Colin McCabe | 7 years 30 weeks | info |
| 340 | Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dong Lin | 7 years 31 weeks | info |
| 333 | Add faster mode of rebalancing |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Richard Yu | 7 years 32 weeks | info |
| 325 | Extend Consumer Group Command to Show Beginning Offsets |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Vahid Hashemian | 7 years 33 weeks | info |
| 322 | Return new error code for DeleteTopics API when topic deletion disabled. |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Manikumar Reddy O. | 7 years 34 weeks | info |
| 320 | Allow fetchers to detect and handle log truncation |
Mentioned within the last 106751 days
|
1
Dong Lin
|
0 | 0 | Jason Gustafson | 7 years 34 weeks | info |
| 317 | Add end-to-end data encryption functionality to Apache Kafka |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sönke Liebau | 7 years 34 weeks | info |
| 316 | Command-line overrides for ConnectDistributed worker properties |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Kevin Lafferty | 7 years 35 weeks | info |
| 315 | Stream Join Sticky Assignor |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mike Freyberger | 7 years 35 weeks | info |
| 314 | KTable to GlobalKTable Bi-directional Join |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Adam Bellemare | 7 years 36 weeks | info |
| 304 | Connect runtime mode improvements for container platforms |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Saulius Valatka | 7 years 39 weeks | info |
| 301 | Schema Inferencing for JsonConverter |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Allen Tang | 7 years 39 weeks | info |
| 296 | Connector level configurability for client configs |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Allen Tang | 7 years 40 weeks | info |
| 293 | Add new metrics for consumer/replication fetch requests |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Adam Kotwasinski | 7 years 41 weeks | info |
| 287 | Support partition and processor expansion for stateful processing jobs |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dong Lin | 7 years 43 weeks | info |
| 286 | producer.send() should not block on metadata update |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dong Lin | 7 years 44 weeks | info |
| 273 | Kafka to support using ETCD beside Zookeeper |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Balint Molnar | 7 years 46 weeks | info |
| 271 | Add NetworkClient redirector |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sergey Korytnikov | 7 years 48 weeks | info |
| 270 | A Scala Wrapper Library for Kafka Streams |
Mentioned within the last 106751 days
|
3
Ismael Juma
Matthias J. Sax Guozhang Wang |
0 | 0 | Debasish Ghosh | 7 years 48 weeks | info |
| 264 | Add a consumer metric to record raw fetch size |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Vahid Hashemian | 7 years 50 weeks | info |
| 259 | Improve Streams DSL Timestamp Propagation Semantics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Matthias J. Sax | 7 years 51 weeks | info |
| 256 | Add RocksDB statistics via Streams metrics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | jameschien | 7 years 51 weeks | info |
| 254 | JsonConverter Exception Handeling |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Prasanna Subburaj | 7 years 0 weeks | info |
| 253 | Support in-order message delivery with partition expansion |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dong Lin | 7 years 1 weeks | info |
| 252 | Extend ACLs to allow filtering based on ip ranges and subnets |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Sönke Liebau | 8 years 2 weeks | info |
| 250 | Add Support for Quorum-based Producer Acknowledgment |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Litao Deng | 8 years 3 weeks | info |
| 249 | Add Delegation Token Operations to KafkaAdminClient |
Mentioned within the last 106751 days
|
1
Rajini Sivaram
|
0 | 0 | Manikumar Reddy O. | 8 years 4 weeks | info |
| 242 | Mask password in Kafka Connect Rest API response |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Vincent Meng | 8 years 8 weeks | info |
| 241 | KTable repartition with compacted Topics |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jan Filipiak | 8 years 8 weeks | info |
| 240 | AdminClient.listReassignments AdminClient.describeReassignments |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 8 years 9 weeks | info |
| 236 | Interruptible Partition Reassignment |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 8 years 10 weeks | info |
| 234 | add support for getting topic defaults from AdminClient |
Mentioned within the last 106751 days
|
0 | 0 | 0 | dan norwood | 8 years 10 weeks | info |
| 232 | Detect outdated metadata using leaderEpoch and partitionEpoch |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Dong Lin | 8 years 10 weeks | info |
| 228 | Negative record timestamp support |
Mentioned within the last 106751 days
|
1
Matthias J. Sax
|
0 | 0 | Konstantin Chukhlomin | 8 years 11 weeks | info |
| 209 | Connection String Support |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Clebert Suconic | 8 years 17 weeks | info |
| 201 | Rationalising Policy interfaces |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Tom Bentley | 8 years 22 weeks | info |
| 193 | Add SchemaBuilder.from(Schema) |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ewen Cheslack-Postava | 8 years 24 weeks | info |
| 185 | Make exactly once in order delivery per partition the default producer setting |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Apurva Mehta | 8 years 27 weeks | info |
| 181 | DescribeGroups Protocol Enhancement |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Vahid Hashemian | 8 years 29 weeks | info |
| 178 | Size-based log directory selection strategy |
Mentioned within the last 106751 days
|
0 | 0 | 0 | huxihx | 8 years 30 weeks | info |
| 169 | Lag-Aware Partition Assignment Strategy |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Grant Neale | 8 years 34 weeks | info |
| 166 | Add a tool to make amounts of replicas and leaders on brokers balanced |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ma Tianchi | 8 years 37 weeks | info |
| 159 | Introducing Rich functions to Streams |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jeyhun Karimov | 8 years 38 weeks | info |
| 148 | Add a connect timeout for client |
Mentioned within the last 106751 days
|
0 | 0 | 0 | pengwei | 8 years 42 weeks | info |
| 142 | Add ListTopicsRequest to efficiently list all the topics in a cluster |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Colin McCabe | 8 years 43 weeks | info |
| 139 | Kafka TestKit library |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ismael Juma | 8 years 44 weeks | info |
| 135 | Send of null key to a compacted topic should throw non-retriable error back to user |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Mayuresh Gharat | 8 years 47 weeks | info |
| 125 | ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Onur Karaman | 8 years 51 weeks | info |
| 87 | Add Compaction Tombstone Flag |
Mentioned within the last 106751 days
|
1
Becket Qin
|
0 | 0 | Michael André Pearce | 9 years 16 weeks | info |
| 76 | Enable getting password from executable rather than passing as plaintext in config files |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ashish Singh | 9 years 25 weeks | info |
| 69 | Kafka Schema Registry |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Harsha | 9 years 33 weeks | info |
| 68 | Add a consumed log retention before log retention |
Mentioned within the last 106751 days
|
0 | 0 | 0 | pengwei | 9 years 33 weeks | info |
| 64 | Allow underlying distributed filesystem to take over replication depending on configuration |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Arvind Kandhare | 9 years 34 weeks | info |
| 61 | Add a log retention parameter for maximum disk space usage percentage |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ben Drees | 9 years 40 weeks | info |
| 60 | Make Java client classloading more flexible |
Mentioned within the last 106751 days
|
2
Harsha Chintalapani
Ismael Juma |
0 | 0 | Rajini Sivaram | 9 years 40 weeks | info |
| 59 | Proposal for a kafka broker command |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jayesh Thakrar | 9 years 40 weeks | info |
| 53 | Add custom policies for reconnect attempts to NetworkdClient |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Florian Hussonnois | 9 years 45 weeks | info |
| 52 | Connector Control APIs |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jason Gustafson | 9 years 46 weeks | info |
| 49 | Fair Partition Assignment Strategy |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Andrew Olson | 9 years 50 weeks | info |
| 47 | Add timestamp-based log deletion policy |
Mentioned within the last 106751 days
|
1
Gwen Shapira
|
0 | 0 | Bill Warshaw | 9 years 1 weeks | info |
| 46 | Self Healing Kafka |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Aditya Auradkar | 10 years 2 weeks | info |
| 45 | Standardize all client sequence interaction on j.u.Collection. |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Pierre-Yves Ritschard | 10 years 3 weeks | info |
| 44 | Allow Kafka to have a customized security protocol |
Mentioned within the last 106751 days
|
0 | 0 | 0 | XIAO, TAO | 10 years 3 weeks | info |
| 37 | Add Namespaces to Kafka |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ashish Singh | 10 years 20 weeks | info |
| 34 | Add Partitioner Change Listener to Partitioner Interface for Multiple Use Case |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Bhavesh Mistry | 10 years 22 weeks | info |
| 30 | Allow for brokers to have plug-able consensus and meta data storage sub systems |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Joe Stein | 10 years 51 weeks | info |
| 29 | Add an IsrPropagateIntervalMs configuration to KafkaConfig |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jiangjie Qin | 10 years 28 weeks | info |
| 27 | Conditional Publish |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ben Kirwin | 10 years 31 weeks | info |
| 23 | Add JSON/CSV output and looping options to ConsumerGroupCommand |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Ashish Singh | 10 years 41 weeks | info |
| 17 | Add HighwaterMarkOffset to OffsetFetchResponse |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Grant Henke | 10 years 47 weeks | info |
| 14 | Tools Standardization |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Jiangjie Qin | 10 years 50 weeks | info |
| 6 | New reassignment partition logic for rebalancing |
Mentioned within the last 106751 days
|
0 | 0 | 0 | Joe Stein | 11 years 4 weeks | info |