[jira] [Commented] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837350#comment-15837350 ] Jeyhun Karimov commented on KAFKA-4144: --- Thanks for clarification. I got the point.

[jira] [Created] (KAFKA-4695) Can't start Kafka server after Blue Screen

Kevin Tippenhauer created KAFKA-4695: Summary: Can't start Kafka server after Blue Screen Key: KAFKA-4695 URL: https://issues.apache.org/jira/browse/KAFKA-4695 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-4695) Can't start Kafka server after Blue Screen

[ https://issues.apache.org/jira/browse/KAFKA-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tippenhauer updated KAFKA-4695: - Description: When I get a blue screen (my laptop does that quite often) I can't start my

[jira] [Updated] (KAFKA-4695) Can't start Kafka server after Blue Screen

[ https://issues.apache.org/jira/browse/KAFKA-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tippenhauer updated KAFKA-4695: - Description: When I get a blue screen (my laptop does that quite often) I can't start my

[jira] [Updated] (KAFKA-4695) Can't start Kafka server after Blue Screen

[ https://issues.apache.org/jira/browse/KAFKA-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tippenhauer updated KAFKA-4695: - Description: When I get a blue screen (my laptop does that quite often) I can't start my

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

[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837519#comment-15837519 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipien

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

[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837518#comment-15837518 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipien

[jira] [Created] (KAFKA-4696) Streams standby task assignment should be state-store aware

Damian Guy created KAFKA-4696: - Summary: Streams standby task assignment should be state-store aware Key: KAFKA-4696 URL: https://issues.apache.org/jira/browse/KAFKA-4696 Project: Kafka Issue Ty

Re: [VOTE] KIP-104: Granular Sensors for Streams

Just FYI: between feature freeze and code freeze we realised that the name of a method didn't match its Javadoc and implementation, so changed addLatencySensor -> addLatencyAndThroughputSensor in the KIP and code. Thanks Eno > On 11 Jan 2017, at 08:10, Eno Thereska wrote: > > Thank you, this

[GitHub] kafka pull request #2399: KAFKA-4596: Throttled Replica Reassignment Error

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2399 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-4596) KIP-73 rebalance throttling breaks on plans for specific partitions

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

[jira] [Updated] (KAFKA-4596) KIP-73 rebalance throttling breaks on plans for specific partitions

[ https://issues.apache.org/jira/browse/KAFKA-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4596: --- Resolution: Fixed Status: Resolved (was: Patch Available) > KIP-73 rebalance throttling break

[GitHub] kafka pull request #2433: Update kafka-run-class.bat

GitHub user jonfreedman opened a pull request: https://github.com/apache/kafka/pull/2433 Update kafka-run-class.bat handle existing classpath with spaces list each lib dependency individually You can merge this pull request into a Git repository by running: $ git pull https

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

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837764#comment-15837764 ] Mitch Seymour commented on KAFKA-4113: -- [~guozhang] Yes that is perfect. I haven't ha

Build failed in Jenkins: kafka-trunk-jdk8 #1214

See Changes: [ismael] KAFKA-4596; Throttled reassignment should support partial JSON file -- [...truncated 4126 lines...] kafka.integration.SaslPlaintextTopicMetadataTest > testIsrAfterBrokerS

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

[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837793#comment-15837793 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipien

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

[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837792#comment-15837792 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipien

[jira] [Updated] (KAFKA-4636) Per listener security setting overrides (KIP-103)

[ https://issues.apache.org/jira/browse/KAFKA-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4636: --- Status: Patch Available (was: In Progress) > Per listener security setting overrides (KIP-103) >

Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression

Is there more discussion to be had on this KIP, or should it be taken to a vote? On Mon, Jan 16, 2017 at 6:37 AM Dongjin Lee wrote: > I updated KIP-110 with JMH-measured benchmark results. Please have a review > when you are free. (The overall result is not different yet.) > > Regards, > Dongjin

Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression

So far the discussion was around the performance characteristics of the new compression algorithm. Another area that is important and is not covered in the KIP is the compatibility implications. For example, what happens if a consumer that doesn't support zstd tries to consume a topic compressed wi

[jira] [Commented] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837964#comment-15837964 ] Ismael Juma commented on KAFKA-4631: Are we still aiming to have this done by this Fri

[jira] [Updated] (KAFKA-3987) Allow configuration of the hash algorithm used by the LogCleaner's offset map

[ https://issues.apache.org/jira/browse/KAFKA-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3987: --- Fix Version/s: (was: 0.10.2.0) > Allow configuration of the hash algorithm used by the LogCleaner'

[jira] [Updated] (KAFKA-3987) Allow configuration of the hash algorithm used by the LogCleaner's offset map

[ https://issues.apache.org/jira/browse/KAFKA-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3987: --- Labels: needs-kip (was: ) > Allow configuration of the hash algorithm used by the LogCleaner's offset

[jira] [Commented] (KAFKA-3987) Allow configuration of the hash algorithm used by the LogCleaner's offset map

[ https://issues.apache.org/jira/browse/KAFKA-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837969#comment-15837969 ] Ismael Juma commented on KAFKA-3987: Removed "fix version" as this needs a KIP. > All

[jira] [Updated] (KAFKA-3987) Allow configuration of the hash algorithm used by the LogCleaner's offset map

[ https://issues.apache.org/jira/browse/KAFKA-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3987: --- Priority: Major (was: Minor) > Allow configuration of the hash algorithm used by the LogCleaner's off

[jira] [Comment Edited] (KAFKA-3987) Allow configuration of the hash algorithm used by the LogCleaner's offset map

[ https://issues.apache.org/jira/browse/KAFKA-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837969#comment-15837969 ] Ismael Juma edited comment on KAFKA-3987 at 1/25/17 4:00 PM: -

[jira] [Updated] (KAFKA-3947) kafka-reassign-partitions.sh should support dumping current assignment

[ https://issues.apache.org/jira/browse/KAFKA-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3947: --- Fix Version/s: (was: 0.10.2.0) > kafka-reassign-partitions.sh should support dumping current assig

[jira] [Updated] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andres Gomez Ferrer updated KAFKA-4474: --- Attachment: kafka-streams-bug-1.png Example Architecture > Poor kafka-streams through

[jira] [Issue Comment Deleted] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andres Gomez Ferrer updated KAFKA-4474: --- Comment: was deleted (was: Example Architecture) > Poor kafka-streams throughput > --

[jira] [Updated] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andres Gomez Ferrer updated KAFKA-4474: --- Attachment: kafka-streams-bug-2.png > Poor kafka-streams throughput >

[jira] [Updated] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3959: --- Labels: needs-kip reliability (was: reliability) > __consumer_offsets wrong number of replicas at sta

[jira] [Updated] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3959: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > __consumer_offsets wrong number of re

[jira] [Updated] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2000: -- Resolution: Fixed Fix Version/s: (was: 0.10.2.0) 0.

[jira] [Commented] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15837994#comment-15837994 ] Ismael Juma commented on KAFKA-3959: Either way, it's too late for 0.10.2.0. I'll move

[GitHub] kafka pull request #1850: KAFKA-2000: Delete topic should also delete consum...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1850 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

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

[jira] [Updated] (KAFKA-4242) Re-enable committing offsets in consumer's unsubscribe() when auto commit is enabled

[ https://issues.apache.org/jira/browse/KAFKA-4242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4242: --- Fix Version/s: (was: 0.10.2.0) > Re-enable committing offsets in consumer's unsubscribe() when aut

[jira] [Commented] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838055#comment-15838055 ] Andres Gomez Ferrer commented on KAFKA-4474: Hi all, I investigated more on

[jira] [Commented] (KAFKA-4242) Re-enable committing offsets in consumer's unsubscribe() when auto commit is enabled

[ https://issues.apache.org/jira/browse/KAFKA-4242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838052#comment-15838052 ] Ismael Juma commented on KAFKA-4242: I removed the "fix version" since this depends on

[jira] [Updated] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3989: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Add JMH module for Benchmarks > -

[jira] [Commented] (KAFKA-3989) Add JMH module for Benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838056#comment-15838056 ] Ismael Juma commented on KAFKA-3989: Too late for 0.10.2.0, so aiming for 0.10.3.0. >

[jira] [Comment Edited] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838055#comment-15838055 ] Andres Gomez Ferrer edited comment on KAFKA-4474 at 1/25/17 4:31 PM: ---

[jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3554: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Generate actual data with specific co

[jira] [Updated] (KAFKA-3333) Client Partitioner - Round Robin

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-: --- Labels: needs-kip (was: ) > Client Partitioner - Round Robin > > >

[jira] [Updated] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3436: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Speed up controlled shutdown. > -

[jira] [Updated] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2000: -- Fix Version/s: 0.10.2.0 > Delete consumer offsets from kafka once the topic is d

[jira] [Updated] (KAFKA-3333) Client Partitioner - Round Robin

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-: --- Fix Version/s: (was: 0.10.2.0) > Client Partitioner - Round Robin > --

[jira] [Commented] (KAFKA-3333) Client Partitioner - Round Robin

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838064#comment-15838064 ] Ismael Juma commented on KAFKA-: This falls under "Any change that impacts the pub

[jira] [Commented] (KAFKA-3300) Calculate the initial/max size of offset index files and reduce the memory footprint for memory mapped index files.

[ https://issues.apache.org/jira/browse/KAFKA-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838069#comment-15838069 ] Ismael Juma commented on KAFKA-3300: This was deemed not necessary if I recall correct

[jira] [Updated] (KAFKA-3264) Mark the old Scala consumer and related classes as deprecated

[ https://issues.apache.org/jira/browse/KAFKA-3264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3264: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Mark the old Scala consumer and relat

[jira] [Updated] (KAFKA-3266) List/Alter Acls - protocol and server side implementation

[ https://issues.apache.org/jira/browse/KAFKA-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3266: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > List/Alter Acls - protocol and server

[jira] [Commented] (KAFKA-3234) Minor documentation edits: clarify minISR; some topic-level configs are missing

[ https://issues.apache.org/jira/browse/KAFKA-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838075#comment-15838075 ] Ismael Juma commented on KAFKA-3234: Removed "fix version" for now. > Minor documenta

[jira] [Updated] (KAFKA-3234) Minor documentation edits: clarify minISR; some topic-level configs are missing

[ https://issues.apache.org/jira/browse/KAFKA-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3234: --- Fix Version/s: (was: 0.10.2.0) > Minor documentation edits: clarify minISR; some topic-level confi

[jira] [Updated] (KAFKA-3203) Add UnknownCodecException and UnknownMagicByteException to error mapping

[ https://issues.apache.org/jira/browse/KAFKA-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3203: --- Fix Version/s: (was: 0.10.2.0) > Add UnknownCodecException and UnknownMagicByteException to error

[jira] [Updated] (KAFKA-3203) Add UnknownCodecException and UnknownMagicByteException to error mapping

[ https://issues.apache.org/jira/browse/KAFKA-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3203: --- Fix Version/s: 0.10.3.0 > Add UnknownCodecException and UnknownMagicByteException to error mapping > -

[jira] [Updated] (KAFKA-3155) Transient Failure in kafka.api.PlaintextProducerSendTest.testFlush

[ https://issues.apache.org/jira/browse/KAFKA-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3155: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Transient Failure in kafka.api.Plaint

[jira] [Updated] (KAFKA-1923) Negative offsets in replication-offset-checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1923: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Negative offsets in replication-offse

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

[ https://issues.apache.org/jira/browse/KAFKA-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4487: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Tests should be run in Jenkins with I

[jira] [Commented] (KAFKA-1923) Negative offsets in replication-offset-checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838086#comment-15838086 ] Ismael Juma commented on KAFKA-1923: [~ewencp], moved to 0.10.3.0 since we don't know

[jira] [Commented] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838184#comment-15838184 ] Jason Gustafson commented on KAFKA-4631: Perhaps it is not critical since we got K

Build failed in Jenkins: kafka-0.10.2-jdk7 #35

See Changes: [harsha] KAFKA-2000; Delete topic should also delete consumer offsets. -- [...truncated 4121 lines...] kafka.coordinator.GroupMetadataTest > testAwaitingSyncToPreparingRebalanceTra

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838245#comment-15838245 ] Matthias J. Sax commented on KAFKA-4691: I am not sure, if we can fix this soon. T

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

[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838302#comment-15838302 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipien

[jira] [Commented] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838318#comment-15838318 ] Matthias J. Sax commented on KAFKA-4222: We merged couple of bug fixes the last tw

[jira] [Resolved] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4222. Resolution: Fixed > Transient failure in QueryableStateIntegrationTest.queryOnRebalance > --

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

[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838320#comment-15838320 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipien

[jira] [Commented] (KAFKA-4474) Poor kafka-streams throughput

[ https://issues.apache.org/jira/browse/KAFKA-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838343#comment-15838343 ] Eno Thereska commented on KAFKA-4474: - Thanks [~agomez] I'll have a look shortly. > P

[GitHub] kafka pull request #2432: KAFKA-3502: KStreamTestDriver needs to be closed a...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2432 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

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

[jira] [Commented] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838408#comment-15838408 ] Matthias J. Sax commented on KAFKA-4631: Yes. KAFKA-4633 did fix the critical prob

Re: [DISCUSS]- JIRA ISSUE KAFKA-4566 : Can't Symlink to Kafka bins

Thanks for looking at this, Akhilesh. Can you be a little bit clearer about why keeping all the scripts or script symlinks in the same directory is not an option for you? best, Colin On Tue, Jan 24, 2017, at 06:01, Akhilesh Naidu wrote: > Hi, > > > The bug deals with the problem

Re: [DISCUSS] KIP-112: Handle disk failure for JBOD

Hi Dong, Thanks for the writeup! It's very interesting. I apologize in advance if this has been discussed somewhere else. But I am curious if you have considered the solution of running multiple brokers per node. Clearly there is a memory overhead with this solution because of the fixed cost o

[jira] [Commented] (KAFKA-4566) Can't Symlink to Kafka bins

[ https://issues.apache.org/jira/browse/KAFKA-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838425#comment-15838425 ] Colin P. McCabe commented on KAFKA-4566: That is quite a lot of code to add to eve

[jira] [Updated] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4631: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Refresh consumer metadata mor

[GitHub] kafka pull request #2398: HOTFIX: KIP-104 for code freeze

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2398 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Updated] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4631: --- Component/s: consumer > Refresh consumer metadata more frequently for unknown subscribed topic

Build failed in Jenkins: kafka-0.10.2-jdk7 #36

See Changes: [wangguoz] KAFKA-3502: KStreamTestDriver needs to be closed after the test case [wangguoz] HOTFIX: KIP-104 follow-up: remove duplicated per-processor-node -- [...truncated 4124 line

[jira] [Created] (KAFKA-4697) Simplify Streams Reset Tool

Matthias J. Sax created KAFKA-4697: -- Summary: Simplify Streams Reset Tool Key: KAFKA-4697 URL: https://issues.apache.org/jira/browse/KAFKA-4697 Project: Kafka Issue Type: Bug Compo

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838538#comment-15838538 ] Francesco Lemma commented on KAFKA-4691: Thanks for commenting Matthias. The fact

[jira] [Comment Edited] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838538#comment-15838538 ] Francesco Lemma edited comment on KAFKA-4691 at 1/25/17 8:45 PM: ---

Build failed in Jenkins: kafka-trunk-jdk7 #1878

See Changes: [wangguoz] KAFKA-3502: KStreamTestDriver needs to be closed after the test case [wangguoz] HOTFIX: KIP-104 follow-up: remove duplicated per-processor-node -- [...truncated 4127 lin

[jira] [Comment Edited] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838538#comment-15838538 ] Francesco Lemma edited comment on KAFKA-4691 at 1/25/17 8:46 PM: ---

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838558#comment-15838558 ] Matthias J. Sax commented on KAFKA-4691: Sorry for not being precise enough. For {

[jira] [Comment Edited] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838558#comment-15838558 ] Matthias J. Sax edited comment on KAFKA-4691 at 1/25/17 8:55 PM: ---

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838565#comment-15838565 ] Matthias J. Sax commented on KAFKA-4691: Btw: we got "dynamic routing" (ie, comput

Reg: Kafka ACLS

Hi, I have a question, can we use Kafka ACL's with only SASL/PLAIN mechanism. Because after I enabled, still I am able to produce/consume from topics. And one more observation is in kafka-_jaas.conf, there is no client section, will get an WARN as below, as we dont have this kind of mechanisim wit

Jenkins build is back to normal : kafka-trunk-jdk8 #1215

See

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838619#comment-15838619 ] Francesco Lemma commented on KAFKA-4691: Thanks Matthias. I perfectly understand w

Re: [DISCUSS] KIP-112: Handle disk failure for JBOD

Hey Colin, Good point! Yeah we have actually considered and tested this solution, which we call one-broker-per-disk. It would work and should require no major change in Kafka as compared to this JBOD KIP. So it would be a good short term solution. But it has a few drawbacks which makes it less de

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838657#comment-15838657 ] Francesco Lemma commented on KAFKA-4691: [~mjsax] This issue is not related to dyn

[jira] [Comment Edited] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838657#comment-15838657 ] Francesco Lemma edited comment on KAFKA-4691 at 1/25/17 9:56 PM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838724#comment-15838724 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipien

[jira] [Created] (KAFKA-4698) `-target:jvm-1.7` in scalaCompileOptions seems to cause java.lang.VerifyError when loading kafka/client/ClientUtils

Chris Heisterkamp created KAFKA-4698: Summary: `-target:jvm-1.7` in scalaCompileOptions seems to cause java.lang.VerifyError when loading kafka/client/ClientUtils Key: KAFKA-4698 URL: https://issues.apache.or

[jira] [Updated] (KAFKA-4698) `-target:jvm-1.7` in scalaCompileOptions seems to cause java.lang.VerifyError when loading kafka/client/ClientUtils

[ https://issues.apache.org/jira/browse/KAFKA-4698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Heisterkamp updated KAFKA-4698: - Description: When we updated to kafka 2.11-0.10.1.1 from 2.11-0.8.2.2 we started getting t

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

[ https://issues.apache.org/jira/browse/KAFKA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838740#comment-15838740 ] postmas...@inn.ru commented on KAFKA-1207: -- Delivery is delayed to these recipien

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838744#comment-15838744 ] Matthias J. Sax commented on KAFKA-4691: I see. Understood now. Seems to be a fair

[jira] [Assigned] (KAFKA-4698) `-target:jvm-1.7` in scalaCompileOptions seems to cause java.lang.VerifyError when loading kafka/client/ClientUtils

[ https://issues.apache.org/jira/browse/KAFKA-4698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-4698: -- Assignee: Ismael Juma > `-target:jvm-1.7` in scalaCompileOptions seems to cause java.lang.Verif

[jira] [Updated] (KAFKA-4698) `-target:jvm-1.7` in scalaCompileOptions seems to cause java.lang.VerifyError when loading kafka/client/ClientUtils

[ https://issues.apache.org/jira/browse/KAFKA-4698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4698: --- Fix Version/s: 0.10.2.0 > `-target:jvm-1.7` in scalaCompileOptions seems to cause java.lang.VerifyErro

Build failed in Jenkins: kafka-trunk-jdk8 #1216

See Changes: [wangguoz] KAFKA-3502: KStreamTestDriver needs to be closed after the test case [wangguoz] HOTFIX: KIP-104 follow-up: remove duplicated per-processor-node -- [...truncated 8440 lin

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15838829#comment-15838829 ] Anna Povzner commented on KAFKA-4691: - I agree with [~mjsax] about not changing KafkaP

  1   2   >