[GitHub] kafka pull request #3940: Adding LINE corp logo to streams page

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

[GitHub] kafka pull request #3941: KAFKA-3999: Record raw size of fetch responses as ...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/3941 KAFKA-3999: Record raw size of fetch responses as part of consumer metrics Currently, only the decompressed size of fetch responses is recorded. This PR adds a sensor to keep track of the

Build failed in Jenkins: kafka-trunk-jdk7 #2802

See Changes: [jason] MINOR: Follow-up improvements on top of KAFKA-5793 -- [...truncated 354.64 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

[GitHub] kafka pull request #3906: KAFKA-5735: KIP-190: Handle client-ids consistentl...

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

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

GitHub user eu657 opened a pull request: https://github.com/apache/kafka/pull/3938 HOTFIX: ConsumerGroupCommand - Offset and partition numbers are not converted to long and int correctly Running the command line with --from-file option causes the following exception:

[GitHub] kafka-site issue #83: Line logo to Powered-by page + minor edits to styles +...

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

[GitHub] kafka-site pull request #83: Line logo to Powered-by page + minor edits to s...

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

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

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? Thanks & Regards Jakub On Sun, Sep 17, 2017 at 11:33 PM, Jakub Scholz wrote: > Hi, > > I would like to try to start

[GitHub] kafka pull request #1698: KAFKA-3999: Record raw size of fetch responses as ...

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

Jenkins build is back to normal : kafka-trunk-jdk7 #2801

See

[GitHub] kafka-site pull request #83: Line logo to Powered-by page + minor edits to s...

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka-site/pull/83 Line logo to Powered-by page + minor edits to styles +google webmaster file @dguy @guozhangwang Can you please review this PR? You can merge this pull request into a Git repository by running:

[GitHub] kafka pull request #3939: KAFKA-5949: User Callback Exceptions need to be ha...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3939 KAFKA-5949: User Callback Exceptions need to be handled properly - catch user exception in user callback (TimestampExtractor, DeserializationHandler, StateRestoreListener) and wrap with

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

Xavier Léauté created KAFKA-5959: Summary: NPE in NetworkClient Key: KAFKA-5959 URL: https://issues.apache.org/jira/browse/KAFKA-5959 Project: Kafka Issue Type: Bug Components:

[jira] [Resolved] (KAFKA-5821) Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls

[ https://issues.apache.org/jira/browse/KAFKA-5821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5821. --- Resolution: Cannot Reproduce > Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls >

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

See Changes: [me] KAFKA-5330: Use per-task converters in Connect -- [...truncated 1.91 MB...] org.apache.kafka.connect.runtime.isolation.PluginUtilsTest >

[GitHub] kafka-site pull request #79: Adding Customer section to Streams page

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

[GitHub] kafka pull request #3935: MINOR: improvement on top of KAFKA-5793: Tighten u...

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

[GitHub] kafka pull request #3878: KAFKA-5913: Add hasOffset() and hasTimestamp() met...

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

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

Hi Damian, Thanks for the update. I working on it and will provide an update soon. Cheers, Jeyhun On Thu, Sep 21, 2017 at 4:50 PM Damian Guy wrote: > Hi Jeyhun, > > All KIP-182 API PRs have now been merged. So you can consider it as stable. > Thanks, > Damian > > On Thu,

[GitHub] kafka pull request #3940: Adding LINE corp logo to streams page

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka/pull/3940 Adding LINE corp 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 Alternatively

[GitHub] kafka pull request #3913: KAFKA-5937: Improve ProcessorStateManager exceptio...

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

Jenkins build is back to normal : kafka-trunk-jdk7 #2803

See

[jira] [Created] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch

Jason Gustafson created KAFKA-5957: -- Summary: Producer IllegalStateException due to second deallocate after aborting a batch Key: KAFKA-5957 URL: https://issues.apache.org/jira/browse/KAFKA-5957

[GitHub] kafka pull request #3942: KAFKA-5957: Prevent second deallocate if response ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3942 KAFKA-5957: Prevent second deallocate if response for aborted batch returns You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[jira] [Created] (KAFKA-5958) User StoreListener not available for global stores

Matthias J. Sax created KAFKA-5958: -- Summary: User StoreListener not available for global stores Key: KAFKA-5958 URL: https://issues.apache.org/jira/browse/KAFKA-5958 Project: Kafka Issue

Re: 1.0.0 KIPs Update

The code freeze is 3rd of October, but the last week is only for bug fixes typically. Ismael On Thu, Sep 21, 2017 at 11:16 AM, Guozhang Wang wrote: > Note that the code freeze date is Oct.3, so people will have about two > weeks for that. > > > Guozhang > > On Thu, Sep 21,

[GitHub] kafka pull request #3928: KAFKA-5947: Handle authentication failure in admin...

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

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

+1 On Thu, Sep 14, 2017 at 10:37 PM, Ted Yu wrote: > +1 > > One interface is cleaner. > > On Thu, Sep 14, 2017 at 7:26 AM, Bill Bejeck wrote: > > > +1 for me on collapsing the Rich and ValueWithKey interfaces > into 1 > > interface. > > > >

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

+1 On Thu, 21 Sep 2017 at 13:46 Guozhang Wang wrote: > +1 for me as well for collapsing. > > Jeyhun, could you update the wiki accordingly to show what's the final > updates post KIP-182 that needs to be done in KIP-159 including KIP-149? > The child page I made is just a

[GitHub] kafka pull request #3930: KAFKA-5856; AdminClient.createPartitions() follow-...

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

[GitHub] kafka pull request #3933: all topics should be in paused states

GitHub user lisa2lisa opened a pull request: https://github.com/apache/kafka/pull/3933 all topics should be in paused states You can merge this pull request into a Git repository by running: $ git pull https://github.com/lisa2lisa/kafka log-fix Alternatively you can review

[GitHub] kafka pull request #3934: KAFKA-5954 Correct Connect REST API system test

GitHub user rhauch opened a pull request: https://github.com/apache/kafka/pull/3934 KAFKA-5954 Correct Connect REST API system test You can merge this pull request into a Git repository by running: $ git pull https://github.com/rhauch/kafka kafka-5954 Alternatively you can

Re: [VOTE] KIP-182 - Reduce Streams DSL overloads and allow easier use of custom storage engines

Hi All, There has been one further update to the KIP. WindowedKStream has been renamed to TimeWindowedKStream. Thanks, Damian On Tue, 19 Sep 2017 at 12:21 Damian Guy wrote: > All, a small addition to the KIP. During implementation we realized it > would be good to add

[GitHub] kafka-site pull request #82: Adding minor style changes

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

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

Hi all, Thanks a lot for your comments. For the single interface (RichXXX and XXXWithKey) solution, I have already submitted a PR but probably it is outdated (when the KIP first proposed), I need to revisit that one. @Guozhang, from our (offline) discussion, I understood that we may not make it

[GitHub] kafka pull request #3934: KAFKA-5954: Correct Connect REST API system test

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

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

Hi Jeyhun, All KIP-182 API PRs have now been merged. So you can consider it as stable. Thanks, Damian On Thu, 21 Sep 2017 at 15:23 Jeyhun Karimov wrote: > Hi all, > > Thanks a lot for your comments. For the single interface (RichXXX and > XXXWithKey) solution, I have

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

See Changes: [ismael] KAFKA-5856; AdminClient.createPartitions() follow-up (KIP-195) -- [...truncated 1.39 MB...] kafka.server.epoch.LeaderEpochFileCacheTest >

Build failed in Jenkins: kafka-trunk-jdk7 #2799

See Changes: [ismael] KAFKA-5856; AdminClient.createPartitions() follow-up (KIP-195) -- [...truncated 1.79 MB...]

[jira] [Created] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit

Ismael Juma created KAFKA-5955: -- Summary: Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit Key: KAFKA-5955 URL:

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

See Changes: [wangguoz] KAFKA-5922: Add SessionWindowedKStream [wangguoz] MINOR: add upgrade note for KIP-173 topic configs [ismael] KAFKA-5947; Handle authentication failure in admin client, txn producer

[jira] [Resolved] (KAFKA-5947) Handle authentication failures from transactional producer and KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5947. Resolution: Fixed > Handle authentication failures from transactional producer and >

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

Randall Hauch created KAFKA-5954: Summary: Failure in Connect system test: ConnectRestApiTest Key: KAFKA-5954 URL: https://issues.apache.org/jira/browse/KAFKA-5954 Project: Kafka Issue Type:

Jenkins build is back to normal : kafka-trunk-jdk7 #2797

See

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

+1 for me as well for collapsing. Jeyhun, could you update the wiki accordingly to show what's the final updates post KIP-182 that needs to be done in KIP-159 including KIP-149? The child page I made is just a suggestion, but you would still need to update your proposal for people to comment and

[GitHub] kafka pull request #3932: KAFKA-5867: Log Kafka Connect worker info during s...

GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3932 KAFKA-5867: Log Kafka Connect worker info during startup You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka

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

See Changes: [ismael] MINOR: Fix testUniqueErrorCodes unit test failure -- [...truncated 3.47 MB...] org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest >

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

See Changes: [jason] KAFKA-5793; Tighten up the semantics of the OutOfOrderSequenceException [ismael] KAFKA-5856; Add AdminClient.createPartitions() (KIP-195) --

[jira] [Created] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

James Cheng created KAFKA-5951: -- Summary: Autogenerate Producer RecordAccumulator metrics Key: KAFKA-5951 URL: https://issues.apache.org/jira/browse/KAFKA-5951 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5952) Refactor Consumer Fetcher metrics

James Cheng created KAFKA-5952: -- Summary: Refactor Consumer Fetcher metrics Key: KAFKA-5952 URL: https://issues.apache.org/jira/browse/KAFKA-5952 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request #3931: Minor: Fix testUniqueErrorCodes unit test failure

GitHub user wushujames opened a pull request: https://github.com/apache/kafka/pull/3931 Minor: Fix testUniqueErrorCodes unit test failure I'm not really sure if I'm doing the right thing here, but I thought I'd give it a shot and try to fix the unit test breakage. Running

[GitHub] kafka-site issue #82: Adding minor style changes

Github user dguy commented on the issue: https://github.com/apache/kafka-site/pull/82 @manjuapu you should be able to close it yourself? I can't close it. ---

[GitHub] kafka pull request #3931: Minor: Fix testUniqueErrorCodes unit test failure

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

[jira] [Created] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers

Jason Gustafson created KAFKA-5960: -- Summary: Producer uses unsupported ProduceRequest version against older brokers Key: KAFKA-5960 URL: https://issues.apache.org/jira/browse/KAFKA-5960 Project:

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

See Changes: [me] KAFKA-5330: Use per-task converters in Connect -- [...truncated 360.70 KB...] kafka.security.auth.SimpleAclAuthorizerTest > testAclInheritance PASSED

[jira] [Resolved] (KAFKA-5330) Use per-task converters in Connect

[ https://issues.apache.org/jira/browse/KAFKA-5330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5330. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request

[GitHub] kafka pull request #3196: KAFKA-5330: Use per-task converters in Connect

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

[GitHub] kafka pull request #3937: KAFKA-5856 AdminClient.createPartitions() follow u...

GitHub user tombentley opened a pull request: https://github.com/apache/kafka/pull/3937 KAFKA-5856 AdminClient.createPartitions() follow up Adds support for noop requests. When assignments are given with a request that would be a noop we validate that the given assignments match

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

Damian Guy created KAFKA-5956: - Summary: StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized Key: KAFKA-5956 URL: https://issues.apache.org/jira/browse/KAFKA-5956

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

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3936 KAFKA-5956: use serdes from materialized in table and globalTable The new overloads `StreamBuilder.table(String, Materialized)` and `StreamsBuilder.globalTable(String, Materialized)` need to set the

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

See

Build failed in Jenkins: kafka-trunk-jdk7 #2800

See Changes: [ismael] KAFKA-5954; Correct Connect REST API system test -- [...truncated 354.37 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

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

See

[GitHub] kafka pull request #3935: MINOR: improvement on top of KAFKA-5793: Tighten u...

GitHub user tedyu opened a pull request: https://github.com/apache/kafka/pull/3935 MINOR: improvement on top of KAFKA-5793: Tighten up the semantics of the OutOfOrderSequenceException Simplified the condition in Sender#failBatch() Added log in

Build failed in Jenkins: kafka-trunk-jdk7 #2796

See Changes: [wangguoz] KAFKA-5922: Add SessionWindowedKStream -- [...truncated 356.36 KB...] kafka.message.MessageCompressionTest > testCompressSize STARTED

[GitHub] kafka pull request #3902: KAFKA-5922: Add SessionWindowedKStream

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

[jira] [Created] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

Jiri Pechanec created KAFKA-5953: Summary: Connect classloader isolation may be broken for JDBC drivers Key: KAFKA-5953 URL: https://issues.apache.org/jira/browse/KAFKA-5953 Project: Kafka

[jira] [Resolved] (KAFKA-5922) Add SessionWindowedKStream

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

Build failed in Jenkins: kafka-trunk-jdk7 #2795

See Changes: [ismael] MINOR: Fix testUniqueErrorCodes unit test failure -- [...truncated 354.48 KB...] kafka.server.ServerGenerateBrokerIdTest >

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

See

[GitHub] kafka-site issue #79: Adding Customer section to Streams page

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/79 Some meta comments: 1. The `.DS_Store` should not be included. 2. As @ewencp mentioned, these files under `0110/` should be in `kafka` repo as well. You would need to file a

[GitHub] kafka-site issue #82: Adding minor style changes

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/82 @manjuapu Only the PR submitter can close her own PRs unfortunately. ---

Re: 1.0.0 KIPs Update

Note that the code freeze date is Oct.3, so people will have about two weeks for that. Guozhang On Thu, Sep 21, 2017 at 7:46 AM, Ismael Juma wrote: > Yes, although it would have to be reviewed and merged by next Wednesday. > > Ismael > > On Thu, Sep 21, 2017 at 12:17 AM,

[GitHub] kafka pull request #3921: MINOR: add upgrade note for KIP-173 topic configs

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