[jira] [Issue Comment Deleted] (KAFKA-7114) Kafka Not sending few partitions messages to consumers

2018-08-03 Thread Matt Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated KAFKA-7114: - Comment: was deleted (was: [~soundari] you can open the debug log of consumer client, then you can see

[jira] [Commented] (KAFKA-7114) Kafka Not sending few partitions messages to consumers

2018-08-03 Thread Matt Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16569066#comment-16569066 ] Matt Wang commented on KAFKA-7114: -- [~soundari] you can open the debug log of consumer client, then you

[jira] [Commented] (KAFKA-7114) Kafka Not sending few partitions messages to consumers

2018-08-03 Thread Matt Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16569065#comment-16569065 ] Matt Wang commented on KAFKA-7114: -- [~soundari] you can open the debug log of consumer client, then you

[jira] [Resolved] (KAFKA-6662) Consumer use offsetsForTimes() get offset return None.

2018-08-03 Thread Matt Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang resolved KAFKA-6662. -- Resolution: Not A Problem > Consumer use offsetsForTimes() get offset return None. >

[jira] [Updated] (KAFKA-7238) Producer can't update Metadata when two brokers break down and restart the first one

2018-08-03 Thread little brother ma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] little brother ma updated KAFKA-7238: - External issue URL: https://issues.apache.org/jira/browse/KAFKA-1843 > Producer can't

[jira] [Commented] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully

2018-08-03 Thread little brother ma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16569030#comment-16569030 ] little brother ma commented on KAFKA-1843: -- I am still facing this issue in version 0.11.0.1 

[jira] [Created] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2018-08-03 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-7245: -- Summary: Deprecate WindowStore#put(key, value) Key: KAFKA-7245 URL: https://issues.apache.org/jira/browse/KAFKA-7245 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

2018-08-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568970#comment-16568970 ] Guozhang Wang commented on KAFKA-7158: -- Hi [~cah6] I've tried your code on my laptop for 10+ times

[jira] [Commented] (KAFKA-7233) InMemoryKeyValueStore is not thread-safe for Interactive Queries

2018-08-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568958#comment-16568958 ] Matthias J. Sax commented on KAFKA-7233: [~hashan] No problem. I am just glad that there is no

[jira] [Updated] (KAFKA-1175) Hierarchical Topics

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1175: -- Component/s: core > Hierarchical Topics > --- > > Key: KAFKA-1175 >

[jira] [Updated] (KAFKA-1450) check invalid leader in a more robust way

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1450: -- Component/s: core > check invalid leader in a more robust way >

[jira] [Updated] (KAFKA-1206) allow Kafka to start from a resource negotiator system

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1206: -- Component/s: packaging > allow Kafka to start from a resource negotiator system >

[jira] [Updated] (KAFKA-2079) Support exhibitor

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2079: -- Component/s: zkclient packaging > Support exhibitor > - > >

[jira] [Updated] (KAFKA-1754) KOYA - Kafka on YARN

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1754: -- Component/s: packaging > KOYA - Kafka on YARN > > > Key:

[jira] [Updated] (KAFKA-1207) Launch Kafka from within Apache Mesos

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1207: -- Component/s: packaging > Launch Kafka from within Apache Mesos > -

[jira] [Updated] (KAFKA-10) Kafka deployment on EC2 should be WHIRR based, instead of current contrib/deploy code based solution

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-10?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-10: Component/s: packaging > Kafka deployment on EC2 should be WHIRR based, instead of current > contrib/deploy

[jira] [Resolved] (KAFKA-5153) KAFKA Cluster : 0.10.2.0 : Servers Getting disconnected : Service Impacting

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang resolved KAFKA-5153. --- Resolution: Information Provided Fix Version/s: 0.11.0.1 Upgrading fixed the problem based on

[jira] [Updated] (KAFKA-3346) Rename "Mode" to "SslMode"

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3346: -- Component/s: security > Rename "Mode" to "SslMode" > -- > >

[jira] [Updated] (KAFKA-3458) Selector should throw InterruptException when interrupted

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3458: -- Component/s: network > Selector should throw InterruptException when interrupted >

[jira] [Updated] (KAFKA-4610) getting error:Batch containing 3 record(s) expired due to timeout while requesting metadata from brokers for test2R2P2-1

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4610: -- Component/s: producer > getting error:Batch containing 3 record(s) expired due to timeout while >

[jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5092: -- Component/s: producer > KIP 141 - ProducerRecord Interface Improvements >

[jira] [Updated] (KAFKA-4385) producer is sending too many unnecessary meta data request if the meta data for a topic is not available and "auto.create.topics.enable" =false

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4385: -- Component/s: producer > producer is sending too many unnecessary meta data request if the meta data

[jira] [Updated] (KAFKA-4487) Tests should be run in Jenkins with INFO or DEBUG level

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4487: -- Component/s: unit tests > Tests should be run in Jenkins with INFO or DEBUG level >

[jira] [Updated] (KAFKA-4915) Don't include "error" in log messages at non-error levels

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4915: -- Component/s: logging > Don't include "error" in log messages at non-error levels >

[jira] [Updated] (KAFKA-5071) 2017-04-11 18:18:45.574 ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-128] Failed to commit StreamTask 0_304 state: org.apache.kafka.streams.erro

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5071: -- Component/s: streams > 2017-04-11 18:18:45.574 ERROR StreamThread:783 StreamThread-128 - >

[jira] [Updated] (KAFKA-5306) Official init.d scripts

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5306: -- Component/s: packaging > Official init.d scripts > --- > > Key:

[jira] [Updated] (KAFKA-5480) Partition Leader may not be elected although there is one live replica in ISR

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5480: -- Component/s: replication > Partition Leader may not be elected although there is one live replica in

[jira] [Updated] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7110: -- Component/s: streams > Windowed changelog keys not deserialized properly by TimeWindowedSerde >

[jira] [Updated] (KAFKA-3296) All consumer reads hang indefinately

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3296: -- Component/s: consumer > All consumer reads hang indefinately > >

[jira] [Updated] (KAFKA-4418) Broker Leadership Election Fails If Missing ZK Path Raises Exception

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4418: -- Component/s: zkclient > Broker Leadership Election Fails If Missing ZK Path Raises Exception >

[jira] [Updated] (KAFKA-4414) Unexpected "Halting because log truncation is not allowed"

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4414: -- Component/s: replication > Unexpected "Halting because log truncation is not allowed" >

[jira] [Updated] (KAFKA-3493) Replica fetcher load is not balanced over fetcher threads

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3493: -- Component/s: replication > Replica fetcher load is not balanced over fetcher threads >

[jira] [Updated] (KAFKA-4666) Failure test for Kafka configured for consistency vs availability

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4666: -- Component/s: documentation > Failure test for Kafka configured for consistency vs availability >

[jira] [Updated] (KAFKA-4493) Connections to Kafka brokers should be validated

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4493: -- Component/s: clients > Connections to Kafka brokers should be validated >

[jira] [Updated] (KAFKA-5813) Unexpected unclean leader election due to leader/controller's unusual event handling order

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5813: -- Component/s: zkclient replication > Unexpected unclean leader election due to

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

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568763#comment-16568763 ] ASF GitHub Bot commented on KAFKA-3514: --- guozhangwang opened a new pull request #5458: [NOT MERGE]

[jira] [Updated] (KAFKA-4040) Round Robin Assignment does not create balanced assignments

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4040: -- Component/s: replication > Round Robin Assignment does not create balanced assignments >

[jira] [Updated] (KAFKA-3630) Consider auto closing outdated pull requests

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3630: -- Component/s: build > Consider auto closing outdated pull requests >

[jira] [Updated] (KAFKA-3877) Gradle compiler daemon exits with non-zero exit code while running LogOffsetTest

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3877: -- Component/s: unit tests > Gradle compiler daemon exits with non-zero exit code while running >

[jira] [Updated] (KAFKA-4519) Delete old unused branches in git repo

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4519: -- Component/s: build > Delete old unused branches in git repo > -- >

[jira] [Updated] (KAFKA-4987) Topic creation allows invalid config values on running brokers

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4987: -- Component/s: config > Topic creation allows invalid config values on running brokers >

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

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4629: -- Component/s: metrics > Per topic MBeans leak > - > > Key:

[jira] [Updated] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-5802: -- Component/s: security > ScramServerCallbackHandler#handle should check username not being null before

[jira] [Updated] (KAFKA-6619) InstanceAlreadyExistsException while Tomcat starting up

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6619: -- Component/s: packaging > InstanceAlreadyExistsException while Tomcat starting up >

[jira] [Updated] (KAFKA-6798) Kafka leader rebalance failures

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-6798: -- Component/s: replication > Kafka leader rebalance failures > --- > >

[jira] [Updated] (KAFKA-661) Prevent a shutting down broker from re-entering the ISR

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-661: - Component/s: replication > Prevent a shutting down broker from re-entering the ISR >

[jira] [Updated] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2939: -- Component/s: config > Make AbstractConfig.logUnused() tunable for clients >

[jira] [Commented] (KAFKA-764) Race Condition in Broker Registration after ZooKeeper disconnect

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568727#comment-16568727 ] Ray Chiang commented on KAFKA-764: -- This is for a very old version of Kafka. If I don't see any update

[jira] [Updated] (KAFKA-764) Race Condition in Broker Registration after ZooKeeper disconnect

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-764: - Component/s: zkclient > Race Condition in Broker Registration after ZooKeeper disconnect >

[jira] [Commented] (KAFKA-7244) Add note about memory map kernel limits to documentation

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568722#comment-16568722 ] ASF GitHub Bot commented on KAFKA-7244: --- TolerableCoder opened a new pull request #158: KAFKA-7244:

[jira] [Created] (KAFKA-7244) Add note about memory map kernel limits to documentation

2018-08-03 Thread Ray Chiang (JIRA)
Ray Chiang created KAFKA-7244: - Summary: Add note about memory map kernel limits to documentation Key: KAFKA-7244 URL: https://issues.apache.org/jira/browse/KAFKA-7244 Project: Kafka Issue Type:

[jira] [Reopened] (KAFKA-4479) Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordinator

2018-08-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-4479: The code still passes Time.SYSTEM: {code} /* start group coordinator */ // Hardcode

[jira] [Assigned] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7240: -- Assignee: Sam Lendle (was: John Roesler) > -total metrics in Streams are incorrect >

[jira] [Commented] (KAFKA-4479) Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordinator

2018-08-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568572#comment-16568572 ] Guozhang Wang commented on KAFKA-4479: -- My understanding is that, the previous flakiness of

[jira] [Commented] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-03 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568560#comment-16568560 ] John Roesler commented on KAFKA-7240: - [~slendle] For some reason, I can't assign this ticket to

[jira] [Created] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

2018-08-03 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-7243: Summary: Add unit integration tests to validate metrics in Kafka Streams Key: KAFKA-7243 URL: https://issues.apache.org/jira/browse/KAFKA-7243 Project: Kafka

[jira] [Commented] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-03 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568557#comment-16568557 ] John Roesler commented on KAFKA-7240: - Oh, by all means, go ahead! I'll assign it to you.   If you

[jira] [Updated] (KAFKA-4238) consumer-subscription not working, when accessing a newly created topic immediately after its creation with the AdminUtils

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4238: -- Component/s: consumer admin > consumer-subscription not working, when accessing a

[jira] [Updated] (KAFKA-4294) Allow password file in server.properties to separate 'secrets' from standard configs

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-4294: -- Component/s: security config > Allow password file in server.properties to separate

[jira] [Updated] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3410: -- Component/s: replication > Unclean leader election and "Halting because log truncation is not allowed"

[jira] [Updated] (KAFKA-3962) ConfigDef support for resource-specific configuration

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3962: -- Component/s: config > ConfigDef support for resource-specific configuration >

[jira] [Updated] (KAFKA-3861) Shrunk ISR before leader crash makes the partition unavailable

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3861: -- Component/s: replication > Shrunk ISR before leader crash makes the partition unavailable >

[jira] [Updated] (KAFKA-3329) Validation script to test expected behavior of Authorizer implementations

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3329: -- Component/s: tools > Validation script to test expected behavior of Authorizer implementations >

[jira] [Updated] (KAFKA-3790) Default options when removing ACLs do not comply with documentation

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3790: -- Component/s: documentation > Default options when removing ACLs do not comply with documentation >

[jira] [Updated] (KAFKA-3790) Default options when removing ACLs do not comply with documentation

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3790: -- Component/s: security > Default options when removing ACLs do not comply with documentation >

[jira] [Updated] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3980: -- Component/s: metrics > JmxReporter uses excessive memory causing OutOfMemoryException >

[jira] [Resolved] (KAFKA-3577) Partial cluster breakdown

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang resolved KAFKA-3577. --- Resolution: Duplicate > Partial cluster breakdown > - > >

[jira] [Updated] (KAFKA-3494) mbeans overwritten with identical clients on a single jvm

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3494: -- Component/s: metrics > mbeans overwritten with identical clients on a single jvm >

[jira] [Updated] (KAFKA-3420) Transient failure in OffsetCommitTest.testNonExistingTopicOffsetCommit

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3420: -- Component/s: unit tests > Transient failure in OffsetCommitTest.testNonExistingTopicOffsetCommit >

[jira] [Updated] (KAFKA-3241) JmxReporter produces invalid JSON when a value is Infinity

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-3241: -- Component/s: metrics > JmxReporter produces invalid JSON when a value is Infinity >

[jira] [Resolved] (KAFKA-3094) Kafka process 100% CPU when no message in topic

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang resolved KAFKA-3094. --- Resolution: Cannot Reproduce > Kafka process 100% CPU when no message in topic >

[jira] [Updated] (KAFKA-7239) Kafka Connect secret externalization not working

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7239: -- Component/s: KafkaConnect > Kafka Connect secret externalization not working >

[jira] [Updated] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1736: -- Component/s: replication > Improve parition-broker assignment strategy for better availaility in >

[jira] [Commented] (KAFKA-4479) Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordinator

2018-08-03 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568537#comment-16568537 ] Ismael Juma commented on KAFKA-4479: I don't understand why we closed this. > Streams tests should

[jira] [Updated] (KAFKA-2471) Replicas Order and Leader out of sync

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2471: -- Component/s: replication > Replicas Order and Leader out of sync >

[jira] [Updated] (KAFKA-2127) Running TopicCommand --alter causes connection close/reset errors in kafka logs

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2127: -- Component/s: tools > Running TopicCommand --alter causes connection close/reset errors in kafka >

[jira] [Updated] (KAFKA-1543) Changing replication factor

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1543: -- Component/s: replication > Changing replication factor > --- > >

[jira] [Updated] (KAFKA-1543) Changing replication factor

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1543: -- Component/s: tools > Changing replication factor > --- > >

[jira] [Updated] (KAFKA-1665) controller state gets stuck in message after execute

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1665: -- Component/s: controller > controller state gets stuck in message after execute >

[jira] [Updated] (KAFKA-1712) Excessive storage usage on newly added node

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1712: -- Component/s: log > Excessive storage usage on newly added node >

[jira] [Updated] (KAFKA-1967) Support more flexible serialization in Log4jAppender

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-1967: -- Component/s: logging > Support more flexible serialization in Log4jAppender >

[jira] [Updated] (KAFKA-2575) inconsistant offset count in replication-offset-checkpoint during lead election leads to huge exceptions

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2575: -- Component/s: (was: offset manager) replication > inconsistant offset count in

[jira] [Updated] (KAFKA-2178) Loss of highwatermarks on incorrect cluster shutdown/restart

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2178: -- Component/s: replication > Loss of highwatermarks on incorrect cluster shutdown/restart >

[jira] [Updated] (KAFKA-6648) Fetcher.getTopicMetadata() should return all partitions for each requested topic

2018-08-03 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6648: Fix Version/s: 2.0.1 > Fetcher.getTopicMetadata() should return all partitions for each requested > topic

[jira] [Updated] (KAFKA-2575) inconsistant offset count in replication-offset-checkpoint during lead election leads to huge exceptions

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2575: -- Component/s: offset manager > inconsistant offset count in replication-offset-checkpoint during lead

[jira] [Updated] (KAFKA-2717) Add kafka logbak appender

2018-08-03 Thread Ray Chiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2717: -- Component/s: logging > Add kafka logbak appender > - > > Key:

[jira] [Commented] (KAFKA-6648) Fetcher.getTopicMetadata() should return all partitions for each requested topic

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568531#comment-16568531 ] ASF GitHub Bot commented on KAFKA-6648: --- lindong28 closed pull request #4679: KAFKA-6648 -

[jira] [Updated] (KAFKA-6648) Fetcher.getTopicMetadata() should return all partitions for each requested topic

2018-08-03 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6648: Summary: Fetcher.getTopicMetadata() should return all partitions for each requested topic (was:

[jira] [Resolved] (KAFKA-4479) Streams tests should pass without hardcoded Time.SYSTEM in GroupCoordinator

2018-08-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4479. -- Resolution: Won't Fix > Streams tests should pass without hardcoded Time.SYSTEM in

[jira] [Commented] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-03 Thread Sam Lendle (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568457#comment-16568457 ] Sam Lendle commented on KAFKA-7240: --- [~vvcephei] I'd like to work on it if I can avoid a KIP :) I'll

[jira] [Assigned] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7240: -- Assignee: John Roesler > -total metrics in Streams are incorrect >

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-08-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 8/3/18 4:15 PM: --- +1 from me . was (Author:

[jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

2018-08-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 8/3/18 4:14 PM: --- Thanks for taking this

[jira] [Commented] (KAFKA-7094) Variate should unify code style in one method, and use camel name

2018-08-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568420#comment-16568420 ] ASF GitHub Bot commented on KAFKA-7094: --- wangzzu closed pull request #5287: KAFKA-7094: Variate

[jira] [Comment Edited] (KAFKA-6678) Upgrade dependencies with later release versions

2018-08-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434768#comment-16434768 ] Ted Yu edited comment on KAFKA-6678 at 8/3/18 3:58 PM: --- 2.0 release would drop

[jira] [Commented] (KAFKA-7240) -total metrics in Streams are incorrect

2018-08-03 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568382#comment-16568382 ] John Roesler commented on KAFKA-7240: - Thanks for the report [~slendle]. That does indeed sound like

[jira] [Created] (KAFKA-7242) Externalized secrets are revealed in task configuration

2018-08-03 Thread Bahdan Siamionau (JIRA)
Bahdan Siamionau created KAFKA-7242: --- Summary: Externalized secrets are revealed in task configuration Key: KAFKA-7242 URL: https://issues.apache.org/jira/browse/KAFKA-7242 Project: Kafka

[jira] [Updated] (KAFKA-7241) Reassignment partitiona to non existent broker

2018-08-03 Thread Igor Martemyanov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Martemyanov updated KAFKA-7241: Description: There is the trouble with starting reassignment partitions process to non

[jira] [Created] (KAFKA-7241) Reassignment partitiona to non existent broker

2018-08-03 Thread Igor Martemyanov (JIRA)
Igor Martemyanov created KAFKA-7241: --- Summary: Reassignment partitiona to non existent broker Key: KAFKA-7241 URL: https://issues.apache.org/jira/browse/KAFKA-7241 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-7238) Producer can't update Metadata when two brokers break down and restart the first one

2018-08-03 Thread little brother ma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567988#comment-16567988 ] little brother ma edited comment on KAFKA-7238 at 8/3/18 9:14 AM: -- {{I

  1   2   >