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

See Changes: [jason] MINOR: Link to related class in the Admin `alterPartitionReassignments` [wangguoz] KAFKA-9384: Loop improvements (#7907) [matthias] KAFKA-9068: Fix javadoc of Stores.{persistent,inMemory}S

[jira] [Created] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

Andy Bryant created KAFKA-9390: -- Summary: Non-key joining of KTable not compatible with confluent avro serdes Key: KAFKA-9390 URL: https://issues.apache.org/jira/browse/KAFKA-9390 Project: Kafka

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

See

Re: about default value of struct of connect api

update my findings, below is code of method 'defaultValue': public SchemaBuilder defaultValue(Object value) { checkCanSet(DEFAULT_FIELD, defaultValue, value); checkNotNull(TYPE_FIELD, type, DEFAULT_FIELD); try { ConnectSchema.validateValue(this, value);

Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

Sorry that I dropped the ball on this... Thanks for updating the KIP. Overall LGTM now. Feel free to start a VOTE thread. What is still unclear to me is, what we gain by having both `StreamsNotRunningException` and `StateStoreNotAvailableException`. Both exception are thrown when KafkaStreams is

[jira] [Resolved] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

[ https://issues.apache.org/jira/browse/KAFKA-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9068. Fix Version/s: 2.4.1 2.3.2 2.5.0 Resolution: Fi

[jira] [Resolved] (KAFKA-9384) Loop improvements

[ https://issues.apache.org/jira/browse/KAFKA-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9384. -- Fix Version/s: (was: 2.4.0) 2.5.0 Resolution: Fixed > Loop impro

[jira] [Resolved] (KAFKA-8988) Replace CreatePartitions request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8988. Fix Version/s: 2.5.0 Resolution: Fixed > Replace CreatePartitions request/response w

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

Thanks Guozhang for another review! I have addressed all the javadoc changes for PendingTransactionException in the KIP. For FENCED_INSTANCE_ID the only thrown place would be on the new send offsets API, which is also addressed. Thanks Matthias for the vote! As we have 3 binding votes (Guozhang, J

[jira] [Resolved] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6049. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams: Add Cogroup in the DSL > ---

[jira] [Created] (KAFKA-9389) Document how to use kafka-reassign-partitions.sh to change log dirs for a partition

James Cheng created KAFKA-9389: -- Summary: Document how to use kafka-reassign-partitions.sh to change log dirs for a partition Key: KAFKA-9389 URL: https://issues.apache.org/jira/browse/KAFKA-9389 Project

[jira] [Created] (KAFKA-9388) Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables

Matthias J. Sax created KAFKA-9388: -- Summary: Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables Key: KAFKA-9388 URL: https://issues.apache.org/jira/brow

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

I just re-read the KIP. Overall I am +1 as well. Some minor comments (also apply to the Google design doc): 1) As 2.4 was release, references should be updated to 2.5. 2) About the upgrade path, the KIP says: 2a) > Broker must be upgraded to 2.4 first. This means the > `inter.broker.protoco

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

Hello Boyang, I've reviewed the open PRs you have created and also made another pass on the wiki. Here's some more comments: Meta: 1. From the code I realized that the newly introduced PendingTransactionException can be thrown out of the public APIs too (see my comments in the PR, e.g. from cons

Need Help For Kafka Android Clients

Dear Concerned,​ Hope you are doing well. We wanted to create Apache Kafka Producer and Consumer Client for our Android app. But we are getting this error that the Management Factory is not present in Android. Is there any alternative way we can use for that? If we can, will you suggest any a

[jira] [Created] (KAFKA-9387) LZ4 Compression creates significant unnecessary CPU usage

Fabian Lange created KAFKA-9387: --- Summary: LZ4 Compression creates significant unnecessary CPU usage Key: KAFKA-9387 URL: https://issues.apache.org/jira/browse/KAFKA-9387 Project: Kafka Issue T

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

See Changes: [github] MINOR: Set MaxInlineLevel to 15 (#7811) -- [...truncated 2.80 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldCloseProcessor[Eos e

[jira] [Resolved] (KAFKA-8868) Consider auto-generating Streams binary protocol messages

[ https://issues.apache.org/jira/browse/KAFKA-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-8868. - Resolution: Fixed > Consider auto-generating Streams binary protocol messages > -

[jira] [Created] (KAFKA-9386) Flaky test AclAuthorizerTest.testHighConcurrencyDeletionOfResourceAcls

Rajini Sivaram created KAFKA-9386: - Summary: Flaky test AclAuthorizerTest.testHighConcurrencyDeletionOfResourceAcls Key: KAFKA-9386 URL: https://issues.apache.org/jira/browse/KAFKA-9386 Project: Kafka

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

See Changes: [github] MINOR: Fix assertion in testCreatePermissionMetadataRequestAutoCreate -- [...truncated 5.66 MB...] org.apache.kafka.streams.TestTopicsTest > testRe

[jira] [Resolved] (KAFKA-8959) Update Guava to 24 (or newer) or remove dependency

[ https://issues.apache.org/jira/browse/KAFKA-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8959. Resolution: Duplicate Marking this as a duplicate of KAFKA-3061 since the newest version of reflec

[jira] [Created] (KAFKA-9385) Connect cluster: connector task repeat like a splitbrain cluster problem

kaikai.hou created KAFKA-9385: - Summary: Connect cluster: connector task repeat like a splitbrain cluster problem Key: KAFKA-9385 URL: https://issues.apache.org/jira/browse/KAFKA-9385 Project: Kafka