Re: Kafka official docker image

Would it be possible to get official images that aren't Confluent branded and only include the things that are maintained by under the scope of the Apache PMC? IIRC, the Confluent images typically include extras that are maintained solely by Confluent. (e.g. implementation of code to work with

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

See Changes: [wangguoz] KAFKA-4850: Enable bloomfilters (#6012) [wangguoz] MINOR: fix race condition in KafkaStreamsTest (#6185) -- [...truncated 2.27 MB...]

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

See Changes: [wangguoz] KAFKA-4850: Enable bloomfilters (#6012) [wangguoz] MINOR: fix race condition in KafkaStreamsTest (#6185) -- [...truncated 2.26 MB...] > Task

Re: [EXTERNAL] [VOTE] KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

+1 (binding) My only final comment would be that the topic.creation.enable setting could potentially be left out. We're still backwards compatible with what we promised before (or at least compatibility is debatable). You could enforce not being able to create topics with ACLs anyway, so avoiding

Re: [VOTE] KIP-421: Support resolving externalized secrets in AbstractConfig

Hi Colin, If the configProvider is not configured we will return the unresolved value as is, so from the example the value returned will be ${file:/path/to/variables.properties:foo.bar} instead of the resolved value. We currently wont be supporting mechanism to update via subscribe so it

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

See Changes: [colin] MINOR: ducker-ak: add down -f, avoid using a terminal in ducker test -- [...truncated 2.27 MB...] org.apache.kafka.connect.json.JsonConverterTest >

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

See

[jira] [Created] (KAFKA-7866) Duplicate offsets after transaction index append failure

Jason Gustafson created KAFKA-7866: -- Summary: Duplicate offsets after transaction index append failure Key: KAFKA-7866 URL: https://issues.apache.org/jira/browse/KAFKA-7866 Project: Kafka

[jira] [Created] (KAFKA-7865) Kafka Constant Consumer Errors for ~30 min after Network Blip

Aravind Velamur Srinivasan created KAFKA-7865: - Summary: Kafka Constant Consumer Errors for ~30 min after Network Blip Key: KAFKA-7865 URL: https://issues.apache.org/jira/browse/KAFKA-7865

[jira] [Resolved] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-6995. Resolution: Won't Fix We are planning to deprecate this config with the introduction of KIP-345. 

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

See Changes: [me] KAFKA-5117: Stop resolving externalized configs in Connect REST API -- [...truncated 2.84 MB...]

[DISCUSSION] KIP-430: Add support for user/client configuration in the Kafka Admin Client

Hi folks, I've published KIP-430 which is about adding support for user/client configurations in the Kafka Admin Client. Basically the story here is to allow KafkaAdminClient to configure the user or client configurations for users, instead of requiring users to directly talk to ZK. The link

Re: [VOTE] KIP-420: Add Single Value Fetch in Session Stores

Hello Matthias, Cool. I'd add it to the wiki page as well. Guozhang On Sat, Jan 19, 2019 at 10:59 AM Matthias J. Sax wrote: > Thanks for the KIP Guozhang! > > Would it make sense to add a default implementation for the new method? > I am not sure, and I actually think it would not make

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

See

Re: [VOTE] KIP-421: Support resolving externalized secrets in AbstractConfig

Hi Tejal, Looks good overall. Can you please add this KIP to the wiki page at https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals ? What is the behavior when there is a configuration key which specifies a ConfigurationProvider which has not been supplied? For

[jira] [Created] (KAFKA-7864) AdminZkClient.validateTopicCreate() should validate that partitions are 0-based

Jun Rao created KAFKA-7864: -- Summary: AdminZkClient.validateTopicCreate() should validate that partitions are 0-based Key: KAFKA-7864 URL: https://issues.apache.org/jira/browse/KAFKA-7864 Project: Kafka

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

See Changes: [me] KAFKA-5117: Stop resolving externalized configs in Connect REST API -- [...truncated 2.27 MB...] org.apache.kafka.connect.runtime.isolation.PluginsTest

[jira] [Created] (KAFKA-7863) Kafka 1.1.1 JmxReporter doesn't remove old mbean(OOME as result)

Alexandr Minaev created KAFKA-7863: -- Summary: Kafka 1.1.1 JmxReporter doesn't remove old mbean(OOME as result) Key: KAFKA-7863 URL: https://issues.apache.org/jira/browse/KAFKA-7863 Project: Kafka

[jira] [Resolved] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-5117. -- Resolution: Fixed Assignee: Chris Egerton (was: Randall Hauch) Resolved with 

[jira] [Created] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

Boyang Chen created KAFKA-7862: -- Summary: Modify JoinGroup logic to incorporate group.instance.id change Key: KAFKA-7862 URL: https://issues.apache.org/jira/browse/KAFKA-7862 Project: Kafka

Re: KIP creation permissions

Thank Manikumar for telling me. Yes, I saw that, many functionalities have been included in the kafka-console-consumer.sh. Have a good evening! Best Regards, Daniele Ascione Il giorno mer 23 gen 2019 alle ore 15:45 Manikumar < manikumar.re...@gmail.com> ha scritto: > Done. Thanks for your

[jira] [Resolved] (KAFKA-7852) Add public version of EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7852. - Resolution: Duplicate > Add public version of EmbeddedKafkaCluster >

[jira] [Resolved] (KAFKA-5272) Improve validation for Alter Configs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivas Reddy resolved KAFKA-5272. --- Resolution: Fixed > Improve validation for Alter Configs (KIP-133) >

Re: [DISCUSS] KIP-400 - Improve exit status in case of errors in ConsoleProducer

Hi Dongjin, Can you please elaborate which shell scripts interoperability you are talking about? thanks Kamal On Sun, Jan 20, 2019 at 9:00 AM Dongjin Lee wrote: > Thank you for the KIP. In my opinion, this feature must work well with > shell scripts, by improving interoperability. Isn't it?

Re: KIP creation permissions

Done. Thanks for your interest. BTW, kafka-simple-consumer-shell was deprecated and removed in 2.0 release. On Wed, Jan 23, 2019 at 8:01 PM Daniele Ascione wrote: > Hello Kafka Team, > > I would like to have the permissions to create a KIP. I would like to > propose a feature for the

Re: Permissions to create KIP

Done. Thanks for your interest. On Wed, Jan 23, 2019 at 6:09 PM Suman B N wrote: > Hi Apache Kafka Team, > > Could you please grant me permission to create a KIP for Apache Kafka, I > wanted to propose a feature to ConsoleProducer in Kafka. > > Following are my details: > >- Full Name:

KIP creation permissions

Hello Kafka Team, I would like to have the permissions to create a KIP. I would like to propose a feature for the kafka-simple-consumer-shell . - username: ascione.d - Full Name: Daniele Ascione - Email: ascion...@gmail.com

[jira] [Created] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default

Edoardo Comar created KAFKA-7861: Summary: AlterConfig may change the source of another config entry if it matches the broker default Key: KAFKA-7861 URL: https://issues.apache.org/jira/browse/KAFKA-7861

Permissions to create KIP

Hi Apache Kafka Team, Could you please grant me permission to create a KIP for Apache Kafka, I wanted to propose a feature to ConsoleProducer in Kafka. Following are my details: - Full Name: Suman BN - Email: sumannew...@gmail.com - Wiki ID: sumannewton -- *Suman* *OlaCabs*

Re: [VOTE] KIP-421: Support resolving externalized secrets in AbstractConfig

+1 (non-binding) Best, Dongjin On Wed, Jan 23, 2019 at 2:54 AM Ryanne Dolan wrote: > +1 non-binding, thanks! > > Ryanne > > On Tue, Jan 22, 2019 at 11:38 AM te...@confluent.io > wrote: > > > > Hi all, > > > > We would like to start vote on KIP-421 to to enhance the AbstractConfig > base class

[jira] [Created] (KAFKA-7860) kafka broker restart isr lose

qinzl_1 created KAFKA-7860: -- Summary: kafka broker restart isr lose Key: KAFKA-7860 URL: https://issues.apache.org/jira/browse/KAFKA-7860 Project: Kafka Issue Type: Bug Reporter: