Contribution Permission

Hi, I would like to start contributing as a developer and kindly ask to be added to the contributor list. Jira and Wiki username: puhlerblet Thanks and regards, Jonas

Re: [VOTE] KIP-418: A method-chaining way to branch KStream

Wow! So excited to hear that! Thanks for your collaboration, now it's my turn to write a PR. Regards, Ivan 04.07.2020 20:16, John Roesler пишет: Hi Ivan, Congratulations! It looks like you have 3 binding and 2 non-binding votes, so you can announce this KIP as accepted and follow up with

Re: Contribution Permission

Hey Jonas, I have added you the permission in both JIRA and wiki. Happy contributing! On Sun, Jul 5, 2020 at 11:12 PM Jonas Amslinger wrote: > Hi, > > I would like to start contributing as a developer and kindly ask to be > added to the contributor list. > > Jira and Wiki username: puhlerblet

[jira] [Created] (KAFKA-10236) Kafka Streams | onCommit interceptor with EOS enabled

Vinodhini created KAFKA-10236: - Summary: Kafka Streams | onCommit interceptor with EOS enabled Key: KAFKA-10236 URL: https://issues.apache.org/jira/browse/KAFKA-10236 Project: Kafka Issue Type:

[VOTE] KIP-621: Deprecate and replace DescribeLogDirsResult.all() and .values()

Hi, I'd like to start a vote on KIP-621 which is about deprecating methods in DescribeLogDirsResult which leak internal classes, replacing them with public API classes. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=158862109 Thanks, Tom

[jira] [Reopened] (KAFKA-6453) Reconsider timestamp propagation semantics

[ https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6453: IMHO, the PR only covers part of this ticket. We should also document how timestamps are

[jira] [Created] (KAFKA-10242) Adding metrics to track the total count of idempotent producers that Broker need to track

Ming Liu created KAFKA-10242: Summary: Adding metrics to track the total count of idempotent producers that Broker need to track Key: KAFKA-10242 URL: https://issues.apache.org/jira/browse/KAFKA-10242

Re: [DISCUSS] KIP-639 Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

Hi Mohamed, Thank you for the KIP. Comments regarding the KIP wiki: 1. In section "Public Interface", you should state what you want to change in interface StreamsMetrics. In your case, you want to add two methods. You can find a good example how to describe this in KIP-444

Re: KIP-560 Discuss

I'm sorry. I just modified the KIP! On 2020/03/07 20:09:47, "Matthias J. Sax" wrote: > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Thanks for the KIP Sang! > > I have a couple of more comments about the wiki page: > > (1) The "Public Interface" section should only list the new

Re: KIP-560 Discuss

I'm sorry. I just modified the KIP. On 2020/05/26 20:11:46, Boyang Chen wrote: > Hey Sang, unfortunately we couldn't make it in 2.6. Do you still plan to > work on this KIP? > > On Thu, May 14, 2020 at 6:49 PM Boyang Chen > wrote: > > > Hey Sang, seems this thread has been quiet, are you

[jira] [Resolved] (KAFKA-9769) ReplicaManager Partition.makeFollower Increases LeaderEpoch when ZooKeeper disconnect occurs

[ https://issues.apache.org/jira/browse/KAFKA-9769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-9769. Fix Version/s: 2.7.0 Assignee: Andrew Choi Resolution: Fixed merged the PR to trunk >

Re: [VOTE] KIP-418: A method-chaining way to branch KStream

I am late, but I am also +1 (binding). -Matthias On 7/6/20 2:16 AM, Ivan Ponomarev wrote: > Wow! > > So excited to hear that! > > Thanks for your collaboration, now it's my turn to write a PR. > > Regards, > > Ivan > > 04.07.2020 20:16, John Roesler пишет: >> Hi Ivan, >> >> Congratulations!

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Hi John, Thanks, I have updated the KIP. Thanks! Sagar. On Mon, Jul 6, 2020 at 12:00 AM John Roesler wrote: > Hi Sagar, > > Sorry for the ambiguity. You could just mention it in the Public > Interfaces section. Or, if you want to be more specific, you can show it in > the method definition

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

See Changes: [github] MINOR: rename class `RecordTimeDefintion` to `RecordTimeDefinition` -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[DISCUSS] Include min.insync.replicas in MetadataResponse to make Producer smarter in partitioning events

Hi everyone, I would like to start the discussion for KIP-637 https://cwiki.apache.org/confluence/display/KAFKA/KIP-637%3A+Include+min.insync.replicas+in+MetadataResponse+to+make+Producer+smarter+in+partitioning+events Looking forward to your feedback. Thanks, Arvin

Re: Feedback: Print schemaId using bin/kafka-dump-log.sh

Do anyone have feedback on this? ☺ From: Mohanraj Nagasamy Date: Wednesday, July 1, 2020 at 6:29 PM To: "dev@kafka.apache.org" Subject: Feedback: Print schemaId using bin/kafka-dump-log.sh When I try to dump kafka logs for diagnosing or debugging a problem, It's handy to see if the kafka log

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

See Changes: [github] KAFKA-10017: fix flaky EosBetaUpgradeIntegrationTest (#8963) -- [...truncated 3.18 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: Potential Improvement for Kafka Producer

Arvin, thanks for your email. This is definitely the right channel. I am personally not familiar enough with the producer code, but what you say makes sense to me from a high level. Maybe it would be best if you would file a Jira to improve the producer accordingly? I guess, this change would

[jira] [Created] (KAFKA-10238) kafka-console-producer null value

Ryan created KAFKA-10238: Summary: kafka-console-producer null value Key: KAFKA-10238 URL: https://issues.apache.org/jira/browse/KAFKA-10238 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-10240) Sink tasks should not throw WakeupException on shutdown

Chris Egerton created KAFKA-10240: - Summary: Sink tasks should not throw WakeupException on shutdown Key: KAFKA-10240 URL: https://issues.apache.org/jira/browse/KAFKA-10240 Project: Kafka

Build failed in Jenkins: kafka-2.6-jdk8 #70

See Changes: [jason] MINOR: Improve logging around initial log loading (#8970) -- [...truncated 3.15 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: [DISCUSS] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

William, thanks for the KIP. LGMT. Feel free to start a vote. -Matthias On 7/4/20 10:14 AM, John Roesler wrote: > Hi Richard, > > It’s good to hear from you! > > Thanks for bringing up the wall-clock suppression feature. IIRC, someone > actually started a KIP discussion for it already, but

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

See Changes: [github] MINOR: rename class `RecordTimeDefintion` to `RecordTimeDefinition` -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest

[jira] [Created] (KAFKA-10239) The groupInstanceId field in DescribeGroup response should be ignorable

Jason Gustafson created KAFKA-10239: --- Summary: The groupInstanceId field in DescribeGroup response should be ignorable Key: KAFKA-10239 URL: https://issues.apache.org/jira/browse/KAFKA-10239

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

See Changes: [github] MINOR: Improve logging around initial log loading (#8970) [github] KAFKA-9769: ReplicaManager Partition.makeFollower Increases LeaderEpoch [github] KAFKA-8398: Prevent NPE in `forceUnmap`

[jira] [Created] (KAFKA-10237) Properly handle in-memory stores OOM

Boyang Chen created KAFKA-10237: --- Summary: Properly handle in-memory stores OOM Key: KAFKA-10237 URL: https://issues.apache.org/jira/browse/KAFKA-10237 Project: Kafka Issue Type: Improvement

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

See Changes: [github] MINOR: rename class `RecordTimeDefintion` to `RecordTimeDefinition` -- [...truncated 3.16 MB...]

[jira] [Resolved] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10173. -- Fix Version/s: (was: 2.5.1) (was: 2.4.2) Resolution: Fixed

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Atm, the config should be ignored and the global-consumer should use "none" in a hard-coded way. However, if am still wondering if we actually want/need to allow users to specify the reset policy? It might be worth to consider, to just change the behavior: catch the exception, log an ERROR (for

Re: Potential Improvement for Kafka Producer

Thanks to Matthias for the response, I've created a KIP and started another email thread to discuss this, check following. [DISCUSS] Include min.insync.replicas in MetadataResponse to make Producer smarter in partitioning events Matthias J. Sax 于2020年7月6日周一 下午12:30写道： > Arvin, > > thanks for

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

See Changes: [github] MINOR: Improve logging around initial log loading (#8970) [github] KAFKA-9769: ReplicaManager Partition.makeFollower Increases LeaderEpoch [github] KAFKA-8398: Prevent NPE in `forceUnmap`

Untrimmed index Files resulting in data loss

Hi there, about a week ago I submitted an issue report and an associated PR https://issues.apache.org/jira/browse/KAFKA-10207 https://github.com/apache/kafka/pull/8936 Is there any further information I can provide to help this along? Sorry to bug everyone about this, but after identifying the

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

See Changes: [github] KAFKA-10017: fix flaky EosBetaUpgradeIntegrationTest (#8963) -- [...truncated 6.37 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Jenkins build is back to normal : kafka-2.6-jdk8 #71

See

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

See

[jira] [Created] (KAFKA-10241) Pursue a better way to cover ignorable RPC fields

Boyang Chen created KAFKA-10241: --- Summary: Pursue a better way to cover ignorable RPC fields Key: KAFKA-10241 URL: https://issues.apache.org/jira/browse/KAFKA-10241 Project: Kafka Issue Type:

Untrimmed Index Files resulting in data loss

Hi there, about a week ago I submitted an issue report and an associated PR https://issues.apache.org/jira/browse/KAFKA-10207 https://github.com/apache/kafka/pull/8936 Is there any further information I can provide to help this along? Sorry to bug everyone about this, but after identifying the

Re: [DISCUSS] KIP-639 Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

Thank Bruno for your review. Changes was added as you sugested. Le 06/07/2020 à 14:57, Bruno Cadonna a écrit : Hi Mohamed, Thank you for the KIP. Comments regarding the KIP wiki: 1. In section "Public Interface", you should state what you want to change in interface StreamsMetrics. In your

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

See Changes: [github] MINOR: Improve logging around initial log loading (#8970) [github] KAFKA-9769: ReplicaManager Partition.makeFollower Increases LeaderEpoch [github] KAFKA-8398: Prevent NPE in

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

See

[jira] [Resolved] (KAFKA-10239) The groupInstanceId field in DescribeGroup response should be ignorable

[ https://issues.apache.org/jira/browse/KAFKA-10239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10239. - Resolution: Fixed > The groupInstanceId field in DescribeGroup response should be ignorable >

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

See Changes: [github] MINOR: prune the metadata upgrade test matrix (#8971) [github] KAFKA-10166: checkpoint recycled standbys and ignore empty rocksdb base [github] MINOR: document timestamped state stores