[GitHub] kafka pull request #3997: Applying AC transformation using Rascal

GitHub user jmarcelonunes opened a pull request: https://github.com/apache/kafka/pull/3997 Applying AC transformation using Rascal Using Rascal Software retrieved from https://github.com/refactoring-towards-language-evolution/rascal-Java8. AC transformation was applied and the

Re: How is CorrelationId used for matching request and response

Which release / version are you looking at ? In trunk branch, I only see one toSend(): protected Send toSend(String destination, ResponseHeader header, short apiVersion) { return new NetworkSend(destination, serialize(apiVersion, header)); On Fri, Sep 29, 2017 at 4:49 PM, Javed,

How is CorrelationId used for matching request and response

The Kafka protocol guide mentions that each request and response contains a correlationId which is a user-supplied integer to match requests and corresponding responses. However, when I look at the code in the class AbstractResponse, we have a method defined as following: public Send

[jira] [Reopened] (KAFKA-5989) disableLogging() causes an initialization loop

[ https://issues.apache.org/jira/browse/KAFKA-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tuan Nguyen reopened KAFKA-5989: > disableLogging() causes an initialization loop > -- > >

[GitHub] kafka pull request #3996: KAFKA-5746; Return 0.0 from Metric.value() instead...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3996 KAFKA-5746; Return 0.0 from Metric.value() instead of throwing exception This is less likely to break custom metric reporters and since the method is deprecated, people will be warned about this

[GitHub] kafka pull request #3995: KAFKA-5514 KafkaConsumer ignores default values in...

GitHub user Galus opened a pull request: https://github.com/apache/kafka/pull/3995 KAFKA-5514 KafkaConsumer ignores default values in Properties object because of incorrect use of Properties object. This problem plagues anywhere Properties are being misused. I have this issue with

[jira] [Created] (KAFKA-5996) JsonConverter generates "Mismatching schema" DataException

Yuqi Li created KAFKA-5996: -- Summary: JsonConverter generates "Mismatching schema" DataException Key: KAFKA-5996 URL: https://issues.apache.org/jira/browse/KAFKA-5996 Project: Kafka Issue Type: Bug

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

Github user derrickdoo commented on the issue: https://github.com/apache/kafka-site/pull/78 @joel-hamill I'm concerned that the horizontal nav you're introducing here is going to cause some usability issues and actually conflicts with some work that's been going on with the Streams

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

See Changes: [damian.guy] KAFKA-5986; Streams State Restoration never completes when logging is -- [...truncated 862.98 KB...]

[GitHub] kafka pull request #3994: KAFKA-5985: update javadoc regarding closing itera...

GitHub user bbejeck opened a pull request: https://github.com/apache/kafka/pull/3994 KAFKA-5985: update javadoc regarding closing iterators You can merge this pull request into a Git repository by running: $ git pull https://github.com/bbejeck/kafka

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

See Changes: [ismael] KAFKA-5968; Create/remove request metrics during broker startup/shutdown -- [...truncated 1.38 MB...]

[GitHub] kafka pull request #3993: KAFKA-5995; Rename AlterReplicaDir to AlterReplica...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/3993 KAFKA-5995; Rename AlterReplicaDir to AlterReplicaDirs You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-5995

[jira] [Created] (KAFKA-5995) Rename AlterReplicaDir to AlterReplicaDirs

Dong Lin created KAFKA-5995: --- Summary: Rename AlterReplicaDir to AlterReplicaDirs Key: KAFKA-5995 URL: https://issues.apache.org/jira/browse/KAFKA-5995 Project: Kafka Issue Type: Bug

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

See Changes: [damian.guy] KAFKA-5986; Streams State Restoration never completes when logging is -- [...truncated 1.39 MB...]

[jira] [Resolved] (KAFKA-5968) Remove all broker metrics during shutdown

[ https://issues.apache.org/jira/browse/KAFKA-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5968. Resolution: Fixed Fix Version/s: (was: 1.1.0) 1.0.0 > Remove all

[GitHub] kafka pull request #3991: KAFKA-5968: Create/remove request metrics during b...

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

[GitHub] kafka pull request #3983: KAFKA-5986: Streams State Restoration never comple...

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

[GitHub] kafka pull request #3920: KAFKA-5940: Throw exception if the JSON file is in...

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

[jira] [Created] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations

Dustin Cote created KAFKA-5994: -- Summary: Improve transparency of broker user ACL misconfigurations Key: KAFKA-5994 URL: https://issues.apache.org/jira/browse/KAFKA-5994 Project: Kafka Issue

[GitHub] kafka pull request #3992: MINOR: Allow schedule and commit in MockProcessorC...

GitHub user mewwts opened a pull request: https://github.com/apache/kafka/pull/3992 MINOR: Allow schedule and commit in MockProcessorContext This change allows for testing custom Processors and Transformers that call `schedule` and `commit` using KStreamTestDriver, by _not_

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

See

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

See Changes: [damian.guy] KAFKA-4593; Don't throw IllegalStateException and die on task migration [damian.guy] KAFKA-5949; Follow-up after latest KIP-161 changes [damian.guy] MINOR: always set Serde.Long on

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

See

[GitHub] kafka pull request #3991: KAFKA-5968: Create/remove request metrics during b...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3991 KAFKA-5968: Create/remove request metrics during broker startup/shutdown Replaces the static `RequestMetrics` object with a class so that metrics are created and removed during broker startup

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

See Changes: [damian.guy] KAFKA-4593; Don't throw IllegalStateException and die on task migration [damian.guy] KAFKA-5949; Follow-up after latest KIP-161 changes --

[jira] [Resolved] (KAFKA-4206) Improve handling of invalid credentials to mitigate DOS issue (especially on SSL listeners)

[ https://issues.apache.org/jira/browse/KAFKA-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-4206. -- Resolution: Won't Do > Improve handling of invalid credentials to mitigate DOS issue

[GitHub] kafka pull request #1934: KAFKA-4206 Improve handling of invalid credentials...

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

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

See

[GitHub] kafka pull request #3978: KAFKA-5932: Avoid call to fetchPrevious in FlushLi...

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

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

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

[jira] [Resolved] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir

[ https://issues.apache.org/jira/browse/KAFKA-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marc Cortinas resolved KAFKA-5982. -- Resolution: Won't Fix > Kafka 0.9.0.1 doesn't start after delete storage dir >

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

See

[GitHub] kafka pull request #3986: KAFKA-5949: Follow-up after latest KIP-161 changes

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

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

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

[GitHub] kafka pull request #3989: KAFKA-5746; Fix conversion count computed in `down...

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

[jira] [Resolved] (KAFKA-5992) Better Java Documentation for AdminClient Exceptions

[ https://issues.apache.org/jira/browse/KAFKA-5992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5992. Resolution: Duplicate Duplicate of KAFKA-5445. > Better Java Documentation for AdminClient

[GitHub] kafka pull request #3990: simple change to KafkaHealth

GitHub user prasincs opened a pull request: https://github.com/apache/kafka/pull/3990 simple change to KafkaHealth You can merge this pull request into a Git repository by running: $ git pull https://github.com/prasincs/kafka KAFKA-5473 Alternatively you can review and apply