[jira] [Assigned] (KAFKA-3532) add principal.builder.class that can extract user from a field

[ https://issues.apache.org/jira/browse/KAFKA-3532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned KAFKA-3532: - Assignee: Kaufman Ng (was: Sriharsha Chintalapani) > add

[jira] [Commented] (KAFKA-3532) add principal.builder.class that can extract user from a field

[ https://issues.apache.org/jira/browse/KAFKA-3532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153085#comment-16153085 ] Sriharsha Chintalapani commented on KAFKA-3532: --- [~kaufman] Sorry didn't see you earlier

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153081#comment-16153081 ] Matthias J. Sax commented on KAFKA-4327: [~jeqo] We cannot have a dependency to core module. Thus,

[jira] [Commented] (KAFKA-3532) add principal.builder.class that can extract user from a field

[ https://issues.apache.org/jira/browse/KAFKA-3532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153077#comment-16153077 ] Kaufman Ng commented on KAFKA-3532: --- [~danipl] since [~sriharsha] hasn't responded so far and I have

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153069#comment-16153069 ] Richard Yu commented on KAFKA-5696: --- [~olkuznsmith] bq. I see this in logs. Could you tells us what

[jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153047#comment-16153047 ] Richard Yu edited comment on KAFKA-5696 at 9/5/17 2:24 AM: --- There is the

[jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153047#comment-16153047 ] Richard Yu edited comment on KAFKA-5696 at 9/5/17 2:24 AM: --- There is the

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153047#comment-16153047 ] Richard Yu commented on KAFKA-5696: --- There is the reconfigure method that was originally defined in the

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153032#comment-16153032 ] Richard Yu commented on KAFKA-5696: --- I was mistaken on this issue, I did not realize that configs still

[jira] [Commented] (KAFKA-5823) Update Docs

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

[jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5829: Priority: Critical (was: Major) > Speedup broker startup after unclean shutdown by reducing unnecessary >

[jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5829: Fix Version/s: 1.0.0 > Speedup broker startup after unclean shutdown by reducing unnecessary > snapshot

[jira] [Comment Edited] (KAFKA-3532) add principal.builder.class that can extract user from a field

[ https://issues.apache.org/jira/browse/KAFKA-3532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152822#comment-16152822 ] Daniel Pardo Ligorred edited comment on KAFKA-3532 at 9/4/17 6:09 PM: --

[jira] [Commented] (KAFKA-3532) add principal.builder.class that can extract user from a field

[ https://issues.apache.org/jira/browse/KAFKA-3532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152822#comment-16152822 ] Daniel Pardo Ligorred commented on KAFKA-3532: -- [~sriharsha] if you are agre I can grab this

[jira] [Commented] (KAFKA-5830) kafka-configs.sh should allow deletion of all configs for an entity

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

[jira] [Commented] (KAFKA-5832) Add Consumed class and overloads to StreamBuilder

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

[jira] [Created] (KAFKA-5832) Add Consumed class and overloads to StreamBuilder

Damian Guy created KAFKA-5832: - Summary: Add Consumed class and overloads to StreamBuilder Key: KAFKA-5832 URL: https://issues.apache.org/jira/browse/KAFKA-5832 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5818) KafkaStreams state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5818: --- Fix Version/s: 1.0.0 > KafkaStreams state transitions not correct >

[jira] [Updated] (KAFKA-5808) The Preferred Replica should be global and dynamic

[ https://issues.apache.org/jira/browse/KAFKA-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5808: --- Fix Version/s: (was: 0.11.0.0) > The Preferred Replica should be global and dynamic >

[jira] [Updated] (KAFKA-5790) SocketServer.processNewResponses should not skip a response if exception is thrown

[ https://issues.apache.org/jira/browse/KAFKA-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5790: --- Fix Version/s: (was: 0.11.0.1) > SocketServer.processNewResponses should not skip a response if

[jira] [Assigned] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5515: - Assignee: Damian Guy (was: Neil Avery) > Consider removing date formatting from Segments class

[jira] [Commented] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory

[ https://issues.apache.org/jira/browse/KAFKA-5814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152545#comment-16152545 ] Ismael Juma commented on KAFKA-5814: If you agree that KAFKA-5470 solves the issue, we should close

[jira] [Assigned] (KAFKA-3704) Improve mechanism for compression stream block size selection in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3704: -- Assignee: (was: Ismael Juma) > Improve mechanism for compression stream block size

[jira] [Resolved] (KAFKA-5831) MemoryRecordsBuilder uses small compression buffer leading to snappy low compression ratio

[ https://issues.apache.org/jira/browse/KAFKA-5831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5831. Resolution: Duplicate Thanks for filing the report. This is a duplicate of KAFKA-5236. >

[jira] [Commented] (KAFKA-5831) MemoryRecordsBuilder uses small compression buffer leading to snappy low compression ratio

[ https://issues.apache.org/jira/browse/KAFKA-5831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152512#comment-16152512 ] fengchaoli commented on KAFKA-5831: --- Why using small snappy compression buffer in kafka-client module

[jira] [Commented] (KAFKA-5831) MemoryRecordsBuilder uses small compression buffer leading to snappy low compression ratio

[ https://issues.apache.org/jira/browse/KAFKA-5831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152509#comment-16152509 ] fengchaoli commented on KAFKA-5831: --- In my test case use 1K buffer , 18% compression ration use 32K

[jira] [Resolved] (KAFKA-1946) Fix various broker metrics

[ https://issues.apache.org/jira/browse/KAFKA-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1946. -- Resolution: Fixed > Fix various broker metrics > -- > > Key:

Re: [jira] [Updated] (KAFKA-5830) kafka-configs.sh should allow deletion of all configs for an entity

On Mon, Sep 4, 2017 at 5:03 PM, Mickael Maison (JIRA) wrote: > > [ https://issues.apache.org/jira/browse/KAFKA-5830?page= > com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] > > Mickael Maison updated KAFKA-5830: > -- >

[jira] [Resolved] (KAFKA-1962) Restore delayed request metrics

[ https://issues.apache.org/jira/browse/KAFKA-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1962. -- Resolution: Fixed > Restore delayed request metrics > --- > >

[jira] [Created] (KAFKA-5831) MemoryRecordsBuilder uses small compression buffer leading to snappy low compression ratio

fengchaoli created KAFKA-5831: - Summary: MemoryRecordsBuilder uses small compression buffer leading to snappy low compression ratio Key: KAFKA-5831 URL: https://issues.apache.org/jira/browse/KAFKA-5831

[jira] [Updated] (KAFKA-5830) kafka-configs.sh should allow deletion of all configs for an entity

[ https://issues.apache.org/jira/browse/KAFKA-5830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-5830: -- Summary: kafka-configs.sh should allow deletion of all configs for an entity (was:

[jira] [Created] (KAFKA-5830) kafka-configs.sh allow to delete all configs for an entity

Mickael Maison created KAFKA-5830: - Summary: kafka-configs.sh allow to delete all configs for an entity Key: KAFKA-5830 URL: https://issues.apache.org/jira/browse/KAFKA-5830 Project: Kafka

[jira] [Resolved] (KAFKA-1505) Broker failed to start because of corrupted replication-offset-checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1505. -- Resolution: Fixed This was fixed in newer versions. Pl reopen if you think the issue still exists >

[jira] [Commented] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory

[ https://issues.apache.org/jira/browse/KAFKA-5814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152413#comment-16152413 ] Ismael Juma commented on KAFKA-5814: See KAFKA-5470. > java.lang.OutOfMemoryError: Direct buffer

[jira] [Commented] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory

[ https://issues.apache.org/jira/browse/KAFKA-5814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152406#comment-16152406 ] Alexander Petrovsky commented on KAFKA-5814: Looks like it's related to

[jira] [Commented] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

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

[jira] [Resolved] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3059. -- Resolution: Duplicate This functionality is implemented in KAFKA-4743 > ConsumerGroupCommand should

[jira] [Created] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

Dong Lin created KAFKA-5829: --- Summary: Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion Key: KAFKA-5829 URL: https://issues.apache.org/jira/browse/KAFKA-5829

[jira] [Commented] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer

[ https://issues.apache.org/jira/browse/KAFKA-5523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152256#comment-16152256 ] Paolo Patierno commented on KAFKA-5523: --- Thanks [~guozhang] ... so it's worth to move to use the