[jira] [Commented] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507426#comment-16507426 ] Stanislav Kozlovski commented on KAFKA-6889: How can I reproduce this? Running {code:java}

[jira] [Commented] (KAFKA-7065) Quickstart tutorial fails because of missing brokers

[ https://issues.apache.org/jira/browse/KAFKA-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514726#comment-16514726 ] Stanislav Kozlovski commented on KAFKA-7065: Strange, the quickstart works for me with Ubuntu

[jira] [Commented] (KAFKA-7060) Command-line overrides for ConnectDistributed worker properties

[ https://issues.apache.org/jira/browse/KAFKA-7060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16513581#comment-16513581 ] Stanislav Kozlovski commented on KAFKA-7060: Love this change, the only concern I have is

[jira] [Commented] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507639#comment-16507639 ] Stanislav Kozlovski commented on KAFKA-6889: I seemingly do not even have read access - the

[jira] [Commented] (KAFKA-7033) Modify AbstractOptions's timeoutMs as Long type

[ https://issues.apache.org/jira/browse/KAFKA-7033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507850#comment-16507850 ] Stanislav Kozlovski commented on KAFKA-7033: 2147483647 (the max value of an Integer)

[jira] [Updated] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-6889: --- Attachment: (was: Screen Shot 2018-06-11 at 7.15.02 PM.png) > Fix Streams system

[jira] [Updated] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-6889: --- Attachment: Screen Shot 2018-06-11 at 7.15.02 PM.png > Fix Streams system test to

[jira] [Updated] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-6889: --- Attachment: Screen Shot 2018-06-11 at 7.15.02 PM.png > Fix Streams system test to

[jira] [Updated] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-6889: --- Attachment: (was: Screen Shot 2018-06-11 at 7.15.02 PM.png) > Fix Streams system

[jira] [Commented] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508285#comment-16508285 ] Stanislav Kozlovski commented on KAFKA-6889: What do you mean the Jenkins has read access?

[jira] [Commented] (KAFKA-7028) super.users doesn't work with custom principals

[ https://issues.apache.org/jira/browse/KAFKA-7028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523839#comment-16523839 ] Stanislav Kozlovski commented on KAFKA-7028: After investigation, me and [~rsivaram] found

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523867#comment-16523867 ] Stanislav Kozlovski commented on KAFKA-6812: I believe this current behavior is correct. You

[jira] [Commented] (KAFKA-6809) connections-created metric does not behave as expected

[ https://issues.apache.org/jira/browse/KAFKA-6809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523885#comment-16523885 ] Stanislav Kozlovski commented on KAFKA-6809: Changing them to the first approach (count both

[jira] [Commented] (KAFKA-6809) connections-created metric does not behave as expected

[ https://issues.apache.org/jira/browse/KAFKA-6809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523985#comment-16523985 ] Stanislav Kozlovski commented on KAFKA-6809: I'm not sure I understand what the appropriate

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524760#comment-16524760 ] Stanislav Kozlovski commented on KAFKA-6812: [~andrasbeni] Having the ability to add an

[jira] [Comment Edited] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524760#comment-16524760 ] Stanislav Kozlovski edited comment on KAFKA-6812 at 6/27/18 8:25 AM: -

[jira] [Assigned] (KAFKA-6809) connections-created metric does not behave as expected

[ https://issues.apache.org/jira/browse/KAFKA-6809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-6809: -- Assignee: Stanislav Kozlovski > connections-created metric does not behave as

[jira] [Commented] (KAFKA-6758) Default "" consumer group tracks committed offsets, but is otherwise not a real group

[ https://issues.apache.org/jira/browse/KAFKA-6758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528776#comment-16528776 ] Stanislav Kozlovski commented on KAFKA-6758: Thanks for the issue, [~dwvangeest] Looks like

[jira] [Assigned] (KAFKA-5662) We should be able to specify min.insync.replicas for the __consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-5662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-5662: -- Assignee: Stanislav Kozlovski > We should be able to specify

[jira] [Assigned] (KAFKA-7237) Add explicit fatal marker to fatal error messages

[ https://issues.apache.org/jira/browse/KAFKA-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7237: -- Assignee: Stanislav Kozlovski > Add explicit fatal marker to fatal error

[jira] [Created] (KAFKA-7215) Improve LogCleaner behavior on error

Stanislav Kozlovski created KAFKA-7215: -- Summary: Improve LogCleaner behavior on error Key: KAFKA-7215 URL: https://issues.apache.org/jira/browse/KAFKA-7215 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7266) Fix MetricsTest test flakiness

Stanislav Kozlovski created KAFKA-7266: -- Summary: Fix MetricsTest test flakiness Key: KAFKA-7266 URL: https://issues.apache.org/jira/browse/KAFKA-7266 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-7266) Fix MetricsTest test flakiness

[ https://issues.apache.org/jira/browse/KAFKA-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7266: --- Description: The test `kafka.api.MetricsTest.testMetrics` has been failing

[jira] [Updated] (KAFKA-7324) NPE due to lack of SASLExtensions in SASL/OAUTHBEARER

[ https://issues.apache.org/jira/browse/KAFKA-7324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7324: --- Affects Version/s: (was: 2.0.1) 2.1.0 > NPE due to lack

[jira] [Updated] (KAFKA-7324) NPE due to lack of SASLExtensions in SASL/OAUTHBEARER

[ https://issues.apache.org/jira/browse/KAFKA-7324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7324: --- Fix Version/s: (was: 2.0.1) 2.1.0 > NPE due to lack of

[jira] [Commented] (KAFKA-7324) NPE due to lack of SASLExtensions in SASL/OAUTHBEARER

[ https://issues.apache.org/jira/browse/KAFKA-7324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588541#comment-16588541 ] Stanislav Kozlovski commented on KAFKA-7324: Hi Ron, I've updated the issue to reflect

[jira] [Updated] (KAFKA-7169) Add support for Custom SASL extensions in OAuth authentication

[ https://issues.apache.org/jira/browse/KAFKA-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7169: --- Description: KIP:

[jira] [Updated] (KAFKA-7169) Add support for Custom SASL extensions in OAuth authentication

[ https://issues.apache.org/jira/browse/KAFKA-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7169: --- Description: KIP:

[jira] [Created] (KAFKA-7169) Add support for Custom SASL extensions in OAuth authentication

Stanislav Kozlovski created KAFKA-7169: -- Summary: Add support for Custom SASL extensions in OAuth authentication Key: KAFKA-7169 URL: https://issues.apache.org/jira/browse/KAFKA-7169 Project:

[jira] [Assigned] (KAFKA-7373) GetOffsetShell doesn't work when SSL authentication is enabled

[ https://issues.apache.org/jira/browse/KAFKA-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7373: -- Assignee: Andy Bryant (was: Stanislav Kozlovski) > GetOffsetShell doesn't

[jira] [Commented] (KAFKA-7373) GetOffsetShell doesn't work when SSL authentication is enabled

[ https://issues.apache.org/jira/browse/KAFKA-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605905#comment-16605905 ] Stanislav Kozlovski commented on KAFKA-7373: I get another error with Kafka trunk {code:java}

[jira] [Assigned] (KAFKA-7373) GetOffsetShell doesn't work when SSL authentication is enabled

[ https://issues.apache.org/jira/browse/KAFKA-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7373: -- Assignee: (was: Andy Bryant) > GetOffsetShell doesn't work when SSL

[jira] [Assigned] (KAFKA-7373) GetOffsetShell doesn't work when SSL authentication is enabled

[ https://issues.apache.org/jira/browse/KAFKA-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7373: -- Assignee: Stanislav Kozlovski > GetOffsetShell doesn't work when SSL

[jira] [Commented] (KAFKA-7373) GetOffsetShell doesn't work when SSL authentication is enabled

[ https://issues.apache.org/jira/browse/KAFKA-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605937#comment-16605937 ] Stanislav Kozlovski commented on KAFKA-7373: Hi [~kiwiandy], There is KIP-308 for

[jira] [Assigned] (KAFKA-5682) Consumer should include partition in exceptions raised during record parsing/validation

[ https://issues.apache.org/jira/browse/KAFKA-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-5682: -- Assignee: Stanislav Kozlovski > Consumer should include partition in

[jira] [Updated] (KAFKA-5682) Consumer should include partition in exceptions raised during record parsing/validation

[ https://issues.apache.org/jira/browse/KAFKA-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-5682: --- Priority: Minor (was: Major) > Consumer should include partition in exceptions

[jira] [Commented] (KAFKA-7132) Consider adding faster form of rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532545#comment-16532545 ] Stanislav Kozlovski commented on KAFKA-7132: The best way to consider this is to open a KIP

[jira] [Commented] (KAFKA-6268) Tools should not swallow exceptions like resolving network names

[ https://issues.apache.org/jira/browse/KAFKA-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531689#comment-16531689 ] Stanislav Kozlovski commented on KAFKA-6268: [~astubbs] at the moment there is no clear way

[jira] [Commented] (KAFKA-7028) super.users doesn't work with custom principals

[ https://issues.apache.org/jira/browse/KAFKA-7028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527280#comment-16527280 ] Stanislav Kozlovski commented on KAFKA-7028: As far as I can tell, checking the type and name

[jira] [Commented] (KAFKA-7028) super.users doesn't work with custom principals

[ https://issues.apache.org/jira/browse/KAFKA-7028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527329#comment-16527329 ] Stanislav Kozlovski commented on KAFKA-7028: [~rsivaram] Agreed, instantiating might be a tad

[jira] [Commented] (KAFKA-7111) Review the NetworkClient log level used

[ https://issues.apache.org/jira/browse/KAFKA-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526213#comment-16526213 ] Stanislav Kozlovski commented on KAFKA-7111: [~lcestari] how can I reproduce this and which

[jira] [Commented] (KAFKA-7111) Review the NetworkClient log level used

[ https://issues.apache.org/jira/browse/KAFKA-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526258#comment-16526258 ] Stanislav Kozlovski commented on KAFKA-7111: Okay [~lcestari], I will look into it. What

[jira] [Commented] (KAFKA-6268) Tools should now swallow exceptions like resolving network names

[ https://issues.apache.org/jira/browse/KAFKA-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526212#comment-16526212 ] Stanislav Kozlovski commented on KAFKA-6268: I could not reproduce this with version `0.11`.

[jira] [Commented] (KAFKA-7111) Review the NetworkClient log level used

[ https://issues.apache.org/jira/browse/KAFKA-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526405#comment-16526405 ] Stanislav Kozlovski commented on KAFKA-7111: [~lcestari] I followed the instructions on the

[jira] [Commented] (KAFKA-7111) Review the NetworkClient log level used

[ https://issues.apache.org/jira/browse/KAFKA-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527667#comment-16527667 ] Stanislav Kozlovski commented on KAFKA-7111: Yes I believe it is worth it to change the log

[jira] [Commented] (KAFKA-7111) Review the NetworkClient log level used

[ https://issues.apache.org/jira/browse/KAFKA-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527577#comment-16527577 ] Stanislav Kozlovski commented on KAFKA-7111: Hey Luan, After debugging for a while, I worked

[jira] [Comment Edited] (KAFKA-7266) Fix MetricsTest test flakiness

[ https://issues.apache.org/jira/browse/KAFKA-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640035#comment-16640035 ] Stanislav Kozlovski edited comment on KAFKA-7266 at 10/5/18 4:19 PM: -

[jira] [Commented] (KAFKA-7266) Fix MetricsTest test flakiness

[ https://issues.apache.org/jira/browse/KAFKA-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640035#comment-16640035 ] Stanislav Kozlovski commented on KAFKA-7266: Hey [~lindong], is there any reason this can't

[jira] [Commented] (KAFKA-7266) Fix MetricsTest test flakiness

[ https://issues.apache.org/jira/browse/KAFKA-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640085#comment-16640085 ] Stanislav Kozlovski commented on KAFKA-7266: Thanks. Sorry for not marking it the first time

[jira] [Created] (KAFKA-7517) Add a minimum retention.bytes config value

Stanislav Kozlovski created KAFKA-7517: -- Summary: Add a minimum retention.bytes config value Key: KAFKA-7517 URL: https://issues.apache.org/jira/browse/KAFKA-7517 Project: Kafka Issue

[jira] [Commented] (KAFKA-7525) Handling corrupt records

[ https://issues.apache.org/jira/browse/KAFKA-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658747#comment-16658747 ] Stanislav Kozlovski commented on KAFKA-7525:       Hi [~Solnica] , thanks for the report!

[jira] [Created] (KAFKA-7528) Make Min and Max metrics' default value consistent with each other

Stanislav Kozlovski created KAFKA-7528: -- Summary: Make Min and Max metrics' default value consistent with each other Key: KAFKA-7528 URL: https://issues.apache.org/jira/browse/KAFKA-7528

[jira] [Updated] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7514: --- Description: Trogdor's ConsumeBenchWorker currently uses only two threads - one for

[jira] [Created] (KAFKA-7515) Trogdor - Add Consumer Group Benchmark Specification

Stanislav Kozlovski created KAFKA-7515: -- Summary: Trogdor - Add Consumer Group Benchmark Specification Key: KAFKA-7515 URL: https://issues.apache.org/jira/browse/KAFKA-7515 Project: Kafka

[jira] [Updated] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7514: --- Description: Trogdor's ConsumeBenchWorker currently uses only two threads - one for

[jira] [Updated] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7514: --- Description: Trogdor's ConsumeBenchWorker currently uses only two threads - one for

[jira] [Created] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

Stanislav Kozlovski created KAFKA-7514: -- Summary: Trogdor - Support Multiple Threads in ConsumeBenchWorker Key: KAFKA-7514 URL: https://issues.apache.org/jira/browse/KAFKA-7514 Project: Kafka

[jira] [Updated] (KAFKA-7515) Trogdor - Add Consumer Group Benchmark Specification

[ https://issues.apache.org/jira/browse/KAFKA-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7515: --- Description: Trogdor's `ConsumeBenchWorker` and `ConsumeBenchSpec` currently takes

[jira] [Commented] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660821#comment-16660821 ] Stanislav Kozlovski commented on KAFKA-7532: Thanks for reporting this [~ankon] > Missing

[jira] [Assigned] (KAFKA-7532) Missing stringification in error message "Removed ArrayBuffer() from list of shutting down brokers. (kafka.controller.KafkaController)"

[ https://issues.apache.org/jira/browse/KAFKA-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7532: -- Assignee: Stanislav Kozlovski > Missing stringification in error message

[jira] [Created] (KAFKA-7561) Console Consumer - system test fails

Stanislav Kozlovski created KAFKA-7561: -- Summary: Console Consumer - system test fails Key: KAFKA-7561 URL: https://issues.apache.org/jira/browse/KAFKA-7561 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7559) ConnectStandaloneFileTest system tests do not pass

Stanislav Kozlovski created KAFKA-7559: -- Summary: ConnectStandaloneFileTest system tests do not pass Key: KAFKA-7559 URL: https://issues.apache.org/jira/browse/KAFKA-7559 Project: Kafka

[jira] [Created] (KAFKA-7560) Client Quota - system test failure

Stanislav Kozlovski created KAFKA-7560: -- Summary: Client Quota - system test failure Key: KAFKA-7560 URL: https://issues.apache.org/jira/browse/KAFKA-7560 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7564) Trogdor - Expose single task details from Trogdor Coordinator

Stanislav Kozlovski created KAFKA-7564: -- Summary: Trogdor - Expose single task details from Trogdor Coordinator Key: KAFKA-7564 URL: https://issues.apache.org/jira/browse/KAFKA-7564 Project:

[jira] [Updated] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7514: --- Description: Trogdor's ConsumeBenchWorker currently uses only two threads - one for

[jira] [Created] (KAFKA-7579) System Test Failure - security_test.SecurityTest.test_client_ssl_endpoint_validation_failure

Stanislav Kozlovski created KAFKA-7579: -- Summary: System Test Failure - security_test.SecurityTest.test_client_ssl_endpoint_validation_failure Key: KAFKA-7579 URL:

[jira] [Comment Edited] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675694#comment-16675694 ] Stanislav Kozlovski edited comment on KAFKA-6812 at 11/5/18 7:50 PM: -

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675694#comment-16675694 ] Stanislav Kozlovski commented on KAFKA-6812: Hi [~kamalkang] , no progress has been made on

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680331#comment-16680331 ] Stanislav Kozlovski commented on KAFKA-6812: Hey [~kamalkang], the best way is to directly

[jira] [Commented] (KAFKA-7618) Trogdor - Fix /tasks endpoint parameters

[ https://issues.apache.org/jira/browse/KAFKA-7618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683803#comment-16683803 ] Stanislav Kozlovski commented on KAFKA-7618: https://github.com/apache/kafka/pull/5905 >

[jira] [Created] (KAFKA-7619) Trogdor - Allow filtering tasks by state in /coordinator/tasks endpoint

Stanislav Kozlovski created KAFKA-7619: -- Summary: Trogdor - Allow filtering tasks by state in /coordinator/tasks endpoint Key: KAFKA-7619 URL: https://issues.apache.org/jira/browse/KAFKA-7619

[jira] [Created] (KAFKA-7618) Trogdor - Fix /tasks endpoint parameters

Stanislav Kozlovski created KAFKA-7618: -- Summary: Trogdor - Fix /tasks endpoint parameters Key: KAFKA-7618 URL: https://issues.apache.org/jira/browse/KAFKA-7618 Project: Kafka Issue

[jira] [Created] (KAFKA-7638) Trogdor - Support mass task creation endpoint

Stanislav Kozlovski created KAFKA-7638: -- Summary: Trogdor - Support mass task creation endpoint Key: KAFKA-7638 URL: https://issues.apache.org/jira/browse/KAFKA-7638 Project: Kafka

[jira] [Created] (KAFKA-7597) Trogdor - Support transactions in ProduceBenchWorker

Stanislav Kozlovski created KAFKA-7597: -- Summary: Trogdor - Support transactions in ProduceBenchWorker Key: KAFKA-7597 URL: https://issues.apache.org/jira/browse/KAFKA-7597 Project: Kafka

[jira] [Updated] (KAFKA-7599) Trogdor - Allow configuration for not throttling Benchmark Workers and expose messages per second in task status

[ https://issues.apache.org/jira/browse/KAFKA-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7599: --- Summary: Trogdor - Allow configuration for not throttling Benchmark Workers and

[jira] [Created] (KAFKA-7599) Trogdor - Allow configuration for not throttling Benchmark Workers and expose messages per second

Stanislav Kozlovski created KAFKA-7599: -- Summary: Trogdor - Allow configuration for not throttling Benchmark Workers and expose messages per second Key: KAFKA-7599 URL:

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686259#comment-16686259 ] Stanislav Kozlovski commented on KAFKA-6812: [~kamalkang] I don't have access to that

[jira] [Updated] (KAFKA-7528) Standardize on Min/Avg/Max Kafka metrics' default value

[ https://issues.apache.org/jira/browse/KAFKA-7528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7528: --- Summary: Standardize on Min/Avg/Max Kafka metrics' default value (was: Make Min and

[jira] [Updated] (KAFKA-7528) Standardize on Min/Avg/Max Kafka metrics' default value

[ https://issues.apache.org/jira/browse/KAFKA-7528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7528: --- Description: KIP-386:

[jira] [Commented] (KAFKA-7479) Call to "producer.initTransaction" hangs when using IP for "bootstrap.servers"

[ https://issues.apache.org/jira/browse/KAFKA-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643240#comment-16643240 ] Stanislav Kozlovski commented on KAFKA-7479: Hi [~bezrukavyy] , could you enable debug

[jira] [Updated] (KAFKA-5682) Consumer should include partition in exceptions raised during record parsing/validation

[ https://issues.apache.org/jira/browse/KAFKA-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-5682: --- Fix Version/s: (was: 2.1.0) 2.2.0 > Consumer should include

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

[ https://issues.apache.org/jira/browse/KAFKA-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7114: --- Description: *Infrastructure:* Kafka is running in cluster mode with 3 brokers and

[jira] [Created] (KAFKA-7478) Reduce OAuthBearerLoginModule verbosity

Stanislav Kozlovski created KAFKA-7478: -- Summary: Reduce OAuthBearerLoginModule verbosity Key: KAFKA-7478 URL: https://issues.apache.org/jira/browse/KAFKA-7478 Project: Kafka Issue

[jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690013#comment-16690013 ] Stanislav Kozlovski commented on KAFKA-7641: Thanks for opening the ticket [~bchen225242] . 

[jira] [Resolved] (KAFKA-7515) Trogdor - Add Consumer Group Benchmark Specification

[ https://issues.apache.org/jira/browse/KAFKA-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-7515. Resolution: Fixed > Trogdor - Add Consumer Group Benchmark Specification >

[jira] [Resolved] (KAFKA-7618) Trogdor - Fix /tasks endpoint parameters

[ https://issues.apache.org/jira/browse/KAFKA-7618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-7618. Resolution: Fixed > Trogdor - Fix /tasks endpoint parameters >

[jira] [Resolved] (KAFKA-7564) Trogdor - Expose single task details from Trogdor Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-7564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-7564. Resolution: Fixed > Trogdor - Expose single task details from Trogdor Coordinator

[jira] [Resolved] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-7514. Resolution: Fixed > Trogdor - Support Multiple Threads in ConsumeBenchWorker >

[jira] [Assigned] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7641: -- Assignee: Stanislav Kozlovski (was: Boyang Chen) > Add

[jira] [Created] (KAFKA-7819) Trogdor - Improve RoundTripWorker

Stanislav Kozlovski created KAFKA-7819: -- Summary: Trogdor - Improve RoundTripWorker Key: KAFKA-7819 URL: https://issues.apache.org/jira/browse/KAFKA-7819 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7851) Continue data streaming while rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749793#comment-16749793 ] Stanislav Kozlovski commented on KAFKA-7851: [~cri] it's also worth mentioning that we have a

[jira] [Updated] (KAFKA-7819) Trogdor - Improve RoundTripWorker

[ https://issues.apache.org/jira/browse/KAFKA-7819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7819: --- Description: Trogdor's RoundTripWorker task has a couple of shortcomings: *

[jira] [Created] (KAFKA-7717) Enable security configs in kafka.tools.EndToEndLatency

Stanislav Kozlovski created KAFKA-7717: -- Summary: Enable security configs in kafka.tools.EndToEndLatency Key: KAFKA-7717 URL: https://issues.apache.org/jira/browse/KAFKA-7717 Project: Kafka

[jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701741#comment-16701741 ] Stanislav Kozlovski commented on KAFKA-7641: Hi Jack, Thanks for offering help on this

[jira] [Commented] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712789#comment-16712789 ] Stanislav Kozlovski commented on KAFKA-7711: This sounds good to me. Thanks for opening the

[jira] [Comment Edited] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712789#comment-16712789 ] Stanislav Kozlovski edited comment on KAFKA-7711 at 12/7/18 12:39 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-4493: -- Assignee: Stanislav Kozlovski > Connections to Kafka brokers should be

[jira] [Created] (KAFKA-7670) Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer

Stanislav Kozlovski created KAFKA-7670: -- Summary: Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer Key: KAFKA-7670 URL: https://issues.apache.org/jira/browse/KAFKA-7670

[jira] [Updated] (KAFKA-7670) Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer

[ https://issues.apache.org/jira/browse/KAFKA-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7670: --- Priority: Minor (was: Major) > Fix flaky test -

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

[ https://issues.apache.org/jira/browse/KAFKA-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691676#comment-16691676 ] Stanislav Kozlovski commented on KAFKA-4493: [~taku-k] , I'd like to fix this issue. Are you

  1   2   3   4   5   >