Community over Code EU 2024: The countdown has started!

[Note: You're receiving this email because you are subscribed to one or more project dev@ mailing lists at the Apache Software Foundation.] We are very close to Community Over Code EU -- check out the amazing program and the special discounts that we have for you. Special discounts You still hav

Community over Code EU 2024: Start planning your trip!

[Note: You're receiving this email because you are subscribed to one or more project dev@ mailing lists at the Apache Software Foundation.] Dear community, We hope you are doing great, are you ready for Community Over Code EU? Check out the featured sessions, get your tickets with special discoun

[jira] [Created] (KAFKA-16235) auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION

Ryan Leslie created KAFKA-16235: --- Summary: auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION Key: KAFKA-16235 URL: https://issues.apache.org/jira/browse/KAFKA-16235 Project

Meet our keynote speakers and register to Community Over Code EU!

[Note: You're receiving this email because you are subscribed to one or more project dev@ mailing lists at the Apache Software Foundation.] * Merge with the ASF EUniverse!The registration for Community

Call for Presentations now open: Community over Code EU 2024

excellent platform for showcasing high-level projects and incubator initiatives in a visually engaging manner. We believe this will foster lively discussions and facilitate networking opportunities among participants. All my best, and thanks so much for your participation, Ryan Skraba (on be

Re:Timeout not getting applied on KafkaAdminClient.create

If the broker connection is timing out then see if tuning SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG / SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG helps. The MAX defaults to 30 seconds. From: dev@kafka.apache.org At: 02/13/23 08:46:12 UTC-5:00To: dev@kafka.apache.org Subject: Timeout not gett

[jira] [Created] (KAFKA-14237) Kafka TLS Doesn't Present Intermediary Certificates when using PEM

Ryan R created KAFKA-14237: -- Summary: Kafka TLS Doesn't Present Intermediary Certificates when using PEM Key: KAFKA-14237 URL: https://issues.apache.org/jira/browse/KAFKA-14237 Project:

Re: [DISCUSS] KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols

To: RYAN LESLIE, dev@kafka.apache.org At: 02/16/22 22:02:41 UTC-05:00 Hi Ryan, > I've used pause() between version 0.10 and 2.7 with EAGER protocol only and have not yet observed cases where poll() returned messages unless resume() had been called. Yes, this issue only happens wh

Re: [DISCUSS] KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols

Apologies, but as worded KIP-822 / KAFKA-13425 are a bit challenging to follow. I've used pause() between version 0.10 and 2.7 with EAGER protocol only and have not yet observed cases where poll() returned messages unless resume() had been called. The KIP seems to contradict this though, and ind

Re: [VOTE] KIP-814: Static membership protocol should let the leader skip assignment

Thanks, David. +1 (non-binding) From: show...@gmail.com At: 01/31/22 22:13:57 UTC-5:00To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-814: Static membership protocol should let the leader skip assignment Hi David, Thanks for the KIP. I'm +1(non-binding) Thanks. Luke Jason Gustafson 於 202

[jira] [Created] (KAFKA-13435) Group won't consume partitions added after static member restart

Ryan Leslie created KAFKA-13435: --- Summary: Group won't consume partitions added after static member restart Key: KAFKA-13435 URL: https://issues.apache.org/jira/browse/KAFKA-13435 Project:

Re: [VOTE] KIP 771: KRaft brokers should not expose controller metrics

Hello all, Thank you all for the votes! With 3 binding and 1 non-binding vote this KIP will be accepted. Regards, Ryan Dielhenn On Tue, Sep 21, 2021 at 11:44 AM Ismael Juma wrote: > Thanks for the KIP, +1 (binding). > > Ismael > > On Thu, Sep 2, 2021 at 1:20 PM Ryan Die

Re: [DISCUSS] KIP-771: KRaft broker should not expose controller metrics

KIP: https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=188743985&selectedPageVersions=16&selectedPageVersions=14 Regards, Ryan Dielhenn On Fri, Aug 27, 2021 at 2:19 PM Ryan Dielhenn wrote: > Hello kafka devs, > > I would like to start a discussion on a K

Re: [DISCUSS] KIP-771: KRaft broker should not expose controller metrics

Thanks for the suggestions Colin, I updated the KIP, here are the changes: https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=188743985&selectedPageVersions=14&selectedPageVersions=13 Regards, Ryan Dielhenn On 2021/09/07 16:46:13, "Colin McCabe" wr

[VOTE] KIP 771: KRaft brokers should not expose controller metrics

/r74432034527fab13cc973ad5187ef5881a642500d77b0d275dd7f018%40%3Cdev.kafka.apache.org%3E Regards, Ryan Dielhenn

Re: [DISCUSS] KIP-771: KRaft broker should not expose controller metrics

Thank you Ron & Colin for the comments. I have updated the KIP with the suggested changes: https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=188743985&selectedPageVersions=6&selectedPageVersions=5 Regards, Ryan Dielhenn On 2021/08/31 22:41:21, "Col

[DISCUSS] KIP-771: KRaft broker should not expose controller metrics

Hello kafka devs, I would like to start a discussion on a KIP I have created to change how controller metrics are exposed for KRaft brokers. Here is the KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP+771%3A+KRaft+brokers+should+not+expose+controller+metrics Regards, Ryan Dielhenn

[jira] [Created] (KAFKA-13245) KIP 771: Change behavior of how controller metrics are exposed when using KRaft.

Ryan Dielhenn created KAFKA-13245: - Summary: KIP 771: Change behavior of how controller metrics are exposed when using KRaft. Key: KAFKA-13245 URL: https://issues.apache.org/jira/browse/KAFKA-13245

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

broker configuration. I filed a JIRA: https://issues.apache.org/jira/browse/KAFKA-13160 I also have a PR to fix this: https://github.com/apache/kafka/pull/11168 I think that this should be a blocker for 3.0 because dynamic default broker configs will not be usable in KRaft otherwise. Best, Ryan D

[jira] [Created] (KAFKA-13160) Fix BrokerConfigHandler to expect empty string as the resource name for dynamic default broker configs in KRaft

Ryan Dielhenn created KAFKA-13160: - Summary: Fix BrokerConfigHandler to expect empty string as the resource name for dynamic default broker configs in KRaft Key: KAFKA-13160 URL: https://issues.apache.org/jira

[jira] [Resolved] (KAFKA-13153) Disallow KRaft broker registration if the node.id is already in use

[ https://issues.apache.org/jira/browse/KAFKA-13153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Dielhenn resolved KAFKA-13153. --- Resolution: Won't Fix This would render colocated Kraft useless. > Disallow KRaf

[jira] [Created] (KAFKA-13153) Disallow KRaft broker registration if the node.id is already in use

Ryan Dielhenn created KAFKA-13153: - Summary: Disallow KRaft broker registration if the node.id is already in use Key: KAFKA-13153 URL: https://issues.apache.org/jira/browse/KAFKA-13153 Project: Kafka

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Hey Konstantine, Thanks for the question. If these configs are not validated the user's experience will be affected and upgrades from 3.0 will be harder. Best, Ryan Dielhenn On Thu, Jul 29, 2021 at 3:59 PM Konstantine Karantasis < kkaranta...@apache.org> wrote: > Thanks for

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Hi, Disregard log.clean.policy being included in this blocker. Best, Ryan Dielhenn On Thu, Jul 29, 2021 at 2:38 PM Ryan Dielhenn wrote: > Hey Konstantine, > > I'd like to report another bug in KRaft. > > log.cleanup.policy, alter.config.policy.class.name, and > create.

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

hould fail startup if any of these are configured. I do not have a PR yet but will soon. On another note, I have a PR for the dynamic broker configuration fix here: https://github.com/apache/kafka/pull/11141 Best, Ryan Dielhenn On Wed, May 26, 2021 at 2:48 PM Konstantine Karantasis wrote: >

[jira] [Created] (KAFKA-13151) KRaft does not support Policies (e.g. AlterConfigPolicy). The server should fail startup if any are configured.

Ryan Dielhenn created KAFKA-13151: - Summary: KRaft does not support Policies (e.g. AlterConfigPolicy). The server should fail startup if any are configured. Key: KAFKA-13151 URL: https://issues.apache.org/jira

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

. If invalid dynamic configs are persisted to metadata then they will still be there after an upgrade. I believe that this should be considered as a blocker for 3.0 here is the JIRA: https://issues.apache.org/jira/browse/KAFKA-13142. I will be working on a PR this week. Best Regards, Ryan On Wed

[jira] [Created] (KAFKA-13142) KRaft controller does not validate dynamic configs

Ryan Dielhenn created KAFKA-13142: - Summary: KRaft controller does not validate dynamic configs Key: KAFKA-13142 URL: https://issues.apache.org/jira/browse/KAFKA-13142 Project: Kafka Issue

[jira] [Created] (KAFKA-13051) Require Principal Serde to be defined for 3.0

Ryan Dielhenn created KAFKA-13051: - Summary: Require Principal Serde to be defined for 3.0 Key: KAFKA-13051 URL: https://issues.apache.org/jira/browse/KAFKA-13051 Project: Kafka Issue Type

[jira] [Created] (KAFKA-12953) Bump Zookeeper version to 3.6.3

Ryan Dielhenn created KAFKA-12953: - Summary: Bump Zookeeper version to 3.6.3 Key: KAFKA-12953 URL: https://issues.apache.org/jira/browse/KAFKA-12953 Project: Kafka Issue Type: Task

Re: [DISCUSS] KIP-748: Add Broker Count Metrics

Hey all, I removed the table for the ZK metric and specified that `kafka.controller:type=KafkaController` is used by both ZK and Quorum controllers. Best, Ryan Dielhenn On 2021/06/14 17:56:59, Xavier Léauté wrote: > Any reason we need two different metrics for ZK an Quorum based controll

[VOTE] KIP-748: Add Broker Count Metrics

/r308364dfbb3020e6151cef47237c28a4a540e187b8af84ddafec83af%40%3Cdev.kafka.apache.org%3E Please take a look and vote if you have a chance. Thank you, Ryan

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

C/C++ users in librdkafka, so not many in that community have tried incremental cooperative yet. And bugs are still recently being worked out there too. Just playing devil's advocate here, sorry to come across as a negative nancy! On 2021/06/09 00:05:41, Sophie Blee-Goldman wrote: &g

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

Hey guys, Should open bugs concerning cooperative-sticky also be considered blockers to making it the default? For example, KAFKA-12896 is perhaps still being investigated: https://issues.apache.org/jira/browse/KAFKA-12896 Thanks, Ryan From: dev@kafka.apache.org At: 06/07/21 19:37:45 UTC-4

Re: [DISCUSS] KIP-748: Add Broker Count Metrics

Hey Colin and David, I added another table for the ZK version of RegisteredBrokerCount. Best, Ryan Dielhenn On 2021/06/04 08:21:27, David Jacot wrote: > Hi Ryan, > > Thanks for the KIP. > > +1 for adding RegisteredBrokerCount to the ZK controller as well. This > would

[DISCUSS] KIP-748: Add Broker Count Metrics

Hey kafka-dev, I created KIP-748 as a proposal to add broker count metrics to the Quorum Controller. https://cwiki.apache.org/confluence/display/KAFKA/KIP-748%3A+Add+Broker+Count+Metrics#KIP748:AddBrokerCountMetrics Best, Ryan Dielhenn

[DISCUSS] KIP-748 Kafka Consumer Record Latency Metric

Hey kafka-dev, I created KIP-748 as a proposal to add broker count metrics to the Quorum Controller. https://cwiki.apache.org/confluence/display/KAFKA/KIP-748%3A+Add+Broker+Count+Metrics#KIP748:AddBrokerCountMetrics Best, Ryan Dielhenn

[jira] [Created] (KAFKA-12882) Add RegisteredBrokerCount and UnfencedBrokerCount metrics to the QuorumController

Ryan Dielhenn created KAFKA-12882: - Summary: Add RegisteredBrokerCount and UnfencedBrokerCount metrics to the QuorumController Key: KAFKA-12882 URL: https://issues.apache.org/jira/browse/KAFKA-12882

[jira] [Created] (KAFKA-12838) Kafka Broker - Request threads inefficiently blocking during produce

Ryan Cabral created KAFKA-12838: --- Summary: Kafka Broker - Request threads inefficiently blocking during produce Key: KAFKA-12838 URL: https://issues.apache.org/jira/browse/KAFKA-12838 Project: Kafka

[jira] [Created] (KAFKA-12697) Add GlobalTopicCount and GlobalPartitionCount metrics to QuorumController

Ryan Dielhenn created KAFKA-12697: - Summary: Add GlobalTopicCount and GlobalPartitionCount metrics to QuorumController Key: KAFKA-12697 URL: https://issues.apache.org/jira/browse/KAFKA-12697 Project

[jira] [Created] (KAFKA-12692) Enforce config types in ConfigurationControlManager

Ryan Dielhenn created KAFKA-12692: - Summary: Enforce config types in ConfigurationControlManager Key: KAFKA-12692 URL: https://issues.apache.org/jira/browse/KAFKA-12692 Project: Kafka Issue

Permission to Assign Jiras

Hello, May I have permission to assign Jiras to myself? I just got this done https://issues.apache.org/jira/browse/KAFKA-12265 but don't have access to reassign it. Best, Ryan Dielhenn

[jira] [Created] (KAFKA-12257) Consumer mishandles topics deleted and recreated with the same name

Ryan Leslie created KAFKA-12257: --- Summary: Consumer mishandles topics deleted and recreated with the same name Key: KAFKA-12257 URL: https://issues.apache.org/jira/browse/KAFKA-12257 Project: Kafka

[jira] [Created] (KAFKA-12256) auto commit causes delays due to retribale UNKNOWN_TOPIC_OR_PARTITION

Ryan Leslie created KAFKA-12256: --- Summary: auto commit causes delays due to retribale UNKNOWN_TOPIC_OR_PARTITION Key: KAFKA-12256 URL: https://issues.apache.org/jira/browse/KAFKA-12256 Project: Kafka

Re:[DISCUSS] KIP-700: Add Describe Cluster API

e is a better way to do this. Thanks, Ryan Leslie

[jira] [Created] (KAFKA-10625) Add Union to Connect Schema

Ryan created KAFKA-10625: Summary: Add Union to Connect Schema Key: KAFKA-10625 URL: https://issues.apache.org/jira/browse/KAFKA-10625 Project: Kafka Issue Type: Improvement Components

Re: [DISCUSS] KIP-649: Dynamic Client Configuration

ered with a particular entity to be aggregated and returned to the user in the DescribeClientConfigsResponse. Could clients register their configs every time that they update their configs? This way a log retention time could be set on the internal topic so that only data from active clients

Re: [DISCUSS] KIP-649: Dynamic Client Configuration

he GroupCoordinator’s metadata and if the group member that is rejoining is in a stable state. In practice this just changes the behavior of the leader of the group when the timeout is updated since the leader is the only one that will trigger a rebalance when rejoining while in a stable state.

Re: [DISCUSS] KIP-649: Dynamic Client Configuration

he GroupCoordinator’s metadata and if the group member that is rejoining is in a stable state. In practice this just changes the behavior of the leader of the group when the timeout is updated since the leader is the only one that will trigger a rebalance when rejoining while in a stable state.

Re: [DISCUSS] KIP-649: Dynamic Client Configuration

client. 4. Updated the compatibility, deprecation, and migration plan to address the issue of adding support for dynamic configs over time. I am still working on changing the behavior of JoinGroup to avoid a rebalance when updating the timeout. Best, Ryan Dielhenn On Wed, Aug 5, 2020 at 5:23

Re: [DISCUSS] KIP-649: Dynamic Client Configuration

t triggering a rebalance. I agree. Could a flag be added to the JoinGroup API specifying that just the session timeout needs updating? Without this it seems like it would be hard to differentiate between a regular JoinGroupRequest and a JoinGroupRequest that was sent to update the timeout. On 2

Re: [DISCUSS] KIP-649: Dynamic Client Configuration

sent in the initial JoinGroupRequest to the coordinator and stored with the rest of the group member's metadata. To reconfigure the client, the value in the coordinator must also be changed. This does not need to be done for heartbeat.interval.ms. On 2020/08/03 17:47:19, David Arthur wrote: &

Re: [DISCUSS] KIP-649: Dynamic Client Configuration

sh will accept that new configuration, the broker will store it, and the client(s) will receive it when they pull their dynamic configs. Logic will also have to be added to the client to actually use this value. On 2020/08/03 17:47:19, David Arthur wrote: > Hey Ryan, thanks for the KIP. T

Re: [DISCUSS] KIP-649: Dynamic Client Configuration

oved this line. On 2020/07/31 18:27:38, Jose Garcia Sancio wrote: > Thanks for the KIP Ryan. Here are some of my observations. > > 1. > > We will also be adding a new client configuration enable.dynamic.config to > > both the producer and consumer that will be true by default so

[DISCUSS] KIP-649: Dynamic Client Configuration

and consumer configurations that we would like to provide dynamic support for and they are outlined in this KIP. Please reply with any comments or suggestions. Thank you! Ryan Dielhenn

[jira] [Created] (KAFKA-10325) Implement KIP-649: Dynamic Client Configuration

Ryan Dielhenn created KAFKA-10325: - Summary: Implement KIP-649: Dynamic Client Configuration Key: KAFKA-10325 URL: https://issues.apache.org/jira/browse/KAFKA-10325 Project: Kafka Issue Type

[jira] [Created] (KAFKA-10238) kafka-console-producer null value

Ryan created KAFKA-10238: Summary: kafka-console-producer null value Key: KAFKA-10238 URL: https://issues.apache.org/jira/browse/KAFKA-10238 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9782) Kafka Connect InsertField transform - Add the ability to insert event's Key into Value

Ryan Tomczik created KAFKA-9782: --- Summary: Kafka Connect InsertField transform - Add the ability to insert event's Key into Value Key: KAFKA-9782 URL: https://issues.apache.org/jira/browse/KAFKA

[Discussion] KIP-473: Add support for sasl login authentication callback handler to KafkaLog4jAppender

KIP-425 adds SASL support to the KafkaLog4jAppender however it does not include the credential handling improvements added with KIP-86. This is a proposal is to expose `sasl.login.callback.handler.class` for use by the underlying producer. KIP-473 https://cwiki.apache.org/confluence/display/KA

[DISCUSS] KIP-470: Complete SASL integration for Kafka Log4j Appender (KIP-425)

KIP-425 adds SASL support to the Kafka Log4j appender however it does not include the improvements introduced with KIP-86. This KIP aims to do just that by exposing `sasl.login.callback.handler.class` for use by the appender's producer. https://cwiki.apache.org/confluence/display/KAFKA/KIP-470

[Discussion] KIP-473: Add sasl login callback handler support to KafkaLog4jAppender

Apologies in advance if this thread makes it across your desk more than once. I tried the "Start a new discussion" feature in the UI but it did not appear to work. As such I went ahead and started this thread the old fashioned way. KIP-425 adds SASL support to the KafkaLog4jAppender however it do

[jira] [Created] (KAFKA-8419) Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers

Ryan P created KAFKA-8419: - Summary: Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers Key: KAFKA-8419 URL: https://issues.apache.org/jira/browse/KAFKA-8419 Project: Kafka

Permission to submit a new KIP

I would like to submit a new KIP to complete the changes made to the KafkaLog4jAppender. Although this does enable to ability to support SASL it does not extend to the use of SASL Authentication CallbackHandlers rendering it incomplete. It's a small change however my understanding is that it will s

[jira] [Created] (KAFKA-6893) Processors created after acceptor started which can cause in a brief refusal to accept connections

Ryan P created KAFKA-6893: - Summary: Processors created after acceptor started which can cause in a brief refusal to accept connections Key: KAFKA-6893 URL: https://issues.apache.org/jira/browse/KAFKA-6893

[jira] [Created] (KAFKA-6479) Broker file descriptor leak after consumer request timeout

Ryan Leslie created KAFKA-6479: -- Summary: Broker file descriptor leak after consumer request timeout Key: KAFKA-6479 URL: https://issues.apache.org/jira/browse/KAFKA-6479 Project: Kafka Issue

[jira] [Created] (KAFKA-6440) Expose Connect leader via REST

Ryan P created KAFKA-6440: - Summary: Expose Connect leader via REST Key: KAFKA-6440 URL: https://issues.apache.org/jira/browse/KAFKA-6440 Project: Kafka Issue Type: Improvement Components

[jira] [Created] (KAFKA-6295) Add 'Coordinator Id' to consumer metrics

Ryan P created KAFKA-6295: - Summary: Add 'Coordinator Id' to consumer metrics Key: KAFKA-6295 URL: https://issues.apache.org/jira/browse/KAFKA-6295 Project: Kafka Issue Type: I

[jira] [Created] (KAFKA-6287) Inconsistent protocol type for empty consumer groups

Ryan Leslie created KAFKA-6287: -- Summary: Inconsistent protocol type for empty consumer groups Key: KAFKA-6287 URL: https://issues.apache.org/jira/browse/KAFKA-6287 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-6169) Kafka Log should reject negative timestamps

[ https://issues.apache.org/jira/browse/KAFKA-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P resolved KAFKA-6169. --- Resolution: Won't Fix > Kafka Log should reject negative ti

[jira] [Created] (KAFKA-6169) Kafka Log should reject negative timestamps

Ryan P created KAFKA-6169: - Summary: Kafka Log should reject negative timestamps Key: KAFKA-6169 URL: https://issues.apache.org/jira/browse/KAFKA-6169 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6149) LogCleanerManager should include topic partition name when warning of invalid cleaner offset

Ryan P created KAFKA-6149: - Summary: LogCleanerManager should include topic partition name when warning of invalid cleaner offset Key: KAFKA-6149 URL: https://issues.apache.org/jira/browse/KAFKA-6149

[jira] [Resolved] (KAFKA-5825) Streams not processing when exactly once is set

[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Worsley resolved KAFKA-5825. - Resolution: Done > Streams not processing when exactly once is

[jira] [Created] (KAFKA-5825) Streams not processing when exactly once is set

Ryan Worsley created KAFKA-5825: --- Summary: Streams not processing when exactly once is set Key: KAFKA-5825 URL: https://issues.apache.org/jira/browse/KAFKA-5825 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5773) ConnectRecord.equals() doesn't properly handle array keys/values

Ryan Kennedy created KAFKA-5773: --- Summary: ConnectRecord.equals() doesn't properly handle array keys/values Key: KAFKA-5773 URL: https://issues.apache.org/jira/browse/KAFKA-5773 Project:

[jira] [Created] (KAFKA-5764) KafkaShortnamer should allow for case inensitive matches

Ryan P created KAFKA-5764: - Summary: KafkaShortnamer should allow for case inensitive matches Key: KAFKA-5764 URL: https://issues.apache.org/jira/browse/KAFKA-5764 Project: Kafka Issue Type

[jira] [Created] (KAFKA-5691) ZKUtils.CreateRecursive should handle NOAUTH

Ryan P created KAFKA-5691: - Summary: ZKUtils.CreateRecursive should handle NOAUTH Key: KAFKA-5691 URL: https://issues.apache.org/jira/browse/KAFKA-5691 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5526) ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets

Ryan P created KAFKA-5526: - Summary: ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets Key: KAFKA-5526 URL: https://issues.apache.org/jira/browse/KAFKA-5526

[jira] [Created] (KAFKA-5091) ReassignPartitionsCommand should protect against empty replica list assignment

Ryan P created KAFKA-5091: - Summary: ReassignPartitionsCommand should protect against empty replica list assignment Key: KAFKA-5091 URL: https://issues.apache.org/jira/browse/KAFKA-5091 Project: Kafka

[jira] [Created] (KAFKA-5066) KafkaMetricsConfig properties and description notably missing from documentation

Ryan P created KAFKA-5066: - Summary: KafkaMetricsConfig properties and description notably missing from documentation Key: KAFKA-5066 URL: https://issues.apache.org/jira/browse/KAFKA-5066 Project: Kafka

[jira] [Created] (KAFKA-4985) kafka-acls should resolve dns names and accept ip ranges

Ryan P created KAFKA-4985: - Summary: kafka-acls should resolve dns names and accept ip ranges Key: KAFKA-4985 URL: https://issues.apache.org/jira/browse/KAFKA-4985 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-4041) kafka unable to reconnect to zookeeper behind an ELB

[ https://issues.apache.org/jira/browse/KAFKA-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15828420#comment-15828420 ] Ryan P commented on KAFKA-4041: --- This is actually the result of a ZK bug which is b

[jira] [Commented] (KAFKA-4606) make getOffsetsTopicPartitionCount mutable

[ https://issues.apache.org/jira/browse/KAFKA-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15806253#comment-15806253 ] Ryan P commented on KAFKA-4606: --- Artificial was the wrong word, but I still thin

[jira] [Created] (KAFKA-4606) make getOffsetsTopicPartitionCount mutable

Ryan P created KAFKA-4606: - Summary: make getOffsetsTopicPartitionCount mutable Key: KAFKA-4606 URL: https://issues.apache.org/jira/browse/KAFKA-4606 Project: Kafka Issue Type: Improvement

[jira] [Issue Comment Deleted] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging

[ https://issues.apache.org/jira/browse/KAFKA-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P updated KAFKA-4364: -- Comment: was deleted (was: https://github.com/apache/kafka/pull/2115) > Sink tasks expose secrets in DE

[jira] [Commented] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging

[ https://issues.apache.org/jira/browse/KAFKA-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15649205#comment-15649205 ] Ryan P commented on KAFKA-4364: --- https://github.com/apache/kafka/pull/2115 > Sin

[jira] [Updated] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging

[ https://issues.apache.org/jira/browse/KAFKA-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P updated KAFKA-4364: -- Assignee: Ryan P (was: Ewen Cheslack-Postava) > Sink tasks expose secrets in DEBUG logg

[jira] [Created] (KAFKA-4369) ZkClient is not closed upon streams shutdown

Ryan P created KAFKA-4369: - Summary: ZkClient is not closed upon streams shutdown Key: KAFKA-4369 URL: https://issues.apache.org/jira/browse/KAFKA-4369 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-4364) Sink tasks expose secrets in DEBUG logging

Ryan P created KAFKA-4364: - Summary: Sink tasks expose secrets in DEBUG logging Key: KAFKA-4364 URL: https://issues.apache.org/jira/browse/KAFKA-4364 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-4301) Include some SSL/TLS logging to avoid need need for javax debug util every time an issue arises

Ryan P created KAFKA-4301: - Summary: Include some SSL/TLS logging to avoid need need for javax debug util every time an issue arises Key: KAFKA-4301 URL: https://issues.apache.org/jira/browse/KAFKA-4301

[jira] [Created] (KAFKA-4294) Allow password file in server.properties to separate 'secrets' from standard configs

Ryan P created KAFKA-4294: - Summary: Allow password file in server.properties to separate 'secrets' from standard configs Key: KAFKA-4294 URL: https://issues.apache.org/jira/browse/KAFKA-4294 Proj

[jira] [Updated] (KAFKA-4247) kafka-run-class has potential to add a leading colon to classpath

[ https://issues.apache.org/jira/browse/KAFKA-4247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P updated KAFKA-4247: -- Description: https://github.com/confluentinc/kafka/blob/trunk/bin/kafka-run-class.sh#L128-L133 In the event

[jira] [Updated] (KAFKA-4247) kafka-run-class has potential to add a leading colon to classpath

[ https://issues.apache.org/jira/browse/KAFKA-4247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P updated KAFKA-4247: -- Description: https://github.com/confluentinc/kafka/blob/trunk/bin/kafka-run-class.sh#L128-L133 In the event

[jira] [Created] (KAFKA-4247) kafka-run-class has potential to add a leading colon to classpath

Ryan P created KAFKA-4247: - Summary: kafka-run-class has potential to add a leading colon to classpath Key: KAFKA-4247 URL: https://issues.apache.org/jira/browse/KAFKA-4247 Project: Kafka Issue

[jira] [Commented] (KAFKA-4233) StateDirectory fails to create directory if any parent directory does not exist

[ https://issues.apache.org/jira/browse/KAFKA-4233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15536773#comment-15536773 ] Ryan Worsley commented on KAFKA-4233: - Thanks :) > StateDirectory fails to

[jira] [Created] (KAFKA-4233) StateDirectory fails to create directory if any parent directory does not exist

Ryan Worsley created KAFKA-4233: --- Summary: StateDirectory fails to create directory if any parent directory does not exist Key: KAFKA-4233 URL: https://issues.apache.org/jira/browse/KAFKA-4233 Project

[jira] [Updated] (KAFKA-3719) Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow

[ https://issues.apache.org/jira/browse/KAFKA-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P updated KAFKA-3719: -- Assignee: Ryan P > Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too >

[jira] [Reopened] (KAFKA-3719) Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow

[ https://issues.apache.org/jira/browse/KAFKA-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P reopened KAFKA-3719: --- I would like to re-open this topic for discussion. While [~gwenshap] is correct, underscores are not valid

[jira] [Commented] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https

[ https://issues.apache.org/jira/browse/KAFKA-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408544#comment-15408544 ] Ryan P commented on KAFKA-3665: --- [~junrao] yes I do think that SNI is still rele

[jira] [Commented] (KAFKA-3665) Default ssl.endpoint.identification.algorithm should be https

[ https://issues.apache.org/jira/browse/KAFKA-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15405659#comment-15405659 ] Ryan P commented on KAFKA-3665: --- RFC-6066 describes an extension to the TLS protoco

[jira] [Created] (KAFKA-3986) completedReceives can contain closed channels

Ryan P created KAFKA-3986: - Summary: completedReceives can contain closed channels Key: KAFKA-3986 URL: https://issues.apache.org/jira/browse/KAFKA-3986 Project: Kafka Issue Type: Bug

  1   2   >