[jira] [Commented] (KAFKA-6219) Inconsistent behavior for kafka-consumer-groups

[ https://issues.apache.org/jira/browse/KAFKA-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254849#comment-16254849 ] Vahid Hashemian commented on KAFKA-6219: [~huxi_2b] Is this possibly a duplicate of

[jira] [Commented] (KAFKA-6213) Stream processor receives messages after close() is invoked

[ https://issues.apache.org/jira/browse/KAFKA-6213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254831#comment-16254831 ] Matthias J. Sax commented on KAFKA-6213: The behavior you describe sound as expected. However,

[jira] [Updated] (KAFKA-6219) Inconsistent behavior for kafka-consumer-groups

[ https://issues.apache.org/jira/browse/KAFKA-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-6219: -- Summary: Inconsistent behavior for kafka-consumer-groups (was: Inconsistent behavior for kafka-consumer-groups

[jira] [Updated] (KAFKA-6219) Inconsistent behavior for kafka-consumer-groups

[ https://issues.apache.org/jira/browse/KAFKA-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-6219: -- Description: For example, when ACL is enabled, running kafka-consumer-groups.sh --describe to describe a group

[jira] [Created] (KAFKA-6219) Inconsistent behavior for kafka-consumer-groups with ACL enabled

huxihx created KAFKA-6219: - Summary: Inconsistent behavior for kafka-consumer-groups with ACL enabled Key: KAFKA-6219 URL: https://issues.apache.org/jira/browse/KAFKA-6219 Project: Kafka Issue

[jira] [Commented] (KAFKA-6212) Kafka Streams - Incorrect partition rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-6212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254825#comment-16254825 ] Matthias J. Sax commented on KAFKA-6212: Thanks for report this. It's hard to say what happening

[jira] [Commented] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254822#comment-16254822 ] Sudhir Pradhan commented on KAFKA-5891: --- I am facing same issue when consuming from KAFKA to HDFS

[jira] [Commented] (KAFKA-6181) Examining log messages with {{--deep-iteration}} should show superset of fields

[ https://issues.apache.org/jira/browse/KAFKA-6181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254735#comment-16254735 ] Nikhil Deore commented on KAFKA-6181: - Hi, I am new to the kafka, Can you please assign this issue to

[jira] [Updated] (KAFKA-6211) PartitionAssignmentState is protected whereas KafkaConsumerGroupService.describeGroup() returns PartitionAssignmentState Object

[ https://issues.apache.org/jira/browse/KAFKA-6211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhransu Acharya updated KAFKA-6211: - Priority: Critical (was: Major) > PartitionAssignmentState is protected whereas >

[jira] [Commented] (KAFKA-6218) Optimize condition in if statement to reduce the number of comparisons

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

[jira] [Created] (KAFKA-6218) Optimize condition in if statement to reduce the number of comparisons

sachin bhalekar created KAFKA-6218: -- Summary: Optimize condition in if statement to reduce the number of comparisons Key: KAFKA-6218 URL: https://issues.apache.org/jira/browse/KAFKA-6218 Project:

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254671#comment-16254671 ] Jun Rao commented on KAFKA-6194: [~corlettb], if the compaction is very aggressive, it is possible that a

[jira] [Created] (KAFKA-6217) Allow consumers to read messages from LEO

Ashok Bala created KAFKA-6217: - Summary: Allow consumers to read messages from LEO Key: KAFKA-6217 URL: https://issues.apache.org/jira/browse/KAFKA-6217 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6167) Timestamp on streams directory contains a colon, which is an illegal character

[ https://issues.apache.org/jira/browse/KAFKA-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254617#comment-16254617 ] ASF GitHub Bot commented on KAFKA-6167: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-6210) IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version or log.message.format.version

[ https://issues.apache.org/jira/browse/KAFKA-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254596#comment-16254596 ] ASF GitHub Bot commented on KAFKA-6210: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-6210) IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version or log.message.format.version

[ https://issues.apache.org/jira/browse/KAFKA-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6210. Resolution: Fixed > IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version >

[jira] [Commented] (KAFKA-6170) Add the AdminClient in Streams' KafkaClientSupplier

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

[jira] [Commented] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254503#comment-16254503 ] Ted Yu commented on KAFKA-6024: --- Can you ping a committer ? :-) > Consider moving validation in

[jira] [Updated] (KAFKA-6216) kafka logs for misconfigured ssl clients are unhelpful

[ https://issues.apache.org/jira/browse/KAFKA-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-6216: Description: if you misconfigure the keystores on an ssl client, you will currently get a

[jira] [Commented] (KAFKA-6216) kafka logs for misconfigured ssl clients are unhelpful

[ https://issues.apache.org/jira/browse/KAFKA-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254473#comment-16254473 ] radai rosenblatt commented on KAFKA-6216: - i have a proposed fix to address this here -

[jira] [Created] (KAFKA-6216) kafka logs for misconfigured ssl clients are unhelpful

radai rosenblatt created KAFKA-6216: --- Summary: kafka logs for misconfigured ssl clients are unhelpful Key: KAFKA-6216 URL: https://issues.apache.org/jira/browse/KAFKA-6216 Project: Kafka

[jira] [Commented] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254379#comment-16254379 ] siva santhalingam commented on KAFKA-6024: -- [~tedyu] Could you please merge this to the next

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254129#comment-16254129 ] Trevor Huey commented on KAFKA-3705: [~jfilipiak] Please bear with me while I try to get caught up.

[jira] [Commented] (KAFKA-6215) KafkaStreamsTest fails in trunk

[ https://issues.apache.org/jira/browse/KAFKA-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254030#comment-16254030 ] ASF GitHub Bot commented on KAFKA-6215: --- Github user asfgit closed the pull request at:

[jira] [Assigned] (KAFKA-6215) KafkaStreamsTest fails in trunk

[ https://issues.apache.org/jira/browse/KAFKA-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6215: -- Assignee: Matthias J. Sax > KafkaStreamsTest fails in trunk >

[jira] [Commented] (KAFKA-6215) KafkaStreamsTest fails in trunk

[ https://issues.apache.org/jira/browse/KAFKA-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253871#comment-16253871 ] Guozhang Wang commented on KAFKA-6215: -- I think [~mjsax] has already worked on that with a PR. >

[jira] [Created] (KAFKA-6215) KafkaStreamsTest fails in trunk

Ted Yu created KAFKA-6215: - Summary: KafkaStreamsTest fails in trunk Key: KAFKA-6215 URL: https://issues.apache.org/jira/browse/KAFKA-6215 Project: Kafka Issue Type: Test Reporter: Ted

[jira] [Commented] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253824#comment-16253824 ] John Crowley commented on KAFKA-3806: - Further into the KIP, and not starting the timer until all

[jira] [Commented] (KAFKA-6214) Using standby replicas with an in memory state store causes Streams to crash

[ https://issues.apache.org/jira/browse/KAFKA-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253783#comment-16253783 ] Damian Guy commented on KAFKA-6214: --- Looks like the issue is in {{ProcessorStateManager}}. We only

[jira] [Commented] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253743#comment-16253743 ] John Crowley commented on KAFKA-3806: - Thanks for quick response. Yes, I did find the 4682 entry & KIP

[jira] [Commented] (KAFKA-6210) IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version or log.message.format.version

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

[jira] [Updated] (KAFKA-6210) IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version or log.message.format.version

[ https://issues.apache.org/jira/browse/KAFKA-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6210: --- Priority: Major (was: Critical) > IllegalArgumentException if 1.0.0 is used for

[jira] [Created] (KAFKA-6214) Using standby replicas with an in memory state store causes Streams to crash

Matt Farmer created KAFKA-6214: -- Summary: Using standby replicas with an in memory state store causes Streams to crash Key: KAFKA-6214 URL: https://issues.apache.org/jira/browse/KAFKA-6214 Project:

[jira] [Commented] (KAFKA-6189) Loosing messages on OFFSET_OUT_OF_RANGE error in consumer

[ https://issues.apache.org/jira/browse/KAFKA-6189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253678#comment-16253678 ] Xinyang Gao commented on KAFKA-6189: I noticed that the above bug is resulted from KAFKA-5600, since I

[jira] [Commented] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253663#comment-16253663 ] James Cheng commented on KAFKA-3806: [~jcrowley], you should check out

[jira] [Commented] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active (KIP-211)

[ https://issues.apache.org/jira/browse/KAFKA-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253655#comment-16253655 ] John Crowley commented on KAFKA-4682: - Just found this entry - had previously commented on

[jira] [Comment Edited] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253555#comment-16253555 ] John Crowley edited comment on KAFKA-3806 at 11/15/17 2:55 PM: --- Am working

[jira] [Comment Edited] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253555#comment-16253555 ] John Crowley edited comment on KAFKA-3806 at 11/15/17 2:55 PM: --- Am working

[jira] [Commented] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253555#comment-16253555 ] John Crowley commented on KAFKA-3806: - Am working on a PubSub project where the source is reference

[jira] [Comment Edited] (KAFKA-6194) Server crash while deleting segments

[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253525#comment-16253525 ] Ismael Juma edited comment on KAFKA-6194 at 11/15/17 2:35 PM: -- FYI,

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253525#comment-16253525 ] Ismael Juma commented on KAFKA-6194: FYI, `retention.ms` has no impact if `cleanup.policy` is compact.

[jira] [Commented] (KAFKA-6164) ClientQuotaManager threads prevent shutdown when encountering an error loading logs

[ https://issues.apache.org/jira/browse/KAFKA-6164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253414#comment-16253414 ] ASF GitHub Bot commented on KAFKA-6164: --- Github user rajinisivaram closed the pull request at:

[jira] [Issue Comment Deleted] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request

[ https://issues.apache.org/jira/browse/KAFKA-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Glover updated KAFKA-5859: --- Comment: was deleted (was: I've submitted a PR for this ticket. See description for more details

[jira] [Created] (KAFKA-6213) Stream processor receives messages after close() is invoked

Bart De Vylder created KAFKA-6213: - Summary: Stream processor receives messages after close() is invoked Key: KAFKA-6213 URL: https://issues.apache.org/jira/browse/KAFKA-6213 Project: Kafka

[jira] [Comment Edited] (KAFKA-6185) Selector memory leak with high likelihood of OOM in case of down conversion

[ https://issues.apache.org/jira/browse/KAFKA-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253043#comment-16253043 ] Brett Rann edited comment on KAFKA-6185 at 11/15/17 11:03 AM: -- *update* the

[jira] [Created] (KAFKA-6212) Kafka Streams - Incorrect partition rebalancing

Ivan Atanasov created KAFKA-6212: Summary: Kafka Streams - Incorrect partition rebalancing Key: KAFKA-6212 URL: https://issues.apache.org/jira/browse/KAFKA-6212 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6211) PartitionAssignmentState is protected whereas KafkaConsumerGroupService.describeGroup() returns PartitionAssignmentState Object

Subhransu Acharya created KAFKA-6211: Summary: PartitionAssignmentState is protected whereas KafkaConsumerGroupService.describeGroup() returns PartitionAssignmentState Object Key: KAFKA-6211 URL:

[jira] [Created] (KAFKA-6210) IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version or log.message.format.version

Ismael Juma created KAFKA-6210: -- Summary: IllegalArgumentException if 1.0.0 is used for inter.broker.protocol.version or log.message.format.version Key: KAFKA-6210 URL: