Build failed in Jenkins: kafka-trunk-jdk8 #4032

See Changes: [mimaison] MINOR: fix docs around leader rebalancing to reflect default of true -- [...truncated 2.75 MB...]

Build failed in Jenkins: kafka-2.4-jdk8 #64

See Changes: -- [...truncated 2.69 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestampWithProducerRecord STARTED

Re: [ANNOUNCE] New committer: Mickael Maison

Congrats Mickael! On Sat, Nov 9, 2019 at 4:47 AM Sean Glover wrote: > Congratulations Mickael :) > > On Fri, Nov 8, 2019 at 12:28 PM Ankit Kumar > wrote: > > > Congratulations Mickael!! > > > > *Best regards,* > > *Ankit Kumar.* > > > > > > On Fri, Nov 8, 2019 at 9:08 PM Viktor Somogyi-Vass <

Build failed in Jenkins: kafka-2.4-jdk8 #63

See Changes: -- [...truncated 8.16 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareValue PASSED

Re: Why standby tasks read from the StandbyTasks::checkpointedOffsets in assignStandbyPartitions()

Thanks Guozhang. The jira is filed: [KAFKA-9169] Standby Tasks point ask for incorrect offsets on resuming post suspension - ASF JIRA | | | | [KAFKA-9169] Standby Tasks point ask for incorrect offsets on resuming p... | | | On Monday, 11 November, 2019, 03:10:37 am IST,

[jira] [Created] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

Navinder Brar created KAFKA-9169: Summary: Standby Tasks point ask for incorrect offsets on resuming post suspension Key: KAFKA-9169 URL: https://issues.apache.org/jira/browse/KAFKA-9169 Project:

Re: Deferred processing

Hi Naveen, Is your deferred processing logic respect ordering still or not? More specifically let's say if you published records A, B, C, D ... to the same topic partition and let's say record B's processing need to be delayed, then would 1) records C and D and all following are okay to be

Re: Why standby tasks read from the StandbyTasks::checkpointedOffsets in assignStandbyPartitions()

If a standby task is suspended, it will write the checkpoint file again after flushing its state stores, and when it resumes it does not re initialize the position on the consumer and hence it is still the task-manager's responsibility to set the right starting offset from the latest checkpoint

Re: Subject: [VOTE] 2.2.2 RC2

+1 (non-binding) ... I used the prepared artifacts (Scala 2.12) and run my tests against them. All seems to be fine. On Sun, Nov 10, 2019 at 2:10 AM Matthias J. Sax wrote: > Thanks for running the release Randall! > > - verified all signatures > - build from source > - ran unit/integration

[DISCUSS] KIP-540: Implement per key stream time tracking

Hi all, After some thought, I thought that we could move forward with this KIP. The low traffic suppression buffer issue is not necessarily a blocker issue, since there are ways to mitigate the problem when implementing this KIP. Below is the KIP link:

Build failed in Jenkins: kafka-2.4-jdk8 #62

See Changes: -- [...truncated 5.45 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentForCompareKeyValueTimestampWithProducerRecord PASSED

Jenkins build is back to normal : kafka-trunk-jdk8 #4030

See

Re: [jira] [Created] (KAFKA-9148) Consider forking RocksDB for Streams

Unsubscribe On Wed, Nov 6, 2019 at 6:48 AM Sophie Blee-Goldman (Jira) wrote: > Sophie Blee-Goldman created KAFKA-9148: > -- > > Summary: Consider forking RocksDB for Streams > Key: KAFKA-9148 > URL: