[GitHub] kafka pull request #2543: MINOR: Remove unused MessageWriter

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2543 MINOR: Remove unused MessageWriter You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka remove-message-writer Alternatively you ca

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

See Changes: [jason] KAFKA-4758; Connect missing checks for NO_TIMESTAMP -- [...truncated 4115 lines...] kafka.security.auth.SimpleAclAuthorizerTest > testLoadCache STARTED kafka.security.auth

[jira] [Resolved] (KAFKA-4758) Connect WorkerSinkTask is missing checks for NO_TIMESTAMP

[ https://issues.apache.org/jira/browse/KAFKA-4758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4758. Resolution: Fixed Fix Version/s: 0.10.3.0 Issue resolved by pull request 2533 [https:

[jira] [Commented] (KAFKA-4758) Connect WorkerSinkTask is missing checks for NO_TIMESTAMP

[ https://issues.apache.org/jira/browse/KAFKA-4758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863055#comment-15863055 ] ASF GitHub Bot commented on KAFKA-4758: --- Github user asfgit closed the pull request

[GitHub] kafka pull request #2533: KAFKA-4758: Checking the TimestampType is insuffic...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2533 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

Re: [VOTE] 0.10.2.0 RC1

Hello Ian, I looked at the releasing artifact and tried running a simple streams app with multiple threads with the jar but cannot reproduce your issue. If you are still blocked on this I'm wondering if you could provide some code sketch without any app business logic for me to try to reproduce it

[jira] [Commented] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1]

[ https://issues.apache.org/jira/browse/KAFKA-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15862912#comment-15862912 ] Guozhang Wang commented on KAFKA-4732: -- New instances of this failure: https://build

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

See

[jira] [Commented] (KAFKA-4652) Improve test coverage KStreamBuilder

[ https://issues.apache.org/jira/browse/KAFKA-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15862883#comment-15862883 ] Bill Bejeck commented on KAFKA-4652: Misses these as well with auto-offset reset PR, p

Re: [DISCUSS] KIP-117: Add a public AdministrativeClient API for Kafka admin operations

Hey Colin, Thanks for the hard work on this. I know going back and forth on APIs is kind of frustrating but we're at the point where these things live long enough and are used by enough people that it is worth the pain. I'm sure it'll come down in the right place eventually. A couple things I've f

[jira] [Assigned] (KAFKA-4652) Improve test coverage KStreamBuilder

[ https://issues.apache.org/jira/browse/KAFKA-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4652: -- Assignee: Bill Bejeck > Improve test coverage KStreamBuilder >

[GitHub] kafka pull request #2534: MINOR: Update SimpleAclAuthorizer.scala

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2534 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

Re: log.flush.interval.messages setting of Kafka 0.9.0.0

someone can help explain it？ 发自我的超级手机 2016年12月16日 18:17于 Json Tu 写道： > > Hi all, > we have a cluster of 0.9.0.0 with 3 nodes, we have a topic with 3 replicas, > and send it with ack -1, our sending latency is avg 7ms. I prepare to > optimize performance of cluster through adjusting some params

Re: [VOTE] 0.10.2.0 RC1

Hi Matthias, Thank you for your fast response. I am not using any custom class loaders and it is the 10.2 jar that is being used. I'll try clearing out the state on next failure. The config parameters we are setting are: consumer: heartbeat.interval.ms = "100" auto.offset.reset = "earli

[GitHub] kafka pull request #2542: MINOR: Stream metrics documentation

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2542 MINOR: Stream metrics documentation You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-streams-metrics Alternatively y