[jira] [Created] (KAFKA-9934) Information and doc update needed for support of AclAuthorizer when protocol is PLAINTEXT

kaushik srinivas created KAFKA-9934: --- Summary: Information and doc update needed for support of AclAuthorizer when protocol is PLAINTEXT Key: KAFKA-9934 URL: https://issues.apache.org/jira/browse/KAFKA-9934

[jira] [Created] (KAFKA-9933) Need doc update on the AclAuthorizer when SASL_SSL is the protocol used.

kaushik srinivas created KAFKA-9933: --- Summary: Need doc update on the AclAuthorizer when SASL_SSL is the protocol used. Key: KAFKA-9933 URL: https://issues.apache.org/jira/browse/KAFKA-9933

[jira] [Created] (KAFKA-9932) First LeaderAndIsrRequest can take long due to unnecessary ZK read

Ismael Juma created KAFKA-9932: -- Summary: First LeaderAndIsrRequest can take long due to unnecessary ZK read Key: KAFKA-9932 URL: https://issues.apache.org/jira/browse/KAFKA-9932 Project: Kafka

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

See Changes: [github] KAFKA-9127: don't create StreamThreads for global-only topology (#8540) -- [...truncated 1.52 MB...]

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

See Changes: [github] KAFKA-9127: don't create StreamThreads for global-only topology (#8540) -- [...truncated 1.52 MB...]

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

See Changes: [github] MINOR: Test compilation fixes for Scala 2.11 (#8562) -- [...truncated 2.76 MB...] org.apache.kafka.streams.MockProcessorContextTest >

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

See Changes: [github] KAFKA-9823: Follow-up, check state for handling commit error response [github] KAFKA-9176: Retry on getting local stores from KafkaStreams (#8568)

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

See Changes: [gwen] MINOR: add support for kafka 2.4 and 2.5 to downgrade test -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.SetSchemaMetadataTest >

[jira] [Created] (KAFKA-9931) Kafka Connect should accept '-1' as a valid replication factor

Randall Hauch created KAFKA-9931: Summary: Kafka Connect should accept '-1' as a valid replication factor Key: KAFKA-9931 URL: https://issues.apache.org/jira/browse/KAFKA-9931 Project: Kafka

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

See Changes: [gwen] MINOR: add support for kafka 2.4 and 2.5 to downgrade test -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConverterTest >

[jira] [Created] (KAFKA-9930) Prevent ReplicaFetcherThread from throwing UnknownTopicOrPartitionException upon topic creation and deletion.

Adem Efe Gencer created KAFKA-9930: -- Summary: Prevent ReplicaFetcherThread from throwing UnknownTopicOrPartitionException upon topic creation and deletion. Key: KAFKA-9930 URL:

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

See Changes: [github] KAFKA-6145: KIP-441: Add TaskAssignor class config (#8541) -- [...truncated 6.11 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: [DISCUSS] KIP-595: A Raft Protocol for the Metadata Quorum

Hi Jason, It's amazing to see this coming together :) I haven't had a chance to read in detail, but I read the outline and a few things jumped out at me. First, for every epoch that is 32 bits rather than 64, I sort of wonder if that's a good long-term choice. I keep reading about stuff like

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

See Changes: [wangguoz] KAFKA-9921: disable caching on stores configured to retain duplicates [konstantine] MINOR: Fix partition numbering from 0 to P-1 instead of P in docs

[jira] [Created] (KAFKA-9929) Support reverse iterator on WindowStore

Jorge Esteban Quilcate Otoya created KAFKA-9929: --- Summary: Support reverse iterator on WindowStore Key: KAFKA-9929 URL: https://issues.apache.org/jira/browse/KAFKA-9929 Project: Kafka

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

See Changes: [github] KAFKA-9176: Retry on getting local stores from KafkaStreams (#8568) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.FlattenTest >

[DISCUSS] KIP-317 - Add end-to-end data encryption functionality to Apache Kafka

All, I've asked for comments on this KIP in the past, but since I didn't really get any feedback I've decided to reduce the initial scope of the KIP a bit and try again. I have reworked to KIP to provide a limited, but useful set of features for this initial KIP and laid out a very rough roadmap

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

See Changes: [github] KAFKA-9823: Follow-up, check state for handling commit error response [github] KAFKA-9176: Retry on getting local stores from KafkaStreams (#8568)

Re: [DISCUSS] KIP-589 Add API to Update Replica State in Controller

Hi David, Thanks for the KIP! I think the ReplicaStateEventResponse should have a separate error code for each partition. Currently it just has one error code for the whole request/response, if I'm reading this right. I think Jose made a similar point as well. We should plan for scenarios

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

See Changes: [github] KAFKA-6145: KIP-441: Add TaskAssignor class config (#8541) [github] KAFKA-9823: Follow-up, check state for handling commit error response --

Re: [DISCUSS] KIP-601: Configurable socket connection timeout

Hi Cheng, Thanks for the KIP. > Currently, the initial socket connection timeout is depending on system > setting tcp_syn_retries. The actual timeout value is 2 ^ (tcp_sync_retries + > 1) - 1 seconds This section is confusing since it refers to Linux configuration settings without mentioning

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

See Changes: [github] KAFKA-6145: KIP-441: Add TaskAssignor class config (#8541) -- [...truncated 1.51 MB...]

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

See Changes: [github] KAFKA-9921: disable caching on stores configured to retain duplicates [github] MINOR: Fix partition numbering from 0 to P-1 instead of P in docs

[jira] [Created] (KAFKA-9928) Flaky GlobalKTableEOSIntegrationTest#shouldKStreamGlobalKTableLeftJoin[exactly_once_beta]

Guozhang Wang created KAFKA-9928: Summary: Flaky GlobalKTableEOSIntegrationTest#shouldKStreamGlobalKTableLeftJoin[exactly_once_beta] Key: KAFKA-9928 URL: https://issues.apache.org/jira/browse/KAFKA-9928

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

See Changes: [github] KAFKA-9921: disable caching on stores configured to retain duplicates [github] MINOR: Fix partition numbering from 0 to P-1 instead of P in docs

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

See Changes: [github] KAFKA-9921: disable caching on stores configured to retain duplicates [github] MINOR: Fix partition numbering from 0 to P-1 instead of P in docs --

Re: [DISCUSS] KIP-591: Add Kafka Streams config to set default store type

Hi Matthias, We had another quick discussion on https://issues.apache.org/jira/browse/KAFKA-9925 regarding deprecating the old StreamsBuilder#build overload. Just copying it here: There's risk of course that the props passed in `build` is not the same as the one passed into the `KafkaStreams`

Re: [Discuss] KIP-581: Value of optional null field which has default value

Hi Chris, Thanks for your reminder, the original implement is deprecated, I just update the JIRA with the new PR link: https://github.com/apache/kafka/pull/8575 As question 2), I agree with you that we should consider both serialization and deserialization, and as you said, I only

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

See Changes: [github] Minor: remove redundant check in auto preferred leader election (#8566) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.CastTest >

[jira] [Created] (KAFKA-9927) Add support for varint types to message generator

Jason Gustafson created KAFKA-9927: -- Summary: Add support for varint types to message generator Key: KAFKA-9927 URL: https://issues.apache.org/jira/browse/KAFKA-9927 Project: Kafka Issue

[jira] [Created] (KAFKA-9926) Flaky test PlaintextAdminIntegrationTest.testCreatePartitions

Wang Ge created KAFKA-9926: -- Summary: Flaky test PlaintextAdminIntegrationTest.testCreatePartitions Key: KAFKA-9926 URL: https://issues.apache.org/jira/browse/KAFKA-9926 Project: Kafka Issue Type:

[DISCUSS] KIP-603 - Change `ConfigEntry` value to use optional fields

Hi Kafka developers, I'd like to start the discussion for KIP - 603 . The gist of the KIP is to use `Optional` for a field that can be null to provide a better API for the callers.

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

See Changes: [github] Minor: remove redundant check in auto preferred leader election (#8566) -- [...truncated 1.52 MB...]

Re: updates on Kafka Summit in 2020

Hi, Everyone, Given the current global health crisis and ongoing uncertainty, we have decided to go virtual for Kafka Summit "Austin." The CFP deadline has been extended to May 17, 2020. More details can be found at https://events.kafka-summit.org/2020-faq. Thanks, Jun On Wed, Apr 15, 2020 at

Re: Apache Kafka Streams with Sprinng Boot

Sure Khaja. Thanks C Suresh On Tuesday, April 28, 2020, KhajaAsmath Mohammed wrote: > Hello Suresh, > > I am also looking for the same. Let me know if you find anything > > Sent from my iPhone > > > On Apr 28, 2020, at 8:25 PM, Suresh Chidambaram > wrote: > > > > Hi Team, > > > > Greetings.

Re: Apache Kafka Streams with Sprinng Boot

Hello Suresh, I am also looking for the same. Let me know if you find anything Sent from my iPhone > On Apr 28, 2020, at 8:25 PM, Suresh Chidambaram > wrote: > > Hi Team, > > Greetings. > > I have been looking for an example application which uses Kafka Streams > with Spring Boot, but

Apache Kafka Streams with Sprinng Boot

Hi Team, Greetings. I have been looking for an example application which uses Kafka Streams with Spring Boot, but I'm unable to find one in the internet. Could someone help me by providing the code? Thanks C Suresh

Re: [DISCUSS] KIP-585: Conditional SMT

Hi Tom, I think we should go for a consistent naming convention for the predicates, maybe so they read nicely if you say "IF" first. Here's a suggestion for predicates that the KIP could introduce: - TopicNameMatches - HeaderKeyMatches - RecordIsTombstone On naming, I also suggest using

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

See Changes: [konstantine] MINOR: Fix typos in config properties in MM2 test (#8561) -- [...truncated 7.04 MB...] org.apache.kafka.connect.transforms.CastTest >

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

See

[jira] [Created] (KAFKA-9925) Non-key KTable Joining result in duplicate schema name in confluence schema registry

Kin Siu created KAFKA-9925: -- Summary: Non-key KTable Joining result in duplicate schema name in confluence schema registry Key: KAFKA-9925 URL: https://issues.apache.org/jira/browse/KAFKA-9925 Project:

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

See

[jira] [Created] (KAFKA-9924) Add RocksDB Memory Consumption to RocksDB Metrics

Bruno Cadonna created KAFKA-9924: Summary: Add RocksDB Memory Consumption to RocksDB Metrics Key: KAFKA-9924 URL: https://issues.apache.org/jira/browse/KAFKA-9924 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-585: Conditional SMT

Hi Andrew and Chris, Firstly, thanks for the input. To me, the ?type syntax has some pros and cons. On the pros side: * it's pretty succinct * it's flexible enough for the use cases we've identified so far. On the cons side: * it's a bit cryptic; I don't think people who didn't know it already

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

See Changes: [github] MINOR: Fix typos in config properties in MM2 test (#8561) [github] MINOR: Update the link to the Raft paper in docs (#8560) -- [...truncated 1.51

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

See Changes: [github] MINOR: Fix typos in config properties in MM2 test (#8561) [github] MINOR: Update the link to the Raft paper in docs (#8560) -- [...truncated 1.52