[GitHub] kafka pull request #1746: KAFKA-4049: Fix transient failure in RegexSourceIn...

GitHub user guozhangwang reopened a pull request: https://github.com/apache/kafka/pull/1746 KAFKA-4049: Fix transient failure in RegexSourceIntegrationTest You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka

[jira] [Commented] (KAFKA-4049) Transient failure in RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-4049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429594#comment-15429594 ] ASF GitHub Bot commented on KAFKA-4049: --- Github user guozhangwang closed the pull request at:

[GitHub] kafka pull request #1746: KAFKA-4049: Fix transient failure in RegexSourceIn...

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

[jira] [Commented] (KAFKA-4049) Transient failure in RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-4049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429595#comment-15429595 ] ASF GitHub Bot commented on KAFKA-4049: --- GitHub user guozhangwang reopened a pull request:

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429559#comment-15429559 ] Bill Bejeck commented on KAFKA-3478: [~mjsax], thanks for the clarification. I'll take a look at what

[jira] [Resolved] (KAFKA-4068) FileSinkTask - use JsonConverter to serialize

[ https://issues.apache.org/jira/browse/KAFKA-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shikhar Bhushan resolved KAFKA-4068. Resolution: Not A Problem I was thinking JSON since it would be easy to serialize to a

[jira] [Updated] (KAFKA-4070) Implement a useful Struct.toString()

[ https://issues.apache.org/jira/browse/KAFKA-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shikhar Bhushan updated KAFKA-4070: --- Description: Logging of {{Struct}}'s does not currently provide any useful output, and users

[jira] [Updated] (KAFKA-4070) Implement a useful Struct.toString()

[ https://issues.apache.org/jira/browse/KAFKA-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shikhar Bhushan updated KAFKA-4070: --- Description: Logging of {{Struct}}'s does not currently provide any useful output, and users

[jira] [Created] (KAFKA-4070) Implement a useful Struct.toString()

Shikhar Bhushan created KAFKA-4070: -- Summary: Implement a useful Struct.toString() Key: KAFKA-4070 URL: https://issues.apache.org/jira/browse/KAFKA-4070 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-4068) FileSinkTask - use JsonConverter to serialize

[ https://issues.apache.org/jira/browse/KAFKA-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429511#comment-15429511 ] Ewen Cheslack-Postava commented on KAFKA-4068: -- Or we could override the Struct class's

Jenkins build is back to normal : kafka-0.10.0-jdk7 #192

See

[GitHub] kafka pull request #1765: MINOR: improve Streams application reset tool to m...

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

[GitHub] kafka pull request #1767: KAFKA-4058: Failure in org.apache.kafka.streams.in...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/1767 KAFKA-4058: Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset You can merge this pull request into a Git repository by running: $ git

[jira] [Commented] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

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

[jira] [Commented] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429487#comment-15429487 ] ASF GitHub Bot commented on KAFKA-4058: --- Github user mjsax closed the pull request at:

[GitHub] kafka pull request #1766: KAFKA-4058: Failure in org.apache.kafka.streams.in...

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

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429400#comment-15429400 ] Matthias J. Sax commented on KAFKA-3478: Hey [~bbejeck]. It is still available. However, it is not

[jira] [Work started] (KAFKA-4023) Add thread id as prefix in Kafka Streams thread logging

[ https://issues.apache.org/jira/browse/KAFKA-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4023 started by Bill Bejeck. -- > Add thread id as prefix in Kafka Streams thread logging >

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

See Changes: [wangguoz] KAFKA-3949: Fix race condition when metadata update arrives during -- [...truncated 12056 lines...]

[jira] [Work started] (KAFKA-3780) Add new config cache.max.bytes.buffering to the streams configuration

[ https://issues.apache.org/jira/browse/KAFKA-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3780 started by Eno Thereska. --- > Add new config cache.max.bytes.buffering to the streams configuration >

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

See Changes: [wangguoz] KAFKA-3949: Fix race condition when metadata update arrives during -- [...truncated 12070 lines...] org.apache.kafka.streams.kstream.internals.KStreamImplTest >

[jira] [Assigned] (KAFKA-3777) Extract the existing LRU cache out of RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-3777: --- Assignee: Eno Thereska > Extract the existing LRU cache out of RocksDBStore >

[jira] [Created] (KAFKA-4069) Forward records in context of cache flushing/eviction

Eno Thereska created KAFKA-4069: --- Summary: Forward records in context of cache flushing/eviction Key: KAFKA-4069 URL: https://issues.apache.org/jira/browse/KAFKA-4069 Project: Kafka Issue

[jira] [Assigned] (KAFKA-3780) Add new config cache.max.bytes.buffering to the streams configuration

[ https://issues.apache.org/jira/browse/KAFKA-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-3780: --- Assignee: Eno Thereska > Add new config cache.max.bytes.buffering to the streams

[jira] [Work started] (KAFKA-3974) LRU cache should store bytes/object and not records

[ https://issues.apache.org/jira/browse/KAFKA-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3974 started by Eno Thereska. --- > LRU cache should store bytes/object and not records >