|
kafka git commit: KAFKA-6260; Ensure selection keys are removed from all collections on socket close |
|
| j...@apache.org |
kafka git commit: KAFKA-6260; Ensure selection keys are removed from all collections on socket close |
Fri, 01 Dec, 19:34 |
| j...@apache.org |
kafka git commit: KAFKA-6260; Ensure selection keys are removed from all collections on socket close |
Fri, 01 Dec, 19:37 |
| j...@apache.org |
kafka git commit: KAFKA-6296; Increase jitter to fix transient failure in NetworkClientTest.testConnectionDelayDisconnected |
Fri, 01 Dec, 21:03 |
|
kafka git commit: MINOR: Improve EOS related config docs |
|
| guozh...@apache.org |
kafka git commit: MINOR: Improve EOS related config docs |
Fri, 01 Dec, 22:39 |
| guozh...@apache.org |
kafka git commit: MINOR: Improve EOS related config docs |
Fri, 01 Dec, 22:45 |
| guozh...@apache.org |
kafka git commit: MINOR: Improve EOS related config docs |
Fri, 01 Dec, 22:46 |
|
kafka git commit: KAFKA-6118: Fix transient failure testTwoConsumersWithDifferentSaslCredentials |
|
| guozh...@apache.org |
kafka git commit: KAFKA-6118: Fix transient failure testTwoConsumersWithDifferentSaslCredentials |
Sat, 02 Dec, 07:52 |
| guozh...@apache.org |
kafka git commit: KAFKA-6118: Fix transient failure testTwoConsumersWithDifferentSaslCredentials |
Sat, 02 Dec, 07:52 |
| guozh...@apache.org |
kafka git commit: KAFKA-6118: Fix transient failure testTwoConsumersWithDifferentSaslCredentials |
Sat, 02 Dec, 07:54 |
| guozh...@apache.org |
kafka git commit: HOTFIX: remove mis-merges from the previous commit |
Sat, 02 Dec, 08:21 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix broker compatibility tests |
Sun, 03 Dec, 17:05 |
| guozh...@apache.org |
kafka git commit: MINOR: increase request timeout for streams bounce test |
Mon, 04 Dec, 17:56 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-6150: KIP-204 part III; Purge repartition topics with the admin client |
Mon, 04 Dec, 18:21 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-6150: KIP-204 part III; Purge repartition topics with the admin client |
Mon, 04 Dec, 18:21 |
|
kafka git commit: KAFKA-6174; Add methods in AdminClient Options classes to restore binary compatibility with 0.11 |
|
| ij...@apache.org |
kafka git commit: KAFKA-6174; Add methods in AdminClient Options classes to restore binary compatibility with 0.11 |
Wed, 06 Dec, 13:57 |
| ij...@apache.org |
kafka git commit: KAFKA-6174; Add methods in AdminClient Options classes to restore binary compatibility with 0.11 |
Wed, 06 Dec, 13:57 |
| ij...@apache.org |
kafka git commit: MINOR: Add maybeThrow method to ZooKeeperClient AsyncResponse |
Wed, 06 Dec, 14:55 |
| guozh...@apache.org |
kafka git commit: KAFKA-5520: KIP-171; Extend Consumer Group Reset Offset for Stream Application |
Wed, 06 Dec, 19:38 |
|
kafka git commit: KAFKA-6300; SelectorTest may fail with ConcurrentModificationException |
|
| rsiva...@apache.org |
kafka git commit: KAFKA-6300; SelectorTest may fail with ConcurrentModificationException |
Wed, 06 Dec, 19:42 |
| rsiva...@apache.org |
kafka git commit: KAFKA-6300; SelectorTest may fail with ConcurrentModificationException |
Wed, 06 Dec, 19:42 |
| ij...@apache.org |
kafka git commit: KAFKA-6193; Only delete reassign_partitions znode after reassignment is complete |
Wed, 06 Dec, 20:26 |
| ij...@apache.org |
kafka git commit: KAFKA-6065; Latency metric for KafkaZkClient |
Wed, 06 Dec, 23:14 |
| ij...@apache.org |
kafka git commit: MINOR: Avoid intermediate strings when parsing/decoding ZK JSON |
Thu, 07 Dec, 00:38 |
| ij...@apache.org |
kafka git commit: KAFKA-6313; Add SLF4J as direct dependency to Kafka core |
Thu, 07 Dec, 08:37 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-4857: Replace StreamsKafkaClient with AdminClient in Kafka Streams |
Fri, 08 Dec, 00:16 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-4857: Replace StreamsKafkaClient with AdminClient in Kafka Streams |
Fri, 08 Dec, 00:16 |
|
kafka git commit: KAFKA-6289; NetworkClient should not expose failed internal ApiVersions requests |
|
| rsiva...@apache.org |
kafka git commit: KAFKA-6289; NetworkClient should not expose failed internal ApiVersions requests |
Fri, 08 Dec, 10:53 |
| rsiva...@apache.org |
kafka git commit: KAFKA-6289; NetworkClient should not expose failed internal ApiVersions requests |
Fri, 08 Dec, 10:58 |
| damian...@apache.org |
[1/2] kafka git commit: KAFKA-6121: Restore and global consumer should not use auto.offset.reset |
Mon, 11 Dec, 14:22 |
| damian...@apache.org |
[2/2] kafka git commit: KAFKA-6121: Restore and global consumer should not use auto.offset.reset |
Mon, 11 Dec, 14:22 |
|
kafka git commit: MINOR: Increase number of messages in replica verification tool test |
|
| j...@apache.org |
kafka git commit: MINOR: Increase number of messages in replica verification tool test |
Mon, 11 Dec, 19:14 |
| j...@apache.org |
kafka git commit: MINOR: Increase number of messages in replica verification tool test |
Mon, 11 Dec, 19:15 |
| j...@apache.org |
kafka git commit: MINOR: Increase number of messages in replica verification tool test |
Mon, 11 Dec, 19:15 |
| guozh...@apache.org |
kafka-site git commit: KAFKA-6334: fix typo in backwards compatibility note |
Tue, 12 Dec, 02:51 |
|
kafka git commit: KAFKA-6334: minor typo fix in web docs |
|
| guozh...@apache.org |
kafka git commit: KAFKA-6334: minor typo fix in web docs |
Tue, 12 Dec, 02:55 |
| guozh...@apache.org |
kafka git commit: KAFKA-6334: minor typo fix in web docs |
Tue, 12 Dec, 02:56 |
| ij...@apache.org |
[1/2] kafka git commit: KAFKA-6324; Change LogSegment.delete to deleteIfExists and harden log recovery |
Tue, 12 Dec, 08:00 |
| ij...@apache.org |
[2/2] kafka git commit: KAFKA-6324; Change LogSegment.delete to deleteIfExists and harden log recovery |
Tue, 12 Dec, 08:00 |
|
kafka git commit: KAFKA-6319: Quote strings stored in JSON configs |
|
| ij...@apache.org |
kafka git commit: KAFKA-6319: Quote strings stored in JSON configs |
Tue, 12 Dec, 10:26 |
| ij...@apache.org |
kafka git commit: KAFKA-6319: Quote strings stored in JSON configs |
Tue, 12 Dec, 10:26 |
| ij...@apache.org |
kafka git commit: KAFKA-5631; Use Jackson for serialising to JSON |
Tue, 12 Dec, 16:34 |
| j...@apache.org |
kafka git commit: KAFKA-5764; Add toLowerCase support to sasl.kerberos.principal.to.local rule (KIP-203) |
Tue, 12 Dec, 23:56 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix warn logging in RecordCollectorImpl |
Wed, 13 Dec, 03:13 |
| guozh...@apache.org |
kafka git commit: KAFKA-6349: Fix concurrent modification exception in AbstractStateManager during restore |
Wed, 13 Dec, 03:25 |
| guozh...@apache.org |
kafka git commit: KAFKA-6360: Clear RocksDB Segments when store is closed |
Thu, 14 Dec, 17:51 |
| j...@apache.org |
kafka git commit: KAFKA-6102; Consolidate MockTime implementations between connect and clients |
Thu, 14 Dec, 22:50 |
| j...@apache.org |
kafka git commit: KAFKA-6308; Connect Struct should use deepEquals/deepHashCode |
Thu, 14 Dec, 23:30 |
| damian...@apache.org |
kafka git commit: KAFKA-6086: Provide for custom error handling when Kafka Streams fails to produce |
Fri, 15 Dec, 12:56 |
| j...@apache.org |
kafka git commit: KAFKA-5526; Additional `--describe` views for ConsumerGroupCommand (KIP-175) |
Fri, 15 Dec, 18:30 |
| jun...@apache.org |
kafka git commit: KAFKA-5473; handle ZK session expiration properly when a new session can't be established |
Fri, 15 Dec, 22:48 |
|
kafka git commit: MINOR: improve JavaDocs for KafkaStreams, KafkaProducer, KafkaConsumer |
|
| guozh...@apache.org |
kafka git commit: MINOR: improve JavaDocs for KafkaStreams, KafkaProducer, KafkaConsumer |
Mon, 18 Dec, 19:10 |
| guozh...@apache.org |
kafka git commit: MINOR: improve JavaDocs for KafkaStreams, KafkaProducer, KafkaConsumer |
Mon, 18 Dec, 19:10 |
|
kafka git commit: KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data |
|
| j...@apache.org |
kafka git commit: KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data |
Mon, 18 Dec, 19:16 |
| j...@apache.org |
kafka git commit: KAFKA-6258; SSLTransportLayer should keep reading from socket until either the buffer is full or the socket has no more data |
Mon, 18 Dec, 19:23 |
|
kafka git commit: MINOR: Stabilize flaky smoke system tests before KIP-91 |
|
| guozh...@apache.org |
kafka git commit: MINOR: Stabilize flaky smoke system tests before KIP-91 |
Tue, 19 Dec, 01:34 |
| guozh...@apache.org |
kafka git commit: MINOR: Stabilize flaky smoke system tests before KIP-91 |
Tue, 19 Dec, 01:35 |
|
kafka git commit: MINOR: Fix race condition in KafkaStreamsTest.shouldReturnThreadMetadata |
|
| guozh...@apache.org |
kafka git commit: MINOR: Fix race condition in KafkaStreamsTest.shouldReturnThreadMetadata |
Tue, 19 Dec, 01:39 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix race condition in KafkaStreamsTest.shouldReturnThreadMetadata |
Tue, 19 Dec, 01:39 |
| ij...@apache.org |
kafka git commit: KAFKA-6317; Maven artifact for kafka should not depend on log4j |
Tue, 19 Dec, 15:16 |
| guozh...@apache.org |
kafka git commit: MINOR: Broker down for significant amt of time system test |
Tue, 19 Dec, 23:37 |