[jira] [Updated] (KAFKA-4863) Querying window store may return unwanted keys

[ https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4863: - Fix Version/s: 0.10.2.1 > Querying window store may return unwanted keys >

[jira] [Updated] (KAFKA-4863) Querying window store may return unwanted keys

[ https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4863: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch

[jira] [Resolved] (KAFKA-4848) Stream thread getting into deadlock state while trying to get rocksdb lock in retryWithBackoff

[ https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4848. -- Resolution: Fixed Fix Version/s: 0.11.0.0 > Stream thread getting into deadlock state

[jira] [Updated] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4750: - Labels: newbie (was: ) > KeyValueIterator returns null values >

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930823#comment-15930823 ] Guozhang Wang commented on KAFKA-4890: -- Thanks [~yunolgun] that is super useful, will circle back

[jira] [Commented] (KAFKA-4887) Enabling caching on a persistent window store breaks support for duplicate insertion

[ https://issues.apache.org/jira/browse/KAFKA-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15930727#comment-15930727 ] Guozhang Wang commented on KAFKA-4887: -- Got it. Thanks. As for the fix, we should probably consider

[jira] [Resolved] (KAFKA-4607) Kafka Streams allows you to provide strings with illegal characters for internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4607. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2331

[jira] [Resolved] (KAFKA-4859) Transient test failure: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion (again)

[ https://issues.apache.org/jira/browse/KAFKA-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4859. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2682

[jira] [Resolved] (KAFKA-4885) processstreamwithcachedstatestore and other streams benchmarks fail occasionally

[ https://issues.apache.org/jira/browse/KAFKA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4885. -- Resolution: Fixed Issue resolved by pull request 2693

[jira] [Assigned] (KAFKA-4885) processstreamwithcachedstatestore and other streams benchmarks fail occasionally

[ https://issues.apache.org/jira/browse/KAFKA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4885: Assignee: Guozhang Wang > processstreamwithcachedstatestore and other streams benchmarks

[jira] [Commented] (KAFKA-4885) processstreamwithcachedstatestore and other streams benchmarks fail occasionally

[ https://issues.apache.org/jira/browse/KAFKA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15926571#comment-15926571 ] Guozhang Wang commented on KAFKA-4885: -- [~damianguy] Well, as for the general solution in terms of

[jira] [Commented] (KAFKA-4885) processstreamwithcachedstatestore and other streams benchmarks fail occasionally

[ https://issues.apache.org/jira/browse/KAFKA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925521#comment-15925521 ] Guozhang Wang commented on KAFKA-4885: -- As for the fix, I think it could be quite complicated and

[jira] [Commented] (KAFKA-4885) processstreamwithcachedstatestore and other streams benchmarks fail occasionally

[ https://issues.apache.org/jira/browse/KAFKA-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925516#comment-15925516 ] Guozhang Wang commented on KAFKA-4885: -- Looked into the logs, the root cause is actually because the

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923361#comment-15923361 ] Guozhang Wang commented on KAFKA-4890: -- I have uploaded a small PR to improve the log4j for

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923328#comment-15923328 ] Guozhang Wang commented on KAFKA-4890: -- Since I do not have the code sketch it is hard to reproduce

[jira] [Comment Edited] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923322#comment-15923322 ] Guozhang Wang edited comment on KAFKA-4890 at 3/14/17 12:41 AM:

[jira] [Commented] (KAFKA-4887) Enabling caching on a persistent window store breaks support for duplicate insertion

[ https://issues.apache.org/jira/browse/KAFKA-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922789#comment-15922789 ] Guozhang Wang commented on KAFKA-4887: -- Thanks Elias, this does sound a bug to me. Just curious what

[jira] [Commented] (KAFKA-4859) Transient test failure: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion (again)

[ https://issues.apache.org/jira/browse/KAFKA-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922772#comment-15922772 ] Guozhang Wang commented on KAFKA-4859: -- [~original-brownbear] Thanks a lot for picking this up! Any

[jira] [Resolved] (KAFKA-4657) Improve test coverage of CompositeReadOnlyWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4657. -- Resolution: Fixed Issue resolved by pull request 2672

[jira] [Commented] (KAFKA-4848) Stream thread getting into deadlock state while trying to get rocksdb lock in retryWithBackoff

[ https://issues.apache.org/jira/browse/KAFKA-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922762#comment-15922762 ] Guozhang Wang commented on KAFKA-4848: -- [~sjmittal] BTW I have added you to the contributor list. >

[jira] [Updated] (KAFKA-4769) Add Float serializer, deserializer, serde

[ https://issues.apache.org/jira/browse/KAFKA-4769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4769: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch

[jira] [Updated] (KAFKA-4738) Remove generic type of class ClientState

[ https://issues.apache.org/jira/browse/KAFKA-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4738: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch

[jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4722: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch

[jira] [Assigned] (KAFKA-4863) Querying window store may return unwanted keys

[ https://issues.apache.org/jira/browse/KAFKA-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4863: Assignee: Eno Thereska > Querying window store may return unwanted keys >

[jira] [Resolved] (KAFKA-4851) SessionStore.fetch(key) is a performance bottleneck

[ https://issues.apache.org/jira/browse/KAFKA-4851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4851. -- Resolution: Fixed Fix Version/s: 0.10.2.1 Issue resolved by pull request 2645

[jira] [Commented] (KAFKA-3514) Stream timestamp computation needs some further thoughts

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15897891#comment-15897891 ] Guozhang Wang commented on KAFKA-3514: -- There are some discussions on pros and cons of changing the

[jira] [Resolved] (KAFKA-4828) ProcessorTopologyTestDriver does not work when using .through()

[ https://issues.apache.org/jira/browse/KAFKA-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4828. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2629

[jira] [Commented] (KAFKA-4657) Improve test coverage of CompositeReadOnlyWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15896706#comment-15896706 ] Guozhang Wang commented on KAFKA-4657: -- [~damianguy] Could you update the description? > Improve

[jira] [Resolved] (KAFKA-4826) Fix some findbugs warnings in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4826. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2623

[jira] [Updated] (KAFKA-4639) Kafka Streams metrics are undocumented

[ https://issues.apache.org/jira/browse/KAFKA-4639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4639: - Fix Version/s: 0.10.2.0 > Kafka Streams metrics are undocumented >

[jira] [Updated] (KAFKA-4838) Export buffer cache metrics in JMX

[ https://issues.apache.org/jira/browse/KAFKA-4838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4838: - Fix Version/s: (was: 0.10.2.1) 0.11.0.0 > Export buffer cache metrics in

[jira] [Updated] (KAFKA-4838) Export buffer cache metrics in JMX

[ https://issues.apache.org/jira/browse/KAFKA-4838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4838: - Labels: needs-kip (was: ) > Export buffer cache metrics in JMX >

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15894842#comment-15894842 ] Guozhang Wang commented on KAFKA-4830: -- [~mjuchli] As for this JIRA itself, the goal is to allow

[jira] [Resolved] (KAFKA-4800) Streams State transition ASCII diagrams need fixing and polishing

[ https://issues.apache.org/jira/browse/KAFKA-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4800. -- Resolution: Fixed Fix Version/s: 0.10.2.1 Issue resolved by pull request 2621

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

[ https://issues.apache.org/jira/browse/KAFKA-4652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4652. -- Resolution: Fixed Issue resolved by pull request 2597

[jira] [Updated] (KAFKA-2358) Cluster collection returning methods should never return null

[ https://issues.apache.org/jira/browse/KAFKA-2358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2358: - Fix Version/s: (was: 0.10.3.0) 0.11.0.0 > Cluster collection returning

[jira] [Updated] (KAFKA-2358) Cluster collection returning methods should never return null

[ https://issues.apache.org/jira/browse/KAFKA-2358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2358: - Fix Version/s: 0.10.3.0 > Cluster collection returning methods should never return null >

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

Guozhang Wang created KAFKA-4831: Summary: Extract WindowedSerde to public APIs Key: KAFKA-4831 URL: https://issues.apache.org/jira/browse/KAFKA-4831 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

Guozhang Wang created KAFKA-4830: Summary: Augment KStream.print() to allow users pass in extra parameters in the printed string Key: KAFKA-4830 URL: https://issues.apache.org/jira/browse/KAFKA-4830

[jira] [Commented] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890917#comment-15890917 ] Guozhang Wang commented on KAFKA-4829: -- I'd like to expand the scope of this JIRA a bit to make a

[jira] [Updated] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4829: - Labels: user-experience (was: ) > Improve logging of StreamTask commits >

[jira] [Commented] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics

[ https://issues.apache.org/jira/browse/KAFKA-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888903#comment-15888903 ] Guozhang Wang commented on KAFKA-4789: -- Thanks [~hrafzali] for the patch! I have added you to the

[jira] [Assigned] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics

[ https://issues.apache.org/jira/browse/KAFKA-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4789: Assignee: Hamidreza Afzali > ProcessorTopologyTestDriver does not forward extracted

[jira] [Resolved] (KAFKA-4789) ProcessorTopologyTestDriver does not forward extracted timestamps to internal topics

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

[jira] [Commented] (KAFKA-4778) OOM on kafka-streams instances with high numbers of unreaped Record classes

[ https://issues.apache.org/jira/browse/KAFKA-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886778#comment-15886778 ] Guozhang Wang commented on KAFKA-4778: -- [~peoplemerge] What I was looking for is actually the

[jira] [Resolved] (KAFKA-4744) Streams_bounce test failing occassionally

[ https://issues.apache.org/jira/browse/KAFKA-4744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4744. -- Resolution: Fixed Issue resolved by pull request 2601

[jira] [Commented] (KAFKA-4798) Javadocs for 0.10.2 are missing from kafka.apache.org

[ https://issues.apache.org/jira/browse/KAFKA-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15884000#comment-15884000 ] Guozhang Wang commented on KAFKA-4798: -- Thanks [~ewencp], and I agree we should have a refactoring of

[jira] [Resolved] (KAFKA-4494) Significant startup delays in KStreams app

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

[jira] [Commented] (KAFKA-4778) OOM on kafka-streams instances with high numbers of unreaped Record classes

[ https://issues.apache.org/jira/browse/KAFKA-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15876590#comment-15876590 ] Guozhang Wang commented on KAFKA-4778: -- [~da...@yahoo.com] What are your configuration values in your

[jira] [Resolved] (KAFKA-4752) Streams Simple Benchmark MB/sec calculation is not correct for Join operations

[ https://issues.apache.org/jira/browse/KAFKA-4752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4752. -- Resolution: Fixed Issue resolved by pull request 2551

[jira] [Updated] (KAFKA-4317) RocksDB checkpoint files lost on kill -9

[ https://issues.apache.org/jira/browse/KAFKA-4317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4317: - Resolution: Fixed Fix Version/s: 0.10.3.0 Status: Resolved (was: Patch

[jira] [Updated] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage

[ https://issues.apache.org/jira/browse/KAFKA-4484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4484: - Resolution: Fixed Fix Version/s: 0.10.3.0 Status: Resolved (was: Patch

[jira] [Resolved] (KAFKA-4709) Error message from Struct.validate() should include the name of the offending field.

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

[jira] [Commented] (KAFKA-4720) Add KStream.peek(ForeachAction<K,V>)

[ https://issues.apache.org/jira/browse/KAFKA-4720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869239#comment-15869239 ] Guozhang Wang commented on KAFKA-4720: -- [~stevenschlansker] I have added you to contributor list, you

[jira] [Assigned] (KAFKA-4720) Add KStream.peek(ForeachAction<K,V>)

[ https://issues.apache.org/jira/browse/KAFKA-4720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4720: Assignee: Steven Schlansker > Add KStream.peek(ForeachAction) >

[jira] [Resolved] (KAFKA-4720) Add KStream.peek(ForeachAction<K,V>)

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

[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=15862912#comment-15862912 ] Guozhang Wang commented on KAFKA-4732: -- New instances of this failure:

[jira] [Updated] (KAFKA-4654) Improve test coverage MemoryLRUCache

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

[jira] [Updated] (KAFKA-4716) Fix logic for re-checking if internal topic is ready

[ https://issues.apache.org/jira/browse/KAFKA-4716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4716: - Resolution: Fixed Fix Version/s: 0.10.3.0 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-4738) Remove generic type of class ClientState

[ https://issues.apache.org/jira/browse/KAFKA-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15858581#comment-15858581 ] Guozhang Wang commented on KAFKA-4738: -- I'd suggest we only remove Generic T in this JIRA, as for

[jira] [Resolved] (KAFKA-4702) Parametrize streams benchmarks to run at scale

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

[jira] [Updated] (KAFKA-4716) Fix logic for re-checking if internal topic is ready

[ https://issues.apache.org/jira/browse/KAFKA-4716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4716: - Labels: architecture (was: ) > Fix logic for re-checking if internal topic is ready >

[jira] [Commented] (KAFKA-4716) Fix logic for re-checking if internal topic is ready

[ https://issues.apache.org/jira/browse/KAFKA-4716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15858439#comment-15858439 ] Guozhang Wang commented on KAFKA-4716: -- Coming from this commit:

[jira] [Updated] (KAFKA-4648) Improve test coverage StreamTask

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

[jira] [Resolved] (KAFKA-4733) Improve Streams Reset Tool console output

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

[jira] [Commented] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

[ https://issues.apache.org/jira/browse/KAFKA-4461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15854609#comment-15854609 ] Guozhang Wang commented on KAFKA-4461: -- [~amccague] Thanks for the patch! I have added you to the

[jira] [Resolved] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

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

[jira] [Assigned] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

[ https://issues.apache.org/jira/browse/KAFKA-4461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4461: Assignee: Adrian McCague > When using ProcessorTopologyTestDriver, the combination of map

[jira] [Resolved] (KAFKA-4724) Clean up of state directories can possibly remove stores that are about to be used by another thread

[ https://issues.apache.org/jira/browse/KAFKA-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4724. -- Resolution: Fixed Issue resolved by pull request 2486

[jira] [Updated] (KAFKA-4646) Improve test coverage AbstractProcessorContext

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

[jira] [Updated] (KAFKA-4649) Improve test coverage GlobalStateManagerImpl

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

[jira] [Updated] (KAFKA-4662) Improve test coverage TopologyBuilder

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

[jira] [Commented] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex

[ https://issues.apache.org/jira/browse/KAFKA-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15851097#comment-15851097 ] Guozhang Wang commented on KAFKA-4614: -- [~kawamuray] Thanks for sharing!! > Long GC pause harming

[jira] [Commented] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850282#comment-15850282 ] Guozhang Wang commented on KAFKA-4722: -- One side note is that we have seen some scenarios where

[jira] [Updated] (KAFKA-4645) Improve test coverage of ProcessorTopology

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

[jira] [Updated] (KAFKA-4647) Improve test coverage of GlobalStreamThread

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

[jira] [Updated] (KAFKA-4642) Improve test coverage of ProcessorStateManager

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

[jira] [Updated] (KAFKA-4677) Avoid unnecessary task movement across threads during rebalance

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

[jira] (KAFKA-2955) Add Prompt to kafka-console-producer

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

[jira] [Updated] (KAFKA-4644) Improve test coverage of StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4644: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

[jira] [Updated] (KAFKA-4700) StreamsKafkaClient drops security configs

[ https://issues.apache.org/jira/browse/KAFKA-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4700: - Resolution: Fixed Fix Version/s: 0.10.3.0 Status: Resolved (was: Patch

[jira] [Resolved] (KAFKA-4684) Kafka does not offer kafka-configs.bat on Windows box

[ https://issues.apache.org/jira/browse/KAFKA-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4684. -- Resolution: Fixed Fix Version/s: 0.10.2.0 0.10.3.0 Issue resolved by

[jira] [Updated] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

[ https://issues.apache.org/jira/browse/KAFKA-4461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4461: - Priority: Major (was: Blocker) > When using ProcessorTopologyTestDriver, the combination of map

[jira] [Updated] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

[ https://issues.apache.org/jira/browse/KAFKA-4461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4461: - Labels: newbie unit-test (was: newbie) > When using ProcessorTopologyTestDriver, the combination

[jira] [Updated] (KAFKA-4408) KTable doesn't work with ProcessorTopologyTestDriver in Kafka 0.10.1.0

[ https://issues.apache.org/jira/browse/KAFKA-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4408: - Labels: newbie unit-test (was: ) > KTable doesn't work with ProcessorTopologyTestDriver in Kafka

[jira] [Updated] (KAFKA-4613) Treat null-key records the same way for joins and aggreations

[ https://issues.apache.org/jira/browse/KAFKA-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4613: - Description: Currently, on aggregation records with null-key get dropped while for joins we

[jira] [Resolved] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector

[ https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3835. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request 2417

[jira] [Resolved] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations

[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3896. -- Resolution: Fixed Fix Version/s: (was: 0.10.1.0) 0.10.2.0

[jira] [Commented] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector

[ https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833786#comment-15833786 ] Guozhang Wang commented on KAFKA-3835: -- [~ankushpuri] Sorry for the late reply as I was not pinged

[jira] [Updated] (KAFKA-1850) Failed reassignment leads to additional replica

[ https://issues.apache.org/jira/browse/KAFKA-1850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1850: - Assignee: (was: Neha Narkhede) > Failed reassignment leads to additional replica >

[jira] [Commented] (KAFKA-2363) ProducerSendTest.testCloseWithZeroTimeoutFromCallerThread Transient Failure

[ https://issues.apache.org/jira/browse/KAFKA-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833785#comment-15833785 ] Guozhang Wang commented on KAFKA-2363: -- I have not seen this failure recently, how about you

[jira] [Updated] (KAFKA-1676) Ability to cancel replica reassignment in progress

[ https://issues.apache.org/jira/browse/KAFKA-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1676: - Assignee: (was: Neha Narkhede) > Ability to cancel replica reassignment in progress >

[jira] [Updated] (KAFKA-3124) Update protocol wiki page to reflect latest request/response formats

[ https://issues.apache.org/jira/browse/KAFKA-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3124: - Assignee: (was: Liquan Pei) > Update protocol wiki page to reflect latest request/response

[jira] [Updated] (KAFKA-1354) Failed to load class "org.slf4j.impl.StaticLoggerBinder"

[ https://issues.apache.org/jira/browse/KAFKA-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1354: - Assignee: (was: Jay Kreps) > Failed to load class "org.slf4j.impl.StaticLoggerBinder" >

[jira] [Commented] (KAFKA-3124) Update protocol wiki page to reflect latest request/response formats

[ https://issues.apache.org/jira/browse/KAFKA-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833783#comment-15833783 ] Guozhang Wang commented on KAFKA-3124: -- [~liquanpei] I'm un-assigning you from this task for now,

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833762#comment-15833762 ] Guozhang Wang commented on KAFKA-4113: -- Hello [~mitch-seymour], sorry for the late reply. In a recent

[jira] [Updated] (KAFKA-4672) KIP-100 api changes break Java 8 lambda expressions in some cases

[ https://issues.apache.org/jira/browse/KAFKA-4672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4672: - Resolution: Fixed Fix Version/s: 0.10.3.0 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-4675) Subsequent CreateTopic command could be lost after a DeleteTopic command

[ https://issues.apache.org/jira/browse/KAFKA-4675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15832248#comment-15832248 ] Guozhang Wang commented on KAFKA-4675: -- Actually no, I did not see the exception from broker side. >

[jira] [Created] (KAFKA-4675) Subsequent CreateTopic command could be lost after a DeleteTopic command

Guozhang Wang created KAFKA-4675: Summary: Subsequent CreateTopic command could be lost after a DeleteTopic command Key: KAFKA-4675 URL: https://issues.apache.org/jira/browse/KAFKA-4675 Project:

[jira] [Comment Edited] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations

[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831285#comment-15831285 ] Guozhang Wang edited comment on KAFKA-3896 at 1/20/17 6:37 AM: --- The root

<    4   5   6   7   8   9   10   11   12   13   >