RE: Pause and max.poll.records

Sorry, seems it works as you said. System.out.print("+") in my test is buffered. It does not show the "+" immediately till I print a new line. Weird. Thanks a lot! Yan -Original Message- From: Yan Wang Sent: Sunday, June 25, 2017 11:18 PM To: dev@kafka.apache.org Subject: RE: Pause an

RE: Pause and max.poll.records

As I tested, seems if I pause p1 but do not call pause/resume again on p1, I cannot pull any message from p2. But if I pause p1, I find I get one message from p2 each time I call pause on p1 ( I mean I keep calling consumer.pause(p1) before consumer.poll). Is it a bug or right behavior? Thanks

[GitHub] kafka pull request #3429: KAFKA-5508: Documentation for altering topics

GitHub user huxihx opened a pull request: https://github.com/apache/kafka/pull/3429 KAFKA-5508: Documentation for altering topics Operations documentation should guide user to employ `kafka-configs.sh` to add/remove configs for a topic. You can merge this pull request into a Git re

[jira] [Resolved] (KAFKA-5145) Remove task close() call from closeNonAssignedSuspendedTasks method

[ https://issues.apache.org/jira/browse/KAFKA-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5145. Resolution: Duplicate > Remove task close() call from closeNonAssignedSuspendedTasks method

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

See Changes: [wangguoz] KAFKA-5362: Add Streams EOS system test with repartitioning topic -- [...truncated 4.26 MB...] kafka.tools.MirrorMakerTest > testDefaultMirrorMak

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

See

[GitHub] kafka pull request #3428: HOTFIX: Add back the copy-constructor of abstract ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3428 HOTFIX: Add back the copy-constructor of abstract stream You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KHotfix-add-co

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

See Changes: [wangguoz] KAFKA-5362: Add Streams EOS system test with repartitioning topic -- [...truncated 961.48 KB...] kafka.coordinator.transaction.TransactionMarkerCha

[GitHub] kafka pull request #3310: KAFKA-5362: Add Streams EOS system test with repar...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3310 --- 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