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

See

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

[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

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

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

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

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

[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

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

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

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

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

See

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

See

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

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

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

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

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

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]

[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

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

[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

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

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

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

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

[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

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

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]

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

[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

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 >

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

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, >> >>

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

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

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

[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

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, > >

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

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

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 >

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

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

[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

[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

[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

[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

[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

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.

[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

[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

[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

[GitHub] kafka pull request #3943: MINOR: always set Serde.Long on count operations

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3943 MINOR: always set Serde.Long on count operations You can merge this pull request into a Git repository by running: $ git pull https://github.com/dguy/kafka count-materialized Alternatively you