Jenkins build is back to normal : Kafka » Kafka Branch Builder » 3.0 #51

See

[jira] [Created] (KAFKA-13114) Unregsiter listener during renounce when the in-memory snapshot is missing

Jose Armando Garcia Sancio created KAFKA-13114: -- Summary: Unregsiter listener during renounce when the in-memory snapshot is missing Key: KAFKA-13114 URL:

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #345

See

[jira] [Created] (KAFKA-13113) Add unregister support to the RaftClient.

Jose Armando Garcia Sancio created KAFKA-13113: -- Summary: Add unregister support to the RaftClient. Key: KAFKA-13113 URL: https://issues.apache.org/jira/browse/KAFKA-13113 Project: Kafka

[jira] [Created] (KAFKA-13112) Controller's committed offset get out of sync with raft client listener context

Jose Armando Garcia Sancio created KAFKA-13112: -- Summary: Controller's committed offset get out of sync with raft client listener context Key: KAFKA-13112 URL:

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.0 #50

See Changes: -- [...truncated 483735 lines...] [2021-07-21T01:44:09.167Z] [INFO] Project created from Archetype in dir:

Build failed in Jenkins: Kafka » kafka-2.4-jdk8 #29

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

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #166

See Changes: [Ismael Juma] MINOR: Fix testTlsDefaults failure due to TLS 1.0/1.1 being disabled (#11092) -- [...truncated 3.45 MB...]

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #344

See

[jira] [Resolved] (KAFKA-10541) Convert KTable filters to new PAPI

[ https://issues.apache.org/jira/browse/KAFKA-10541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Esteban Quilcate Otoya resolved KAFKA-10541. -- Fix Version/s: 3.0.0 Assignee: John Roesler (was:

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #128

See Changes: [Ismael Juma] MINOR: Fix testTlsDefaults failure due to TLS 1.0/1.1 being disabled (#11092) -- [...truncated 3.18 MB...]

[jira] [Resolved] (KAFKA-10537) Convert KStreamImpl filters to new PAPI

[ https://issues.apache.org/jira/browse/KAFKA-10537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Esteban Quilcate Otoya resolved KAFKA-10537. -- Resolution: Fixed https://github.com/apache/kafka/pull/10381

[jira] [Resolved] (KAFKA-10538) Convert KStreamImpl maps to new PAPI

[ https://issues.apache.org/jira/browse/KAFKA-10538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Esteban Quilcate Otoya resolved KAFKA-10538. -- Resolution: Fixed https://github.com/apache/kafka/pull/10381

[jira] [Created] (KAFKA-13111) Re-evaluate Fetch flow for topic ID usage

Justine Olshan created KAFKA-13111: -- Summary: Re-evaluate Fetch flow for topic ID usage Key: KAFKA-13111 URL: https://issues.apache.org/jira/browse/KAFKA-13111 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-13110) Review and Optimize KIP-500 related Settings

Niket Goel created KAFKA-13110: -- Summary: Review and Optimize KIP-500 related Settings Key: KAFKA-13110 URL: https://issues.apache.org/jira/browse/KAFKA-13110 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-763: Range queries with open endpoints

Thanks for the KIP, Patrick! I think your KIP is well motivated. It's definitely a bummer to have to iterate over the full store as a workaround for open-ended ranges. I agree with your pragmatic approach here. We have recently had a couple of other contributions to the store APIs (prefix and

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.0 #49

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #343

See

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

Thanks Rohan. I remember now that we moved the round-trip PID's txn completion logic into init-transaction and commit/abort-transaction. So I think we'd count time as in StreamsProducer#initTransaction as well (admittedly it is in most cases a one-time thing). Other than that, I do not have any

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #342

See

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

> Similarly, I think "txn-commit-time-total" and "offset-commit-time-total" may better be inside producer and consumer clients respectively. I agree for offset-commit-time-total. For txn-commit-time-total I'm proposing we measure `StreamsProducer.commitTransaction`, which wraps multiple producer

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

Thanks for the KIP Rohan. I had a question - it seems like from the descriptions of `txn-commit-time-total` and `offset-commit-time-total` that they measure similar processes for ALOS and EOS, but only `txn-commit-time-total` is included in `blocked-time-total`. Why isn't

[jira] [Resolved] (KAFKA-13082) Replace EasyMock with Mockito for ProcessorContextTest

[ https://issues.apache.org/jira/browse/KAFKA-13082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13082. - Fix Version/s: 3.1.0 Resolution: Fixed > Replace EasyMock with Mockito for

[jira] [Resolved] (KAFKA-13100) Controller cannot revert to an in-memory snapshot

[ https://issues.apache.org/jira/browse/KAFKA-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-13100. -- Resolution: Fixed Fixed. Thanks, [~jagsancio]! > Controller cannot revert to an in-memory

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #47

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #341

See

[jira] [Reopened] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-8410: - > Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as > well >

[jira] [Created] (KAFKA-13109) WorkerSourceTask is not enforcing the errors.retry.timeout and errors.retry.delay.max.ms parameters in case of a RetriableException during task.poll()

Damien Gasparina created KAFKA-13109: Summary: WorkerSourceTask is not enforcing the errors.retry.timeout and errors.retry.delay.max.ms parameters in case of a RetriableException during task.poll() Key: KAFKA-13109

Issue with using open messaging

Hi there, I'm trying to use open messaging to run some benchmarks for Kafka I've done the prerequisite setup for machines using terraform machine and ansible now while running the benchmark with sudo bin/benchmark --drivers driver-kafka/kafka.yaml workloads/1-topic-16-partitions-1kb.yaml , I'm

Re: [VOTE] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Hi Ron, Thanks for bringing this up. Thinking about it, the combination of flexible fields and the principal type field gives us enough flexibility that we don't need a magic number. Ismael P.S. For a magic number to be useful for third party implementations, we would need a mechanism to

[jira] [Created] (KAFKA-13108) Improve the test coverage for ConfigCommandTest

Luke Chen created KAFKA-13108: - Summary: Improve the test coverage for ConfigCommandTest Key: KAFKA-13108 URL: https://issues.apache.org/jira/browse/KAFKA-13108 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-13107) KafkaServer.startup leaves server socket open if zk error is throws (ex. NodeExists)

Fuud created KAFKA-13107: Summary: KafkaServer.startup leaves server socket open if zk error is throws (ex. NodeExists) Key: KAFKA-13107 URL: https://issues.apache.org/jira/browse/KAFKA-13107 Project: Kafka

[jira] [Resolved] (KAFKA-13106) Offsets deletion error

[ https://issues.apache.org/jira/browse/KAFKA-13106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Janda resolved KAFKA-13106. -- Resolution: Fixed version 2.3.1 does not suport it > Offsets deletion error >

[jira] [Created] (KAFKA-13106) Offsets deletion error

Robert Janda created KAFKA-13106: Summary: Offsets deletion error Key: KAFKA-13106 URL: https://issues.apache.org/jira/browse/KAFKA-13106 Project: Kafka Issue Type: Bug Components:

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

Hi all, 1. Actually I always thought about the serialized byte array only -- at least this is what local stores depend upon, and what Kafka itself depends upon when doing log compaction. I can imagine a case where two different byte arrays deserialize to objects which are `equals` to each

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

Thanks for the review Guozhang! responding to your feedback inline: > 1) I agree that the current ratio metrics is just "snapshot in point", and more flexible metrics that would allow reporters to calculate based on window intervals are better. However, the current mechanism of the proposed