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

Thanks for the KIP. LGTM. On Fri, May 24, 2019 at 11:34 PM r...@confluent.io wrote: > 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`

[jira] [Resolved] (KAFKA-8422) Client should not use old versions of OffsetsForLeaderEpoch

[ https://issues.apache.org/jira/browse/KAFKA-8422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8422. Resolution: Fixed > Client should not use old versions of OffsetsForLeaderEpoch >

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

See Changes: [cmccabe] KAFKA-8341. Retry Consumer group operation for NOT_COORDINATOR error -- [...truncated 2.46 MB...] org.apache.kafka.connect.data.ConnectSchemaTest

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

See

[jira] [Created] (KAFKA-8430) Unit test to make sure `group.id` and `group.instance.id` won't affect each other

Boyang Chen created KAFKA-8430: -- Summary: Unit test to make sure `group.id` and `group.instance.id` won't affect each other Key: KAFKA-8430 URL: https://issues.apache.org/jira/browse/KAFKA-8430 Project:

[jira] [Resolved] (KAFKA-8341) AdminClient should retry coordinator lookup after NOT_COORDINATOR error

[ https://issues.apache.org/jira/browse/KAFKA-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Singh resolved KAFKA-8341. Resolution: Fixed fixed in commit 46a02f3231cd6d340c622636159b9f59b4b3cb6e > AdminClient should

Build failed in Jenkins: kafka-2.3-jdk8 #14

See Changes: [wangguoz] MINOR: Updated configuration docs with RocksDBConfigSetter#close (#6784) [matthias] MINOR: add Kafka Streams upgrade notes for 2.3 release (#6758)

Re: [VOTE] KIP-430 - Return Authorized Operations in Describe Responses

Hi all, We discovered an issue with how compatibility was handled in this KIP. There should always be a way for the client to know that the information that was requested was omitted by the broker because it was too old. I changed the "Compatibility, Deprecation, and Migration Plan" to add

[jira] [Created] (KAFKA-8429) Consumer should handle offset change while OffsetForLeaderEpoch is inflight

Jason Gustafson created KAFKA-8429: -- Summary: Consumer should handle offset change while OffsetForLeaderEpoch is inflight Key: KAFKA-8429 URL: https://issues.apache.org/jira/browse/KAFKA-8429

Re: [DISCUSSION] KIP-418: A method-chaining way to branch KStream

Matthias: I think that's pretty reasonable from my point of view. Good suggestion. On Thu, May 23, 2019 at 9:50 PM Matthias J. Sax wrote: > Interesting discussion. > > I am wondering, if we cannot unify the advantage of both approaches: > > > > KStream#split() -> KBranchedStream > > // branch

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

See Changes: [wangguoz] MINOR: Updated configuration docs with RocksDBConfigSetter#close (#6784) -- [...truncated 2.61 MB...]

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

See Changes: [wangguoz] MINOR: Updated configuration docs with RocksDBConfigSetter#close (#6784) -- [...truncated 2.48 MB...]

[jira] [Created] (KAFKA-8428) Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only

Guozhang Wang created KAFKA-8428: Summary: Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only Key: KAFKA-8428 URL: https://issues.apache.org/jira/browse/KAFKA-8428

Build failed in Jenkins: kafka-2.3-jdk8 #13

See Changes: [matthias] MINOR: fix Streams version-probing system test (#6764) -- [...truncated 2.91 MB...] kafka.server.ListOffsetsRequestTest > testCurrentEpochValidation

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

See Changes: [github] MINOR: fix Streams version-probing system test (#6764) -- [...truncated 2.48 MB...] org.apache.kafka.connect.source.SourceRecordTest >

Re: [DISCUSS] KIP-466: Add support for List serialization and deserialization

Hey, - did we consider to make the return type (ie, ArrayList, vs LinkesList) configurable or encode it the serialized bytes? Not sure about this one. Could you elaborate? - atm the size of each element is encoded individually; did we consider an optimization for fixed size elements (like Long)

[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

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

See Changes: [github] MINOR: fix Streams version-probing system test (#6764) -- [...truncated 2.48 MB...] org.apache.kafka.connect.util.KafkaBasedLogTest >

Re: Contributor Apply

Added you to the list on contributors. You can not self-assign tickets. Please read https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes to get started. -Matthias On 5/24/19 11:47 AM, gongfuboych...@gmail.com wrote: > hi, > > my name is LiMing Zhou from China, who

[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.

[jira] [Created] (KAFKA-8427) error while cleanup under windows for EmbeddedKafkaCluster

Sukumaar Mane created KAFKA-8427: Summary: error while cleanup under windows for EmbeddedKafkaCluster Key: KAFKA-8427 URL: https://issues.apache.org/jira/browse/KAFKA-8427 Project: Kafka

[jira] [Created] (KAFKA-8426) KIP 421 Bug: ConfigProvider configs param inconsistent with KIP-297

TEJAL ADSUL created KAFKA-8426: -- Summary: KIP 421 Bug: ConfigProvider configs param inconsistent with KIP-297 Key: KAFKA-8426 URL: https://issues.apache.org/jira/browse/KAFKA-8426 Project: Kafka

[jira] [Created] (KAFKA-8425) KIP 421 Bug: Modifying Immutable Originals Map results in Java exception

TEJAL ADSUL created KAFKA-8425: -- Summary: KIP 421 Bug: Modifying Immutable Originals Map results in Java exception Key: KAFKA-8425 URL: https://issues.apache.org/jira/browse/KAFKA-8425 Project: Kafka

[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

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

See Changes: [jason] MINOR: Fix a few compiler warnings (#6767) -- [...truncated 2.49 MB...] org.apache.kafka.connect.json.JsonConverterTest >

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

See Changes: [github] MINOR: add Kafka Streams upgrade notes for 2.3 release (#6758) [jason] MINOR: Fix a few compiler warnings (#6767) -- [...truncated 2.53 MB...]

Contributor Apply

hi, my name is LiMing Zhou from China, who is java developer. want to be contributor to kafka project JIRA ID: GongFuBoy thanks LiMing Zhou

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

See Changes: [github] MINOR: add Kafka Streams upgrade notes for 2.3 release (#6758) -- [...truncated 2.48 MB...]

Build failed in Jenkins: kafka-2.3-jdk8 #12

See Changes: [ismael] MINOR: Update jackson to 2.9.9 (#6798) -- [...truncated 2.79 MB...] kafka.security.auth.SimpleAclAuthorizerTest >