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

[ https://issues.apache.org/jira/browse/KAFKA-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9666. Resolution: Fixed > Transactional producer Epoch could not be reset >

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

See Changes: [github] MINOR: update required MacOS version (#9025) [github] KAFKA-10257 system test -- [...truncated 3.20 MB...]

[jira] [Reopened] (KAFKA-9161) Close gaps in Streams configs documentation

[ https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9161: > Close gaps in Streams configs documentation >

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

See

Re: [VOTE] KIP-554: Add Broker-side SCRAM Config API

On Tue, Jul 14, 2020, at 16:23, Ron Dagostino wrote: > Thanks, Colin. > > DescribeScramUsersResponse returns a list of ScramUser instances, which > makes sense, but then each of the ScramUser instances only has a single > ScramUserMechanismInfo instance. I believe it needs a List of those? Hi

Re: [DISCUSS] KIP-631: The Quorum-based Kafka Controller

On Mon, Jul 13, 2020, at 12:48, Jason Gustafson wrote: > Let me add a little more color to my question about the controller.id. I > have been assuming that each process would run a single Raft replication > thread for the metadata quorum, just that its role might be different. Some > would be

Re: [VOTE] 2.6.0 RC0

Thanks, Levani. The content of https://home.apache.org/~rhauch/kafka-2.6.0-rc0/kafka_2.12-2.6.0-site-docs.tgz is the correct generated site. Somehow I messed coping that to the https://github.com/apache/kafka-site/tree/asf-site/26 directory. I've corrected the latter so that

[jira] [Resolved] (KAFKA-10257) system test kafkatest.tests.core.security_rolling_upgrade_test fails

[ https://issues.apache.org/jira/browse/KAFKA-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-10257. - Fix Version/s: 2.6.0 Resolution: Fixed Merged to 2.6 and trunk. > system test

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

See

Re: Requesting permission to create KIP

Should be good to go now. On Wed, Jul 15, 2020 at 8:12 AM Nikhil kumar wrote: > Hi kafka-devs, > I am planning to add support for sources which can't give out changed > records in kafka connect. > Please, provide me permission to create KIP. > > Wiki id - nikhil578 > Email id -

Re: [VOTE] KIP-554: Add Broker-side SCRAM Config API

Hi all, Thanks, everyone, for reviewing. Since we made a few changes to the RPCs in the last few days, I'm going to extend the vote until Monday and close it out then if it looks good. best, Colin On Wed, Jul 15, 2020, at 14:47, Colin McCabe wrote: > On Tue, Jul 14, 2020, at 16:23, Ron

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

See Changes: [github] MINOR: Add ApiMessageTypeGenerator (#9002) -- [...truncated 3.20 MB...] org.apache.kafka.streams.TestTopicsTest > testEmptyTopic STARTED

Re: [VOTE] 2.6.0 RC0

Hi Randall, Not sure if it’s intentional but, documentation for Kafka Streams 2.6.0 also contains “Streams API changes in 2.7.0” https://kafka.apache.org/26/documentation/streams/upgrade-guide Also, there seems to be some

[jira] [Created] (KAFKA-10275) Error bitnami -Unable to connect Kafka to zookeeper over SASL and SSL

Narendra Jadhav created KAFKA-10275: --- Summary: Error bitnami -Unable to connect Kafka to zookeeper over SASL and SSL Key: KAFKA-10275 URL: https://issues.apache.org/jira/browse/KAFKA-10275

[jira] [Created] (KAFKA-10276) Kafka kerberos caching key tabs in default instance not kerberos service name for multi cluster configuration

winkidzz created KAFKA-10276: Summary: Kafka kerberos caching key tabs in default instance not kerberos service name for multi cluster configuration Key: KAFKA-10276 URL:

[jira] [Created] (KAFKA-10277) Relax non-null key requirement for stream-globalTable joins

Matthias J. Sax created KAFKA-10277: --- Summary: Relax non-null key requirement for stream-globalTable joins Key: KAFKA-10277 URL: https://issues.apache.org/jira/browse/KAFKA-10277 Project: Kafka

Re: [VOTE] KIP-554: Add Broker-side SCRAM Config API

Hi again, Colin. I believe the below function should refer to List alterations in its signature and should invoke alterScramUsers(alterations, new AlterScramUsersOptions()), correct? default AlterScramUsersResult alterScramUsers(List alterations) { return alterScramUsers(deletions,

Requesting permission to create KIP

Hi kafka-devs, I am planning to add support for sources which can't give out changed records in kafka connect. Please, provide me permission to create KIP. Wiki id - nikhil578 Email id - nikhilkumar...@gmail.com Thanks, Nikhil

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

See Changes: [jason] KAFKA-9666; Don't increase producer epoch when trying to fence if the -- [...truncated 3.15 MB...]

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Ying, Thanks for the response. It sounds like you agree that storing the metadata in the remote storage would be a better design overall. Given that that's true, is there any reason to include the worse implementation based on RocksDB? Choosing a long-term metadata store is not something

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

See Changes: [junrao] KAFKA-10257 system test -- [...truncated 6.30 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

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

See Changes: [github] KAFKA-9666; Don't increase producer epoch when trying to fence if the -- [...truncated 3.20 MB...] org.apache.kafka.streams.TopologyTestDriverTest

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Colin, Thats not what we said in the previous email. RLMM is pluggable storage and by running numbers even 1PB data you do not need more than 10GB local storage. If in future this becomes a blocker for any users we can revisit but this does not warrant another implementation at

Re: [DISCUSS] KIP-631: The Quorum-based Kafka Controller

On Mon, Jul 13, 2020, at 11:08, Boyang Chen wrote: > Hey Colin, some quick questions, > > 1. I looked around and didn't find a config for broker heartbeat interval, > are we piggy-back on some existing configs? > Good point. I meant to add this, but I forgot. I added