[jira] [Commented] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

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

[GitHub] kafka pull request #2381: KAFKA-3502: move RocksDB options construction to i...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/2381 KAFKA-3502: move RocksDB options construction to init() In RocksDBStore, options / wOptions / fOptions are constructed in the constructor, which needs to be dismissed in the close() call; howev

[jira] [Commented] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823029#comment-15823029 ] huxi commented on KAFKA-4629: - I tried in my kafka0.10.0.1 single-broker test environment with

[jira] [Work started] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3502 started by Guozhang Wang. > Build is killed during kafka streams tests due to `pure virtual method > calle

[GitHub] kafka pull request #2380: MINOR: replace remove() with delete() after 5.0.1 ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/2380 MINOR: replace remove() with delete() after 5.0.1 RocksDB upgrade You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KMino

[jira] [Resolved] (KAFKA-3901) KStreamTransformValues$KStreamTransformValuesProcessor#process() forwards null values

[ https://issues.apache.org/jira/browse/KAFKA-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3901. -- Resolution: Won't Fix > KStreamTransformValues$KStreamTransformValuesProcessor#process() forward

[jira] [Updated] (KAFKA-3515) Migrate org.apache.kafka.connect.json.JsonSerializer / Deser to common package

[ https://issues.apache.org/jira/browse/KAFKA-3515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3515: - Labels: needs-kip (was: ) > Migrate org.apache.kafka.connect.json.JsonSerializer / Deser to commo

[jira] [Created] (KAFKA-4634) Issue of one kafka brokers not listed in zookeeper

Maharajan Shunmuga Sundaram created KAFKA-4634: -- Summary: Issue of one kafka brokers not listed in zookeeper Key: KAFKA-4634 URL: https://issues.apache.org/jira/browse/KAFKA-4634 Project:

[jira] [Commented] (KAFKA-4633) Always use regex pattern subscription to avoid auto create topics

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

[GitHub] kafka pull request #2379: KAFKA-4633: Always using regex pattern subscriptio...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/2379 KAFKA-4633: Always using regex pattern subscription in StreamThread 1. In StreamThread, always use subscribe(Pattern, ..) function in order to avoid sending MetadataRequest with specific topic

[jira] [Comment Edited] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822837#comment-15822837 ] Guozhang Wang edited comment on KAFKA-4125 at 1/14/17 3:38 PM: -

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822837#comment-15822837 ] Guozhang Wang commented on KAFKA-4125: -- Thanks for bringing this up [~mjsax]. I do ag

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822833#comment-15822833 ] Bill Bejeck commented on KAFKA-4125: [~mjsax] - Sounds reasonable to me. With the i