[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047462#comment-16047462 ] Paolo Patierno commented on KAFKA-5434: --- Hi [~vahid] is it possible assigning to me

[jira] [Assigned] (KAFKA-5317) Update KIP-98 to reflect changes during implementation.

[ https://issues.apache.org/jira/browse/KAFKA-5317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-5317: --- Assignee: Apurva Mehta > Update KIP-98 to reflect changes during implementation. > --

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Commented] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047425#comment-16047425 ] Jian Lin commented on KAFKA-5432: - [~huxi_2b] Thanks for your reply. No any changes were

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Commented] (KAFKA-5438) UnsupportedOperationException in WriteTxnMarkers handler

[ https://issues.apache.org/jira/browse/KAFKA-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047417#comment-16047417 ] ASF GitHub Bot commented on KAFKA-5438: --- GitHub user apurvam opened a pull request:

[GitHub] kafka pull request #3313: KAFKA-5438: Fix UnsupportedOperationException in w...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3313 KAFKA-5438: Fix UnsupportedOperationException in writeTxnMarkersRequest Before this patch, the `partitionErrors` was an immutable map. As a result if a single producer had a marker for multiple part

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5438) UnsupportedOperationException in WriteTxnMarkers handler

[ https://issues.apache.org/jira/browse/KAFKA-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5438: --- Fix Version/s: (was: 0.11.1.0) 0.11.0.0 > UnsupportedOperationException

[jira] [Commented] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047390#comment-16047390 ] huxihx commented on KAFKA-5432: --- Are there any changes before observing these exceptions? Sa

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

See

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

See

Re: KIP-160 - Augment KStream.print() to allow users pass in extra parameters in the printed string

Agree with Guozhang, +1 James Chien

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

See Changes: [ismael] KAFKA-5404; Add more AdminClient checks to ClientCompatibilityTest -- [...truncated 895.94 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > sho

[jira] [Resolved] (KAFKA-5428) Transactional producer aborts batches incorrectly in abortable error state

[ https://issues.apache.org/jira/browse/KAFKA-5428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5428. Resolution: Fixed Issue resolved by pull request 3298 [https://github.com/apache/kafka/pull/

[jira] [Commented] (KAFKA-5428) Transactional producer aborts batches incorrectly in abortable error state

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

[GitHub] kafka pull request #3298: KAFKA-5428: Transactional producer should only abo...

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

[GitHub] kafka pull request #3312: HOFIX: Introduce max wait time for retry-and-backo...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3312 HOFIX: Introduce max wait time for retry-and-backoff while creating tasks You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka hotfix-backo

[GitHub] kafka pull request #3311: MINOR: fix local Docker setup

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3311 MINOR: fix local Docker setup You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka colins-patch Alternatively you can review and apply the

[jira] [Commented] (KAFKA-5362) Add EOS system tests for Streams API

[ https://issues.apache.org/jira/browse/KAFKA-5362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047282#comment-16047282 ] ASF GitHub Bot commented on KAFKA-5362: --- GitHub user mjsax opened a pull request:

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

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3310 KAFKA-5362: Add Streams EOS system test with repartitioning topic You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka kafka-5362-add-eos-

[jira] [Assigned] (KAFKA-5274) Review and improve AdminClient Javadoc for the first release (KIP-117)

[ https://issues.apache.org/jira/browse/KAFKA-5274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5274: -- Assignee: Ismael Juma > Review and improve AdminClient Javadoc for the first release (KIP-117)

[jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements

[ https://issues.apache.org/jira/browse/KAFKA-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3866: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > KerberosLogin refresh time bug and ot

[jira] [Updated] (KAFKA-5417) Clients get inconsistent connection states when SASL/SSL connection is marked CONECTED and DISCONNECTED at the same time

[ https://issues.apache.org/jira/browse/KAFKA-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5417: --- Status: Patch Available (was: Open) > Clients get inconsistent connection states when SASL/SSL connec

[jira] [Updated] (KAFKA-5438) UnsupportedOperationException in WriteTxnMarkers handler

[ https://issues.apache.org/jira/browse/KAFKA-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5438: Labels: exactly-once (was: ) > UnsupportedOperationException in WriteTxnMarkers handler > -

[jira] [Resolved] (KAFKA-5436) NullPointerException when loading producer snapshot

[ https://issues.apache.org/jira/browse/KAFKA-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5436. Resolution: Duplicate Marking this as a dup. We can reopen if we hit the error again after K

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

See -- [...truncated 4.57 MB...] org.apache.kafka.streams.StreamsConfigTest > testGetProducerConfigs STARTED org.apache.kafka.streams.StreamsConfigTest > testGetProducerConfigs PASSED o

[jira] [Commented] (KAFKA-5436) NullPointerException when loading producer snapshot

[ https://issues.apache.org/jira/browse/KAFKA-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047247#comment-16047247 ] Jason Gustafson commented on KAFKA-5436: I think the underlying cause is KAFKA-543

[GitHub] kafka pull request #3309: MINOR: NetworkClient#disconnect should not erase c...

GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/3309 MINOR: NetworkClient#disconnect should not erase connection info NetworkClient#disconnect should not erase the connection information. This will allow exponential backoff to occur. You can mer

[jira] [Commented] (KAFKA-5429) Producer IllegalStateException: Batch has already been completed

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

[GitHub] kafka pull request #3300: KAFKA-5429: Ignore produce response if batch was p...

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

[jira] [Resolved] (KAFKA-5429) Producer IllegalStateException: Batch has already been completed

[ https://issues.apache.org/jira/browse/KAFKA-5429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5429. Resolution: Fixed Issue resolved by pull request 3300 [https://github.com/apache/kafka/pull/

[jira] [Assigned] (KAFKA-5436) NullPointerException when loading producer snapshot

[ https://issues.apache.org/jira/browse/KAFKA-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-5436: --- Assignee: Jason Gustafson (was: Apurva Mehta) > NullPointerException when loading producer s

[jira] [Assigned] (KAFKA-5438) UnsupportedOperationException in WriteTxnMarkers handler

[ https://issues.apache.org/jira/browse/KAFKA-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-5438: -- Assignee: Apurva Mehta (was: Jason Gustafson) > UnsupportedOperationException in Write

[jira] [Created] (KAFKA-5438) UnsupportedOperationException in WriteTxnMarkers handler

Jason Gustafson created KAFKA-5438: -- Summary: UnsupportedOperationException in WriteTxnMarkers handler Key: KAFKA-5438 URL: https://issues.apache.org/jira/browse/KAFKA-5438 Project: Kafka Is

[jira] [Commented] (KAFKA-5437) TransactionalMessageCopier should be force killed on test shutdown

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

[GitHub] kafka pull request #3308: KAFKA-5437: Always send a sig_kill when cleaning t...

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

[jira] [Resolved] (KAFKA-5437) TransactionalMessageCopier should be force killed on test shutdown

[ https://issues.apache.org/jira/browse/KAFKA-5437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5437. Resolution: Fixed Fix Version/s: (was: 0.11.1.0) 0.11.0.0 Issu

[jira] [Commented] (KAFKA-5437) TransactionalMessageCopier should be force killed on test shutdown

[ https://issues.apache.org/jira/browse/KAFKA-5437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047171#comment-16047171 ] ASF GitHub Bot commented on KAFKA-5437: --- GitHub user apurvam opened a pull request:

[GitHub] kafka pull request #3308: KAFKA-5437: Always send a sig_kill when cleaning t...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3308 KAFKA-5437: Always send a sig_kill when cleaning the message copier When the message copier hangs (like when there is a bug in the client), it ignores the sigterm and doesn't shut down. this leaves

[jira] [Updated] (KAFKA-5436) NullPointerException when loading producer snapshot

[ https://issues.apache.org/jira/browse/KAFKA-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5436: Issue Type: Sub-task (was: Bug) Parent: KAFKA-4815 > NullPointerException when loading prod

[jira] [Commented] (KAFKA-5427) Transactional producer cannot find coordinator when trying to abort transaction after error

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

[GitHub] kafka pull request #3297: KAFKA-5427: Transactional producer should allow Fi...

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

[jira] [Resolved] (KAFKA-5427) Transactional producer cannot find coordinator when trying to abort transaction after error

[ https://issues.apache.org/jira/browse/KAFKA-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5427. Resolution: Fixed Issue resolved by pull request 3297 [https://github.com/apache/kafka/pull/

[GitHub] kafka pull request #3284: MINOR: A few cleanups of usage of Either in TC

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

[GitHub] kafka pull request #3305: MINOR: Specify keyalg RSA for SSL key generation c...

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

[jira] [Commented] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047111#comment-16047111 ] Ismael Juma commented on KAFKA-3978: This is the root cause of KAFKA-3123 as well, see

[jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3978: --- Priority: Critical (was: Major) > Cannot truncate to a negative offset (-1) exception at broker start

[jira] [Assigned] (KAFKA-3123) Follower Broker cannot start if offsets are already out of range

[ https://issues.apache.org/jira/browse/KAFKA-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3123: -- Assignee: Mickael Maison (was: Soumyajit Sahu) > Follower Broker cannot start if offsets are a

[jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3978: --- Labels: reliability startup (was: startup) > Cannot truncate to a negative offset (-1) exception at b

[jira] [Commented] (KAFKA-3123) Follower Broker cannot start if offsets are already out of range

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

[jira] [Updated] (KAFKA-3123) Follower Broker cannot start if offsets are already out of range

[ https://issues.apache.org/jira/browse/KAFKA-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3123: --- Resolution: Fixed Fix Version/s: (was: 0.11.0.1) 0.11.0.0 Stat

[GitHub] kafka pull request #3296: KAFKA-3123: Follower Broker cannot start if offset...

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

[jira] [Commented] (KAFKA-5404) Add more AdminClient checks to ClientCompatibilityTest

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

[jira] [Resolved] (KAFKA-5404) Add more AdminClient checks to ClientCompatibilityTest

[ https://issues.apache.org/jira/browse/KAFKA-5404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5404. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 3263 [https://github

[GitHub] kafka pull request #3263: KAFKA-5404: Add more AdminClient checks to ClientC...

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

[jira] [Created] (KAFKA-5437) TransactionalMessageCopier should be force killed on test shutdown

Jason Gustafson created KAFKA-5437: -- Summary: TransactionalMessageCopier should be force killed on test shutdown Key: KAFKA-5437 URL: https://issues.apache.org/jira/browse/KAFKA-5437 Project: Kafka

[jira] [Commented] (KAFKA-3129) Console producer issue when request-required-acks=0

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047074#comment-16047074 ] Vahid Hashemian commented on KAFKA-3129: [~pmishra01] I tried this on Ubuntu, Wind

Re: [ANNOUNCE] New committer: Damian Guy

congrats Damian!! Regards, Bharat On Mon, Jun 12, 2017 at 12:52 PM, Konstantine Karantasis < konstant...@confluent.io> wrote: > Congrats! > > On Mon, Jun 12, 2017 at 12:48 PM, Michael Noll > wrote: > > > Congratulations, Damian! > > > > On Mon, Jun 12, 2017 at 9:07 AM, Molnár Bálint > > wrot

[jira] [Created] (KAFKA-5436) NullPointerException when loading producer snapshot

Apurva Mehta created KAFKA-5436: --- Summary: NullPointerException when loading producer snapshot Key: KAFKA-5436 URL: https://issues.apache.org/jira/browse/KAFKA-5436 Project: Kafka Issue Type: B

[jira] [Updated] (KAFKA-4831) Extract WindowedSerde to public APIs

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Pushkar updated KAFKA-4831: -- Reviewer: Guozhang Wang Status: Patch Available (was: In Progress) > Extract WindowedSerd

[jira] [Commented] (KAFKA-4831) Extract WindowedSerde to public APIs

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047003#comment-16047003 ] ASF GitHub Bot commented on KAFKA-4831: --- GitHub user vitaly-pushkar opened a pull re

[GitHub] kafka pull request #3307: KAFKA-4831: Extract WindowedSerde to public APIs

GitHub user vitaly-pushkar opened a pull request: https://github.com/apache/kafka/pull/3307 KAFKA-4831: Extract WindowedSerde to public APIs Now that we have augmented WindowSerde with non-arg parameters, extract it out as part of the public APIs so that users who want to I/O window

Kafka paper broken link in confluence

On the papers and presentations confluence page [1], the original Kafka paper is now a broken link [2], perhaps because the person who had put it on their site took it down. I saw a few places such as http://notes.stephenholiday.com/Kafka.pdf that ho

Re: [ANNOUNCE] New committer: Damian Guy

Congrats! On Mon, Jun 12, 2017 at 12:48 PM, Michael Noll wrote: > Congratulations, Damian! > > On Mon, Jun 12, 2017 at 9:07 AM, Molnár Bálint > wrote: > > > Congrats, Damien! > > > > 2017-06-12 8:44 GMT+02:00 Rajini Sivaram : > > > > > Congratulations, Damian! > > > > > > On Sat, Jun 10, 2017 a

[jira] [Commented] (KAFKA-5416) TransactionCoordinator doesn't complete transition to CompleteCommit

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

[GitHub] kafka pull request #3287: KAFKA-5416: Re-prepare transition to CompleteCommi...

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

[jira] [Updated] (KAFKA-5416) TransactionCoordinator doesn't complete transition to CompleteCommit

[ https://issues.apache.org/jira/browse/KAFKA-5416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5416: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull requ

Re: [ANNOUNCE] New committer: Damian Guy

Congratulations, Damian! On Mon, Jun 12, 2017 at 9:07 AM, Molnár Bálint wrote: > Congrats, Damien! > > 2017-06-12 8:44 GMT+02:00 Rajini Sivaram : > > > Congratulations, Damian! > > > > On Sat, Jun 10, 2017 at 12:15 PM, Mickael Maison < > mickael.mai...@gmail.com > > > > > wrote: > > > > > Congra

Re: Starting contribution on Apache Kafka project

Hi, any news on this ? I see a lot of activity for the new release so maybe the previous email was lost. :) Thanks ! Paolo From: Paolo Patierno Sent: Wednesday, 7 June, 11:31 Subject: Starting contribution on Apache Kafka project To: dev@kafka.apache.org Hi Kafka devs, I'd like to start con

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046960#comment-16046960 ] Kelvin Rutt commented on KAFKA-5413: I've just had this issue myself. The problem is t

Re: Changing JIRA notifications to remove Single Email Address (dev@kafka.apache.org)

Thanks for everyone who has spoken out. I have filed https://issues.apache.org/jira/browse/INFRA-14336 to Apache INFRA. Guozhang On Fri, Jun 9, 2017 at 3:07 PM, Matthias J. Sax wrote: > +1 > > On 6/9/17 3:01 PM, Bill Bejeck wrote: > > +1 > > > > Thanks, > > Bill > > > > On Fri, Jun 9, 2017 at

[jira] [Updated] (KAFKA-5428) Transactional producer aborts batches incorrectly in abortable error state

[ https://issues.apache.org/jira/browse/KAFKA-5428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5428: Labels: exactly-once (was: ) > Transactional producer aborts batches incorrectly in abortable error

[jira] [Updated] (KAFKA-5427) Transactional producer cannot find coordinator when trying to abort transaction after error

[ https://issues.apache.org/jira/browse/KAFKA-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5427: Labels: exactly-once (was: ) > Transactional producer cannot find coordinator when trying to abort

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r121496464 --- Diff: 0110/design.html --- @@ -261,15 +262,23 @@ It can read the messages, process the messages, and finally save its position. In this

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r121496370 --- Diff: 0110/design.html --- @@ -261,15 +262,23 @@ It can read the messages, process the messages, and finally save its position. In this

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046913#comment-16046913 ] Federico Giraud commented on KAFKA-5413: Please let us know if you need any additi

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r121492476 --- Diff: 0110/design.html --- @@ -261,15 +262,23 @@ It can read the messages, process the messages, and finally save its position. In this

[jira] [Commented] (KAFKA-5435) Produce state lost if no snapshot retained

[ https://issues.apache.org/jira/browse/KAFKA-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046868#comment-16046868 ] ASF GitHub Bot commented on KAFKA-5435: --- GitHub user hachikuji opened a pull request

[GitHub] kafka pull request #3306: KAFKA-5435: Ensure producer snapshot retained afte...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3306 KAFKA-5435: Ensure producer snapshot retained after truncation You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5435 Alt

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

See

[jira] [Commented] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

[ https://issues.apache.org/jira/browse/KAFKA-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046851#comment-16046851 ] Matthias J. Sax commented on KAFKA-4743: Thanks a lot. Sounds great :) > Add a to

[GitHub] kafka-site pull request #57: New items for the Powered by page

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

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046845#comment-16046845 ] Nicholas Ngorok commented on KAFKA-5413: I've uploaded all files pertaining to the

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

[ https://issues.apache.org/jira/browse/KAFKA-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046848#comment-16046848 ] Matthias J. Sax commented on KAFKA-5145: This seems to be a duplicate: https://iss

[jira] [Updated] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Ngorok updated KAFKA-5413: --- Attachment: .index.cleaned .log.cleaned

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Hey Colin, Thanks for the suggestion. We have actually considered this and list this as the first future work in KIP-112 . The two advantages that you mentioned are exactly the motivation for this feature. A

Re: 回复：Re： [DISCUSS] KIP-148: Add a connect timeout for client

Just a note: KIP-144 added exponential backoff for broker reconnect attempts, configured via reconnect.backoff.max.ms. cheers, Colin On Sat, Jun 10, 2017, at 08:42, 东方甲乙 wrote: > -- 原始邮件 -- > 发件人: "东方甲乙";<254479...@qq.com>; > 发送时间: 2017年6月4日(星期天) 晚上6:05 > 收件人: "dev

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Has anyone considered a scheme for sharding topic data across multiple disks? For example, if you sharded topics across 3 disks, and you had 10 disks, you could pick a different set of 3 disks for each topic. If you distribute them randomly then you have 10 choose 3 = 120 different combinations.

Re: [DISCUSS] KIP-150 - Kafka-Streams Cogroup

I think we are discussing two separate things here, so it might be worth clarifying: 1) the position of the initializer with respect to the aggregators. If I understand correctly, Guozhang seems to think it is more natural to specify the initializer first, despite it not bearing any relation to th

[jira] [Commented] (KAFKA-5245) KStream builder should capture serdes

[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046796#comment-16046796 ] Matthias J. Sax commented on KAFKA-5245: But {{KStream#groupByKey()}} uses the ser

[jira] [Assigned] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster

[ https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-5424: - Assignee: Mickael Maison > KafkaConsumer.listTopics() throws Exception when unauthorized

[jira] [Assigned] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5434: -- Assignee: Vahid Hashemian > Console consumer hangs if not existing partition is specifi

[jira] [Commented] (KAFKA-4857) Use AdminClient in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046763#comment-16046763 ] Guozhang Wang commented on KAFKA-4857: -- I think it will not be included in the 0.11.0

  1   2   >