[jira] [Resolved] (KAFKA-10282) Log metrics are removed if a log is deleted and re-created quickly enough

[ https://issues.apache.org/jira/browse/KAFKA-10282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett resolved KAFKA-10282. - Resolution: Fixed > Log metrics are removed if a log is deleted and re-created quickly enough >

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

See Changes: [cshapi] KAFKA-10282; Remove Log metrics immediately when deleting log -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest > should

Build failed in Jenkins: kafka-trunk-jdk14 #332

See Changes: [cshapi] KAFKA-10282; Remove Log metrics immediately when deleting log -- [...truncated 3.21 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shoul

Build failed in Jenkins: kafka-trunk-jdk11 #1682

See Changes: [cshapi] KAFKA-10282; Remove Log metrics immediately when deleting log -- [...truncated 3.21 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shoul

Build failed in Jenkins: kafka-trunk-jdk14 #331

See Changes: [github] KAFKA-10255: Fix flaky testOneWayReplicationWithAutoOffsetSync test -- [...truncated 3.21 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-10255: Fix flaky testOneWayReplicationWithAutoOffsetSync test -- [...truncated 6.36 MB...] org.apache.kafka.streams.TopologyTestDriverTest > s

LIST_OFFSETS not returning latest timestamps

Hello, When the LIST_OFFSETS API doesn't find messages with timestamps larger or equal to the requested, it returns the end of the log offsets. In this scenario the API response contains the offsets but not corresponding timestamps. This makes it very hard to get the latest timestamp which is very

[jira] [Created] (KAFKA-10330) Error processing append operation on partition test-1 (kafka.server.ReplicaManager) org.apache.kafka.common.InvalidRecordException: One or more records have been rejecte

Vijay created KAFKA-10330: - Summary: Error processing append operation on partition test-1 (kafka.server.ReplicaManager) org.apache.kafka.common.InvalidRecordException: One or more records have been rejected Key: KAFKA-10330

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

On Thu, Jul 30, 2020 at 7:18 AM David Jacot wrote: > Hi Boyang, > > Thanks for your answers. > > > The point for using the listener name is more of a security purpose, to > > detect any forged request to our best effort. > > For throttling I think we could just check the request header for > > *I

Jenkins build is back to normal : kafka-trunk-jdk14 #329

See

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

See Changes: [github] KAFKA-10319: Skip unknown offsets when computing sum of changelog [github] KAFKA-9629 Use generated protocol for Fetch API (#9008) -- [...truncated

[jira] [Created] (KAFKA-10329) Enable connector context in logs by default

Randall Hauch created KAFKA-10329: - Summary: Enable connector context in logs by default Key: KAFKA-10329 URL: https://issues.apache.org/jira/browse/KAFKA-10329 Project: Kafka Issue Type: Imp

[jira] [Created] (KAFKA-10328) MockConsumer behaves differently than KafkaConsumer

Jeff Kim created KAFKA-10328: Summary: MockConsumer behaves differently than KafkaConsumer Key: KAFKA-10328 URL: https://issues.apache.org/jira/browse/KAFKA-10328 Project: Kafka Issue Type: Bug

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

See

Re: [VOTE] 2.5.1 RC0

+1 (binding), verified signatures, ran the tests on the source archive with Scala 2.13 and Java 11 and verified the quickstart with the source archive and Scala 2.13 binary archive. Ismael On Thu, Jul 23, 2020 at 7:39 PM John Roesler wrote: > Hello Kafka users, developers and client-developers,

Build failed in Jenkins: kafka-trunk-jdk14 #328

See Changes: [github] KAFKA-10120: Deprecate DescribeLogDirsResult.all() and .values() (#9007) -- [...truncated 3.21 MB...] org.apache.kafka.streams.TopologyTestDriverT

Re: [VOTE] KIP-635: GetOffsetShell: support for multiple topics and consumer configuration override

Hi Daniel, Thanks for the KIP. It seems that we have forgotten to include this tool in KIP-499. KAFKA-8507 is resolved by this tool still uses the deprecated "--broker-list". I suggest to include "--bootstrap-server" in your public interfaces as well and fix this omission during the implementatio

Re: [VOTE] 2.5.1 RC0

Hello again all, Just a reminder that the 2.5.1 RC0 is available for verification. Thanks, John On Thu, Jul 23, 2020, at 21:39, John Roesler wrote: > Hello Kafka users, developers and client-developers, > > This is the first candidate for release of Apache Kafka 2.5.1. > > Apache Kafka 2.5.1 i

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

Hi Boyang, Thanks for your answers. > The point for using the listener name is more of a security purpose, to > detect any forged request to our best effort. > For throttling I think we could just check the request header for > *InitialClientId* existence, to distinguish whether to apply > thrott

[jira] [Resolved] (KAFKA-10120) DescribeLogDirsResult exposes internal classes

[ https://issues.apache.org/jira/browse/KAFKA-10120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-10120. Fix Version/s: 2.7 Resolution: Fixed > DescribeLogDirsResult exposes internal class

[jira] [Created] (KAFKA-10327) Make flush after some count of putted records in SinkTask

Pavel Kuznetsov created KAFKA-10327: --- Summary: Make flush after some count of putted records in SinkTask Key: KAFKA-10327 URL: https://issues.apache.org/jira/browse/KAFKA-10327 Project: Kafka

Jenkins build is back to normal : kafka-trunk-jdk11 #1678

See

Re: [VOTE] KIP-635: GetOffsetShell: support for multiple topics and consumer configuration override

+1 (non-binding), thanks for the KIP! On Thu, Jul 30, 2020 at 3:31 PM Manikumar wrote: > +1 (binding) > > Thanks for the KIP! > > > > On Thu, Jul 30, 2020 at 3:07 PM Dániel Urbán > wrote: > > > Hi everyone, > > > > If you are interested in this KIP, please do not forget to vote. > > > > Thanks,

Re: [VOTE] KIP-635: GetOffsetShell: support for multiple topics and consumer configuration override

+1 (binding) Thanks for the KIP! On Thu, Jul 30, 2020 at 3:07 PM Dániel Urbán wrote: > Hi everyone, > > If you are interested in this KIP, please do not forget to vote. > > Thanks, > Daniel > > Viktor Somogyi-Vass ezt írta (időpont: 2020. > júl. > 28., K, 16:06): > > > +1 from me (non-bindin

Re: [VOTE] KIP-635: GetOffsetShell: support for multiple topics and consumer configuration override

Hi everyone, If you are interested in this KIP, please do not forget to vote. Thanks, Daniel Viktor Somogyi-Vass ezt írta (időpont: 2020. júl. 28., K, 16:06): > +1 from me (non-binding), thanks for the KIP. > > On Mon, Jul 27, 2020 at 10:02 AM Dániel Urbán > wrote: > > > Hello everyone, > > >

Build failed in Jenkins: kafka-trunk-jdk14 #327

See Changes: [github] KAFKA-10321: fix infinite blocking for global stream thread startup -- [...truncated 3.21 MB...] org.apache.kafka.streams.internals.WindowStoreFacad

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

See Changes: [github] KAFKA-10321: fix infinite blocking for global stream thread startup -- [...truncated 3.18 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Build failed in Jenkins: kafka-trunk-jdk11 #1677

See Changes: [github] KAFKA-10309: KafkaProducer's sendOffsetsToTransaction should not block -- [...truncated 2.57 MB...] org.apache.kafka.streams.processor.internals.S