[GitHub] kafka pull request #3944: KAFKA-5960 [WIP]; Fix regression in produce versio...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3944 KAFKA-5960 [WIP]; Fix regression in produce version selection on old brokers You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka K

[jira] [Created] (KAFKA-5961) NullPointerException when restore messages with null key.

Andres Gomez Ferrer created KAFKA-5961: -- Summary: NullPointerException when restore messages with null key. Key: KAFKA-5961 URL: https://issues.apache.org/jira/browse/KAFKA-5961 Project: Kafka

[jira] [Created] (KAFKA-5962) java.io.IOException: Map failed

Mehmet Soner created KAFKA-5962: --- Summary: java.io.IOException: Map failed Key: KAFKA-5962 URL: https://issues.apache.org/jira/browse/KAFKA-5962 Project: Kafka Issue Type: Bug Compone

Re: [VOTE] KIP-131 - Add access to OffsetStorageReader from SourceConnector

Hi team, Are there any more votes ? Thanks Le 12 sept. 2017 20:18, "Gwen Shapira" a écrit : > Thanks for clarifying. > > +1 again :) > > > > On Sat, Sep 9, 2017 at 6:57 AM Randall Hauch wrote: > > > Gwen, > > > > I've had more time to look into the code. First, the OffsetStorageReader > > Jav

[GitHub] kafka pull request #3945: MINOR: Move ChannelState.exception() to its own cl...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3945 MINOR: Move ChannelState.exception() to its own class Given that Java doesn't support pattern matching, the benefit is not as clear. Also implemented ChannelState.toString and removed some

[GitHub] kafka pull request #3946: KAFKA-5802 : ScramServerCallbackHandler#handle sho...

GitHub user umesh9794 opened a pull request: https://github.com/apache/kafka/pull/3946 KAFKA-5802 : ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get() Pretty trivial and tested with `gradle clean client:test` You can merge th

[jira] [Resolved] (KAFKA-5910) Kafka 0.11.0.1 Kafka consumer/producers retries in infinite loop when wrong SASL creds are passed

[ https://issues.apache.org/jira/browse/KAFKA-5910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5910. -- Resolution: Duplicate Resolving as duplicate of KAFKA-4764 > Kafka 0.11.0.1 Kafka consumer/producers re

[jira] [Resolved] (KAFKA-5015) SASL/SCRAM authentication failures are hidden

[ https://issues.apache.org/jira/browse/KAFKA-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5015. -- Resolution: Duplicate Resolving as duplicate of KAFKA-4764 > SASL/SCRAM authentication failures are hid

[jira] [Created] (KAFKA-5963) Null Pointer Exception on server

Mudit Garg created KAFKA-5963: - Summary: Null Pointer Exception on server Key: KAFKA-5963 URL: https://issues.apache.org/jira/browse/KAFKA-5963 Project: Kafka Issue Type: Bug Reporter

[jira] [Resolved] (KAFKA-5956) StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized

[ https://issues.apache.org/jira/browse/KAFKA-5956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5956. --- Resolution: Fixed Issue resolved by pull request 3936 [https://github.com/apache/kafka/pull/3936] > S

[GitHub] kafka pull request #3936: KAFKA-5956: use serdes from materialized in table ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3936 ---

[jira] [Resolved] (KAFKA-5954) Failure in Connect system test: ConnectRestApiTest

[ https://issues.apache.org/jira/browse/KAFKA-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-5954. -- Resolution: Fixed > Failure in Connect system test: ConnectRestApiTest > ---

Build failed in Jenkins: kafka-trunk-jdk9 #50

See Changes: [damian.guy] KAFKA-5956; use serdes from materialized in table and globalTable -- [...truncated 1.39 MB...] kafka.server.epoch.LeaderEpochFileCacheTest > shoul

Kafka + ACL Topic based security ,Spring Boot

Hi, I am currently looking to implement Topic based security for Spring Boot latest version for Kafka. I couldn’t find much examples|Tutorials for the same. I have a working producer and consumer ( attached) . Could someone help me to add a security to a particular topic ? Requirement: We hav

Re: Kafka + ACL Topic based security ,Spring Boot

Attachment didn't come thru. Have you read ? https://cwiki.apache.org/confluence/display/KAFKA/Security especially the https://cwiki.apache.org/confluence/display/KAFKA/Security#Security-ImplementingthePermissionManager section ? On Fri, Sep 22, 2017 at 2:45 AM, Pooppillikudiyil, Joby < joby.poo

[jira] [Created] (KAFKA-5964) Add more unit tests for SslTransportLayer

Rajini Sivaram created KAFKA-5964: - Summary: Add more unit tests for SslTransportLayer Key: KAFKA-5964 URL: https://issues.apache.org/jira/browse/KAFKA-5964 Project: Kafka Issue Type: Test

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

Dear community, I updated the related KIP [1]. Please feel free to comment. Cheers, Jeyhun [1] https://cwiki.apache.org/confluence/display/KAFKA/KIP-159%3A+Introducing+Rich+functions+to+Streams On Fri, Sep 22, 2017 at 12:20 AM Jeyhun Karimov wrote: > Hi Damian, > > Thanks for the update. I

[GitHub] kafka-site pull request #84: Adding LINE logo to Streams page

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka-site/pull/84 Adding LINE logo to Streams page @guozhangwang @dguy Please review. You can merge this pull request into a Git repository by running: $ git pull https://github.com/manjuapu/kafka-site asf-

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

bq. provides a hybrd solution Typo in hybrid. bq. accessing read-only keys within XXXValues operators It would be nice if you can name some Value operator as examples. KTable aggregate(final Initializer initializer, final Aggregator adder, The adder doesn't need t

[jira] [Resolved] (KAFKA-5840) TransactionsTest#testBasicTransactions sometimes hangs

[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5840. --- Resolution: Cannot Reproduce > TransactionsTest#testBasicTransactions sometimes hangs > --

Re: Please grant me Wiki Access

Hi, Chetna, You should have the wiki permission now. Thanks, Jun On Mon, Sep 18, 2017 at 4:39 PM, chetna chaudhari wrote: > Any update please? > > On 15 September 2017 at 09:48, chetna chaudhari > > wrote: > > > Hi, > >Please grant me wiki page access. I need the access to create a KIP >

Re: Please add me to contributor list in JIRA and Confluence

Hi, Jakub, Thanks for your interest. You should have the wiki permission now. Jun On Thu, Sep 21, 2017 at 2:31 PM, Jakub Scholz wrote: > Hi, > > It looks like I now have the JIRA rights. But I'm still missing the Wiki > rights to start with my first KIP. Can someone have a look at it please? >

Re: Please add me to contributor list in JIRA and Confluence

Hi Jun, Great, thanks a lot. Regards Jakub On Fri, Sep 22, 2017 at 7:55 PM, Jun Rao wrote: > Hi, Jakub, > > Thanks for your interest. You should have the wiki permission now. > > Jun > > On Thu, Sep 21, 2017 at 2:31 PM, Jakub Scholz wrote: > >> Hi, >> >> It looks like I now have the JIRA righ

[GitHub] kafka pull request #3879: KAFKA-5915: Support unmapping of mapped/direct buf...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3879 ---

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

See Changes: [damian.guy] KAFKA-5956; use serdes from materialized in table and globalTable -- [...truncated 122.15 KB...] kafka.api.LegacyAdminClientTest > testOffsetsFo

[GitHub] kafka pull request #3947: KAFKA-5959: Fix NPE in Sender.canRetry when idempo...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3947 KAFKA-5959: Fix NPE in Sender.canRetry when idempotence is not enabled You can merge this pull request into a Git repository by running: $ git pull https://github.com/apurvam/kafka KAFKA-5959-

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

Hi Ted, Thanks for your comments. I added a couple of comments in KIP to clarify some points. bq. provides a hybrd solution > Typo in hybrid. - My bad. Thanks for the correction. It would be nice if you can name some Value operator as examples. > - I added the corresponding interface names

Spurious INFO message in SessionExpireListener (of KafkaHealthcheck)?

Hi, Just noticed that SessionExpireListener#handleNewSession (of KafkaHealthcheck) prints out the INFO message to the logs [1] and does nothing afterwards. Subscribing to %s path to watch for new topics Why? Is the INFO correct? Where does the subscription happen? [1] https://github.com/apache/

Build failed in Jenkins: kafka-trunk-jdk9 #51

See Changes: [ismael] KAFKA-5915; Support unmapping of mapped/direct buffers in Java 9 -- [...truncated 1.91 MB...] org.apache.kafka.connect.runtime.isolation.PluginUtilsTe

[jira] [Created] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool

Bill Bejeck created KAFKA-5965: -- Summary: Remove Deprecated AdminClient from Streams Resetter Tool Key: KAFKA-5965 URL: https://issues.apache.org/jira/browse/KAFKA-5965 Project: Kafka Issue Type

Re: [DISCUSS] KIP-190: Handle client-ids consistently between clients and brokers

Hi all, In working on the patch for KIP-196: Add metrics to Kafka Connect framework, we realized that we have worker and connector/task IDs that are to be included in metrics and those don't currently have constraints on naming. I'd prefer to avoid adding naming restrictions or mangling names unne

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

See Changes: [ismael] KAFKA-5915; Support unmapping of mapped/direct buffers in Java 9 -- [...truncated 1.88 MB...] org.apache.kafka.connect.runtime.rest.resources.Connect

[GitHub] kafka pull request #3918: KAFKA-5920: Handle SSL handshake failures as authe...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3918 ---

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

recordContext = new RecordContext() { // recordContext initialization is added in this KIP This code snippet seems to be standard - would it make sense to pull it into a (sample) RecordContext implementation ? Cheers On Fri, Sep 22, 2017 at 12:14 PM, Jeyhun Karimov wrote: > Hi

[jira] [Resolved] (KAFKA-5959) NPE in NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-5959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5959. Resolution: Fixed Issue resolved by pull request 3947 [https://github.com/apache/kafka/pull/

[GitHub] kafka pull request #3947: KAFKA-5959: Fix NPE in Sender.canRetry when idempo...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3947 ---

[GitHub] kafka pull request #3948: KAFKA-4593: Don't throw IllegalStateException and ...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3948 KAFKA-4593: Don't throw IllegalStateException and die on task migration You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka kafka-4593-il

Re: Spurious INFO message in SessionExpireListener (of KafkaHealthcheck)?

See KafkaHealthcheck#register() I think it means registration for the zookeeper path. On Fri, Sep 22, 2017 at 12:38 PM, Jacek Laskowski wrote: > Hi, > > Just noticed that SessionExpireListener#handleNewSession > (of KafkaHealthcheck) prints out the INFO message to the logs [1] and does > nothin

[GitHub] kafka pull request #3864: KAFKA-5899 Added Connect metrics for connectors

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3864 ---

[jira] [Created] (KAFKA-5966) Support ByteBuffer serialization in Kafka Streams

Xavier Léauté created KAFKA-5966: Summary: Support ByteBuffer serialization in Kafka Streams Key: KAFKA-5966 URL: https://issues.apache.org/jira/browse/KAFKA-5966 Project: Kafka Issue Type: I

Re: Spurious INFO message in SessionExpireListener (of KafkaHealthcheck)?

Hi Ted, That's exactly the method I've been looking at to understand the INFO message better and don't see how they relate. I don't see how it could help. Care to shed more light on it? Thanks. Pozdrawiam, Jacek Laskowski https://about.me/JacekLaskowski Spark Structured Streaming https://bit

[GitHub] kafka pull request #3949: MINOR: Update Streams quickstart to create output ...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3949 MINOR: Update Streams quickstart to create output topic with compacti… …on enabled You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka

[jira] [Resolved] (KAFKA-5920) Handle SSL authentication failures as non-retriable exceptions in clients

[ https://issues.apache.org/jira/browse/KAFKA-5920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5920. Resolution: Fixed > Handle SSL authentication failures as non-retriable exceptions in clients >

[GitHub] kafka pull request #3938: HOTFIX: ConsumerGroupCommand - Offset and partitio...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3938 ---

Jenkins build is back to normal : kafka-trunk-jdk9 #52

See

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

See

[GitHub] kafka-site issue #84: Adding LINE logo to Streams page

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/84 LGTM Merged to trunk. ---

[GitHub] kafka-site pull request #84: Adding LINE logo to Streams page

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/84 ---

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

See Changes: [jason] KAFKA-5959; Fix NPE in Sender.canRetry when idempotence is not enabled [me] KAFKA-5899: Added Connect metrics for connectors (KIP-196) [ismael] MINOR: Fix ClassCastException in ConsumerGrou

[GitHub] kafka-site pull request #85: Adding New York logo to powered-by and Streams ...

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka-site/pull/85 Adding New York logo to powered-by and Streams page You can merge this pull request into a Git repository by running: $ git pull https://github.com/manjuapu/kafka-site asf-site Alternativ

[GitHub] kafka-site issue #85: Adding New York logo to powered-by and Streams page

Github user manjuapu commented on the issue: https://github.com/apache/kafka-site/pull/85 @guozhangwang Please review. ---

Build failed in Jenkins: kafka-0.11.0-jdk7 #311

See Changes: [ismael] MINOR: Fix ClassCastException in ConsumerGroupCommand -- [...truncated 859.49 KB...] kafka.api.ProducerFailureHandlingTest > testSendAfterClosed PAS

[GitHub] kafka pull request #3950: MINOR - Adding New York Times logo to streams page

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka/pull/3950 MINOR - Adding New York Times logo to streams page You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka customer-logo-stream Alt

[GitHub] kafka-site issue #85: Adding New York logo to powered-by and Streams page

Github user manjuapu commented on the issue: https://github.com/apache/kafka-site/pull/85 @guozhangwang Added Apache word ---

[GitHub] kafka-site pull request #85: Adding New York logo to powered-by and Streams ...

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/85#discussion_r140623385 --- Diff: 0110/streams/index.html --- @@ -201,39 +201,41 @@ The easiest way to write mission-critical real-tim

[GitHub] kafka-site pull request #85: Adding New York logo to powered-by and Streams ...

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/85#discussion_r140623361 --- Diff: 0110/streams/index.html --- @@ -201,39 +201,41 @@ The easiest way to write mission-critical real-tim

[GitHub] kafka pull request #3950: MINOR - Adding New York Times logo to streams page

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3950 ---

[GitHub] kafka-site pull request #85: Adding New York logo to powered-by and Streams ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/85 ---

[GitHub] kafka-site issue #85: Adding New York logo to powered-by and Streams page

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/85 Merged to trunk with some minor tweaks. ---

[GitHub] kafka pull request #3927: KAFKA-5862: Remove ZK dependency from Streams rese...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3927 ---

[jira] [Resolved] (KAFKA-5862) Remove ZK dependency from Streams reset tool

[ https://issues.apache.org/jira/browse/KAFKA-5862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5862. -- Resolution: Fixed Issue resolved by pull request 3927 [https://github.com/apache/kafka/pull/3927

1.0.0 Code Freeze Update

Hello Folks, This is another heads up on 1.0.0 progress post the feature freeze deadline: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=71764913 We have ended up with 28 total KIPs in this release, with 5 other KIPs being postponed to subsequent releases; out of the 28 KIPs t

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

See