[jira] [Created] (KAFKA-9670) Benchmark and optimize MetadataResponse preparation

Manikumar created KAFKA-9670: Summary: Benchmark and optimize MetadataResponse preparation Key: KAFKA-9670 URL: https://issues.apache.org/jira/browse/KAFKA-9670 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-9669) Kafka 2.4.0 Chokes on Filebeat 5.6 Produced Data

Weichu Liu created KAFKA-9669: - Summary: Kafka 2.4.0 Chokes on Filebeat 5.6 Produced Data Key: KAFKA-9669 URL: https://issues.apache.org/jira/browse/KAFKA-9669 Project: Kafka Issue Type: Bug

Build failed in Jenkins: kafka-2.1-jdk8 #254

See Changes: [github] KAFKA-8245: Fix Flaky Test -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H29

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

See

Re: [VOTE] KIP-557: Add emit on change support for Kafka Streams

Hi all, Just polling for some last changes on the name. I think that since there doesn't seem to be much objection to any major changes in the KIP, I will pass it this Friday. If you feel that we still need some more discussion, please let me know. :) Best, Richard P.S. Will start working on a

Build failed in Jenkins: kafka-2.5-jdk8 #56

See Changes: [mumrah] KAFKA-9661: Propagate includeSynonyms option to AdminClient in -- [...truncated 5.86 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-9615: Clean up task/producer create and close (#8213) -- [...truncated 2.90 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Create content permission

Hello, My name is Cheng Tan and I’m working at Confluent. Can I get the create content permission so I can create a KIP? Thank you. Best, - Cheng Tan

[jira] [Created] (KAFKA-9668) Iterating over KafkaStreams.getAllMetadata() results in ConcurrentModificationException

Andy Coates created KAFKA-9668: -- Summary: Iterating over KafkaStreams.getAllMetadata() results in ConcurrentModificationException Key: KAFKA-9668 URL: https://issues.apache.org/jira/browse/KAFKA-9668

Re: [VOTE] KIP-447: Producer scalability for exactly once semantics

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 There is one more change to this KIP for the upgrade path of Kafka Streams applications: We cannot detect broker versions reliable, and thus, we need users to manually opt-in to the feature. Thus, we need to add a third value for configuration

[jira] [Resolved] (KAFKA-9661) Config synonyms are no longer included in kafka-configs --describe output

[ https://issues.apache.org/jira/browse/KAFKA-9661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9661. --- Fix Version/s: 2.5.0 Reviewer: David Arthur Resolution: Fixed > Config

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

See Changes: [github] KAFKA-9661: Propagate includeSynonyms option to AdminClient in -- [...truncated 2.90 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-9661: Propagate includeSynonyms option to AdminClient in -- [...truncated 2.88 MB...]

Re: [VOTE] KIP-131 - Add access to OffsetStorageReader from SourceConnector

Status: this KIP has 2 binding +1 votes, but has not yet passed. :-( I'm very interested in getting this into AK 2.6, but have another suggestion to make on the KIP. The current KIP is great and allows connectors using the latest Connect API to get access to the offset reader. Unfortunately, this

Re: Discussion on new feature to Kafka Streams API

Hello Muhammad, What you described here seems like an "append" aggregation, i.e. the aggregated value is the concatenated list of records, and each aggregation is to append the newly arrived record of the key to that concatenation list. Right? Guozhang On Mon, Mar 2, 2020 at 6:51 AM Muhammad

Re: 回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Feyman, thanks a lot for the KIP. Overall LGTM. I have a few more comment and questions (sorry for the late reply): The KIP mentions that some constructors will be deprecated. Those should be listed explicitly. For example: public class

[jira] [Created] (KAFKA-9667) Connect JSON serde strip trailing zeros

Andy Coates created KAFKA-9667: -- Summary: Connect JSON serde strip trailing zeros Key: KAFKA-9667 URL: https://issues.apache.org/jira/browse/KAFKA-9667 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-9666) Transactional producer Epoch could not be reset

Boyang Chen created KAFKA-9666: -- Summary: Transactional producer Epoch could not be reset Key: KAFKA-9666 URL: https://issues.apache.org/jira/browse/KAFKA-9666 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-9665) Scala compile not producing unused warnings

David Arthur created KAFKA-9665: --- Summary: Scala compile not producing unused warnings Key: KAFKA-9665 URL: https://issues.apache.org/jira/browse/KAFKA-9665 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-9664) Flaky Test KafkaStreamsTest#testStateThreadClose

Sophie Blee-Goldman created KAFKA-9664: -- Summary: Flaky Test KafkaStreamsTest#testStateThreadClose Key: KAFKA-9664 URL: https://issues.apache.org/jira/browse/KAFKA-9664 Project: Kafka

Re: 回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

Thanks for the KIP. +1 (binding). -Bill On Wed, Mar 4, 2020 at 12:40 AM Guozhang Wang wrote: > Thanks, +1 from me (binding). > > On Tue, Mar 3, 2020 at 9:39 PM feyman2009 wrote: > > > Hi, Guozhang > > Thanks a lot for the advice, that make sense! > > I have updated the KIP page

Jenkins build is back to normal : kafka-2.4-jdk8 #164

See

[jira] [Created] (KAFKA-9663) KafkaStreams.metadataForKey, queryMetadataForKey docs don't mention null

Tom Bentley created KAFKA-9663: -- Summary: KafkaStreams.metadataForKey, queryMetadataForKey docs don't mention null Key: KAFKA-9663 URL: https://issues.apache.org/jira/browse/KAFKA-9663 Project: Kafka

[jira] [Created] (KAFKA-9662) Throttling system test fails when messages are produced before consumer starts up

Rajini Sivaram created KAFKA-9662: - Summary: Throttling system test fails when messages are produced before consumer starts up Key: KAFKA-9662 URL: https://issues.apache.org/jira/browse/KAFKA-9662

[jira] [Created] (KAFKA-9661) Config synonyms are no longer included in kafka-configs --describe output

Rajini Sivaram created KAFKA-9661: - Summary: Config synonyms are no longer included in kafka-configs --describe output Key: KAFKA-9661 URL: https://issues.apache.org/jira/browse/KAFKA-9661 Project:

Jenkins build is back to normal : kafka-2.5-jdk8 #55

See

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

See Changes: [github] MINOR: Add an extra check in StreamThreadTest (#8214) -- [...truncated 1.82 MB...] kafka.zookeeper.ZooKeeperClientTest >