[GitHub] kafka-site issue #78: MINOR: Add header items

Github user dguy commented on the issue: https://github.com/apache/kafka-site/pull/78 @joel-hamill thanks for the PR. However... these changes should be made against the Apache Kafka project - otherwise we run the risk of losing them. ---

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

Sounds good to me. On Thu, 14 Sep 2017 at 19:55 Guozhang Wang wrote: > I'd suggest we remove both to and through together in KIP-182, since for > operator "KTable#to" is as confusing as to "KTable#through" which > overwhelms its benefit as a syntax sugar. I think the extra

[GitHub] kafka pull request #3872: KAFKA-5716 [WIP]: Recent polled offsets may not be...

GitHub user steff1193 opened a pull request: https://github.com/apache/kafka/pull/3872 KAFKA-5716 [WIP]: Recent polled offsets may not be written/flushed at SourceTask.commit @rhauch @tedyu @hachikuji For now a test showing that the claimed problem is true. Should

[GitHub] kafka pull request #3609: MINOR: Make the state change log more consistent

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

[jira] [Resolved] (KAFKA-4454) Authorizer should also include the Principal generated by the PrincipalBuilder.

[ https://issues.apache.org/jira/browse/KAFKA-4454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4454. -- Resolution: Fixed This is covered in KIP-189/KAFKA-5783 > Authorizer should also include the Principal

[GitHub] kafka pull request #3868: KAFKA-5908: fix range query in CompositeReadOnlyWi...

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

[jira] [Resolved] (KAFKA-5908) CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times

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

[GitHub] kafka pull request #3868: KAFKA-5908: fix range query in CompositeReadOnlyWi...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3868 KAFKA-5908: fix range query in CompositeReadOnlyWindowStore The `NextIteratorFunction` in `CompositeReadOnlyWindowStore` was incorrectly using the `timeFrom` as the `timeTo` You can merge this pull

[GitHub] kafka pull request #3869: MINOR: Make the state change log more consistent

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3869 MINOR: Make the state change log more consistent Use logIdent to achieve this. Also fixed an issue where we were logging about replicas going offline with an empty set of replicas (i.e.

[GitHub] kafka pull request #3870: KAFKA-5856: Add AdminClient.createPartitions()

GitHub user tombentley opened a pull request: https://github.com/apache/kafka/pull/3870 KAFKA-5856: Add AdminClient.createPartitions() See KIP-195. The contribution is my original work and I license the work to the project under the project's open source license.

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

See Changes: [damian.guy] KAFKA-5908; fix range query in CompositeReadOnlyWindowStore -- [...truncated 2.53 MB...] org.apache.kafka.streams.TopologyTest >

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

See

[GitHub] kafka-site issue #77: MINOR: Add streams child topics to left-hand nav

Github user dguy commented on the issue: https://github.com/apache/kafka-site/pull/77 as per: https://github.com/apache/kafka-site/pull/78#issuecomment-329644776 ---

[jira] [Created] (KAFKA-5909) Remove source jars from classpath while executing CLI tools

Kamal Chandraprakash created KAFKA-5909: --- Summary: Remove source jars from classpath while executing CLI tools Key: KAFKA-5909 URL: https://issues.apache.org/jira/browse/KAFKA-5909 Project:

[GitHub] kafka pull request #3871: KAFKA-5909; Removed the source jars from classpath...

GitHub user Kamal15 opened a pull request: https://github.com/apache/kafka/pull/3871 KAFKA-5909; Removed the source jars from classpath while executing CL… …I tools. - redundant `for` loops removed. - I did this change with assumption that there are no priorities in

Re: [DISCUSS] KIP-152 - Improve diagnostics for SASL authentication failures

Hi, Can you pls let me know if this is resolved or any work around is there. I am using Kafka 0.11.0.1 version. a. When incorrect credentials are sent the publisher or consumer API, logs below warning error , but keeps retrying to broker with out disconnecting. b. We are using

[GitHub] kafka-site issue #77: MINOR: Add streams child topics to left-hand nav

Github user joel-hamill commented on the issue: https://github.com/apache/kafka-site/pull/77 @dguy i don't think these files are in https://github.com/apache/kafka/tree/trunk/docs. these are changes specifically to the header/footer/nav, and files that are specific to the kafka-site

Re: [DISCUSS] KIP-152 - Improve diagnostics for SASL authentication failures

Hi Ramkumar, This is being fixed for 1.0.0. a) Retries will be removed for authentication failures. b) With the current behaviour, retries do add load on the broker as new connections are established for retries. There is a backoff interval between connections to reduce the impact. Regards,

[GitHub] kafka pull request #3873: MINOR: Add semicolon to 'SASL/SCRAM' doc

GitHub user makubi opened a pull request: https://github.com/apache/kafka/pull/3873 MINOR: Add semicolon to 'SASL/SCRAM' doc You can merge this pull request into a Git repository by running: $ git pull https://github.com/makubi/kafka doc-sasl-scram-jaas Alternatively you can

[GitHub] kafka pull request #1875: KAFKA-4190 kafka-reassign-partitions does not repo...

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

[GitHub] kafka-site issue #78: MINOR: Add header items

Github user joel-hamill commented on the issue: https://github.com/apache/kafka-site/pull/78 @dguy i don't think these files are in https://github.com/apache/kafka/tree/trunk/docs. these are changes specifically to the header/footer/nav. ---

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

Ramkumar created KAFKA-5910: --- Summary: Kafka 0.11.0.1 Kafka consumer/producers retries in infinite loop when wrong SASL creds are passed Key: KAFKA-5910 URL: https://issues.apache.org/jira/browse/KAFKA-5910

[GitHub] kafka pull request #3708: KAFKA-4764: Wrap SASL tokens in Kafka headers to i...

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

[jira] [Created] (KAFKA-5911) Avoid creation of extra Map for futures in KafkaAdminClient

Ted Yu created KAFKA-5911: - Summary: Avoid creation of extra Map for futures in KafkaAdminClient Key: KAFKA-5911 URL: https://issues.apache.org/jira/browse/KAFKA-5911 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5912) Trogdor AgentTest.testAgentActivatesFaults is flaky

Apurva Mehta created KAFKA-5912: --- Summary: Trogdor AgentTest.testAgentActivatesFaults is flaky Key: KAFKA-5912 URL: https://issues.apache.org/jira/browse/KAFKA-5912 Project: Kafka Issue Type:

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

See Changes: [rajinisivaram] KAFKA-4764; Wrap SASL tokens in Kafka headers to improve diagnostics -- [...truncated 932.07 KB...]

[GitHub] kafka-site pull request #78: MINOR: Add header items

Github user ewencp commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/78#discussion_r139203439 --- Diff: includes/_nav.htm --- @@ -36,7 +36,7 @@ http://www.apache.org/security/; target="_blank">security -

[GitHub] kafka-site pull request #78: MINOR: Add header items

Github user ewencp commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/78#discussion_r139203750 --- Diff: includes/_top.htm --- @@ -1,5 +1,55 @@ - + + +

[GitHub] kafka-site pull request #78: MINOR: Add header items

Github user joel-hamill commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/78#discussion_r139205053 --- Diff: includes/_nav.htm --- @@ -36,7 +36,7 @@ http://www.apache.org/security/; target="_blank">security -

[GitHub] kafka pull request #3867: MINOR: Use full package name when classes referenc...

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

[GitHub] kafka pull request #3875: MINOR: Use full package name when classes referenc...

GitHub user KevinLiLu opened a pull request: https://github.com/apache/kafka/pull/3875 MINOR: Use full package name when classes referenced in documentation The `metric.reporters` description in the documentation says to implement the `MetricReporter` class, but the actual class is

[GitHub] kafka pull request #3876: Force Connect tasks to stop via thread interruptio...

GitHub user 56quarters opened a pull request: https://github.com/apache/kafka/pull/3876 Force Connect tasks to stop via thread interruption after a timeout Interrupt the thread of Kafka Connect tasks that do not stop within the timeout via `Worker::stopAndAwaitTasks()`.

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

See Changes: [damian.guy] KAFKA-5908; fix range query in CompositeReadOnlyWindowStore -- [...truncated 1.15 MB...] kafka.api.SslConsumerTest > testCoordinatorFailover

[GitHub] kafka pull request #3874: KAFKA-5163; Support replicas movement between log ...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/3874 KAFKA-5163; Support replicas movement between log directories (KIP-113) You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka

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

See Changes: [rajinisivaram] KAFKA-4764; Wrap SASL tokens in Kafka headers to improve diagnostics -- [...truncated 4.46 MB...] kafka.utils.json.JsonValueTest >

[GitHub] kafka-site issue #78: MINOR: Add header items

Github user joel-hamill commented on the issue: https://github.com/apache/kafka-site/pull/78 @manjuapu ---

[GitHub] kafka-site pull request #78: MINOR: Add header items

Github user joel-hamill commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/78#discussion_r139205416 --- Diff: includes/_top.htm --- @@ -1,5 +1,55 @@ - + + +

[GitHub] kafka-site pull request #78: MINOR: Add header items

Github user joel-hamill commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/78#discussion_r139205540 --- Diff: includes/_top.htm --- @@ -1,5 +1,55 @@ - + + +

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

See

[GitHub] kafka-site issue #78: MINOR: Add header items

Github user ewencp commented on the issue: https://github.com/apache/kafka-site/pull/78 @joel-hamill Something like this should work: ``` diff --git a/css/styles.css b/css/styles.css index 1e75e91..2aa587e 100644 --- a/css/styles.css +++ b/css/styles.css @@

Re: system test builder

Hi Ted, Unfortunately the jenkins.confluent.io address is no longer publicly accessible. Thanks, Apurva On Thu, Sep 14, 2017 at 7:35 PM, Ted Yu wrote: > Hi, > When I put the following in the address bar of Chrome: > >

[jira] [Created] (KAFKA-5908) CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times

Damian Guy created KAFKA-5908: - Summary: CompositeReadOnlyWindowStore range fetch doesn't return all values when fetching with different start and end times Key: KAFKA-5908 URL:

[jira] [Created] (KAFKA-5907) Support aggregatedJavadoc in Java 9

Ismael Juma created KAFKA-5907: -- Summary: Support aggregatedJavadoc in Java 9 Key: KAFKA-5907 URL: https://issues.apache.org/jira/browse/KAFKA-5907 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-5915) Support unmapping of mapped/direct buffers in Java 9

Ismael Juma created KAFKA-5915: -- Summary: Support unmapping of mapped/direct buffers in Java 9 Key: KAFKA-5915 URL: https://issues.apache.org/jira/browse/KAFKA-5915 Project: Kafka Issue Type:

[GitHub] kafka-site pull request #77: MINOR: Add streams child topics to left-hand na...

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/77#discussion_r139275915 --- Diff: index.html --- @@ -7,17 +7,17 @@ Publish subscribe

[GitHub] kafka-site pull request #77: MINOR: Add streams child topics to left-hand na...

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/77#discussion_r139275946 --- Diff: index.html --- @@ -7,17 +7,17 @@ Publish subscribe

[GitHub] kafka-site pull request #77: MINOR: Add streams child topics to left-hand na...

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/77#discussion_r139275996 --- Diff: index.html --- @@ -7,17 +7,17 @@ Publish subscribe

[GitHub] kafka-site pull request #77: MINOR: Add streams child topics to left-hand na...

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/77#discussion_r139275998 --- Diff: includes/_nav.htm --- @@ -11,6 +11,12 @@ getting started APIs kafka streams + ---

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

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3879 KAFKA-5915: Support unmapping of mapped/direct buffers in Java 9 As mentioned in MappedByteBuffers' class documentation, its implementation was inspired by Lucene's MMapDirectory:

Re: Please add me to contributor list

What's your apache id? On Sat, Sep 16, 2017 at 8:24 AM, 鄭紹志 wrote: > I want to work on some issue, please add me to contributor list in JIRA. > > Also need to write permission in Confluence. > > > Thanks ! > Vito > -- -- Guozhang

[GitHub] kafka pull request #3877: MINOR: Disable KafkaAdminClientTest.testHandleTime...

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

[GitHub] kafka pull request #3877: MINOR: Disable KafkaAdminClientTest.testHandleTime...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3877 MINOR: Disable KafkaAdminClientTest.testHandleTimeout This test is super flaky in the PR builder. https://issues.apache.org/jira/browse/KAFKA-5792 tracks the fix. You can merge this pull request

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

See

Re: Kip Write Access

Hi Richard, It's done. Cheers. Guozhang On Fri, Sep 15, 2017 at 10:28 AM, Richard Yu wrote: > Hello, I wish to write a kip. Could you grant me access? > > Thanks > > (Wiki username is yohan.richard.yu) > -- -- Guozhang

Please add me to contributor list

I want to work on some issue, please add me to contributor list in JIRA. Also need to write permission in Confluence. Thanks ! Vito

[jira] [Created] (KAFKA-5913) Add RecordMetadataNotAvailableException to indicate that ProduceResponse did not contain offset and timestamp information

Apurva Mehta created KAFKA-5913: --- Summary: Add RecordMetadataNotAvailableException to indicate that ProduceResponse did not contain offset and timestamp information Key: KAFKA-5913 URL:

[jira] [Created] (KAFKA-5914) Return MessageFormatVersion and MessageMaxBytes in MetadataResponse

Apurva Mehta created KAFKA-5914: --- Summary: Return MessageFormatVersion and MessageMaxBytes in MetadataResponse Key: KAFKA-5914 URL: https://issues.apache.org/jira/browse/KAFKA-5914 Project: Kafka

[GitHub] kafka pull request #3878: KAFKA-5913: Add the RecordMetadataNotAvailableExce...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3878 KAFKA-5913: Add the RecordMetadataNotAvailableException We return this exception from `RecordMetadata.offset()` or `RecordMetadata.timestamp()` if these pieces of metadata were not returned by the