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

See Changes: [wangguoz] KAFKA-4317: Checkpoint state stores on commit interval -- [...truncated 158.83 KB...] kafka.server.KafkaConfigTest > testUncleanLeaderElectionDefau

[jira] [Created] (KAFKA-5221) Kafka Consumer Attached to partition but not consuming messages

Abhimanyu Nagrath created KAFKA-5221: Summary: Kafka Consumer Attached to partition but not consuming messages Key: KAFKA-5221 URL: https://issues.apache.org/jira/browse/KAFKA-5221 Project: Kafka

[jira] [Created] (KAFKA-5222) Kafka Connection error in contoller.logs

Abhimanyu Nagrath created KAFKA-5222: Summary: Kafka Connection error in contoller.logs Key: KAFKA-5222 URL: https://issues.apache.org/jira/browse/KAFKA-5222 Project: Kafka Issue Type: Bu

[jira] [Commented] (KAFKA-5222) Kafka Connection error in contoller.logs

[ https://issues.apache.org/jira/browse/KAFKA-5222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007742#comment-16007742 ] huxi commented on KAFKA-5222: - Did you set `broker.id` in server.properties? I wonder where th

[jira] [Commented] (KAFKA-5221) Kafka Consumer Attached to partition but not consuming messages

[ https://issues.apache.org/jira/browse/KAFKA-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007746#comment-16007746 ] huxi commented on KAFKA-5221: - Do you mean all these 38,000 partitions reside on a single brok

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

See Changes: [wangguoz] KAFKA-4881: add internal.leave.group.config to consumer -- [...truncated 158.35 KB...] kafka.server.KafkaConfigTest > testUncleanLeaderElectionDefa

[GitHub] kafka pull request #3030: MINOR: Improve shutdown sequence

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3030 MINOR: Improve shutdown sequence You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka improve-shutdown-sequence Alternatively you can revi

[jira] [Updated] (KAFKA-5221) Kafka Consumer Attached to partition but not consuming messages

[ https://issues.apache.org/jira/browse/KAFKA-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhimanyu Nagrath updated KAFKA-5221: - Description: I have a single node Kafka broker and a single zookeeper (3.4.9). I am using

[jira] [Commented] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007757#comment-16007757 ] huxi commented on KAFKA-5200: - Alternatively, you could start up that broker before the deleti

[jira] [Updated] (KAFKA-5221) Kafka Consumer Attached to partition but not consuming messages

[ https://issues.apache.org/jira/browse/KAFKA-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhimanyu Nagrath updated KAFKA-5221: - Description: I have a single node Kafka broker and a single zookeeper (3.4.9). I am using

[jira] [Commented] (KAFKA-5221) Kafka Consumer Attached to partition but not consuming messages

[ https://issues.apache.org/jira/browse/KAFKA-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007759#comment-16007759 ] Abhimanyu Nagrath commented on KAFKA-5221: -- Hi [~huxi_2b] there was some typo I h

[jira] [Commented] (KAFKA-5222) Kafka Connection error in contoller.logs

[ https://issues.apache.org/jira/browse/KAFKA-5222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007763#comment-16007763 ] Abhimanyu Nagrath commented on KAFKA-5222: -- [~huxi_2b] - yes I have set broker.id

[jira] [Commented] (KAFKA-5221) Kafka Consumer Attached to partition but not consuming messages

[ https://issues.apache.org/jira/browse/KAFKA-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007766#comment-16007766 ] huxi commented on KAFKA-5221: - [~manyu_aditya] How many partitions are subscribed by the consu

[jira] [Commented] (KAFKA-5222) Kafka Connection error in contoller.logs

[ https://issues.apache.org/jira/browse/KAFKA-5222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007770#comment-16007770 ] huxi commented on KAFKA-5222: - You sure you see it when the broker is running instead of being

[jira] [Commented] (KAFKA-5222) Kafka Connection error in contoller.logs

[ https://issues.apache.org/jira/browse/KAFKA-5222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007775#comment-16007775 ] Abhimanyu Nagrath commented on KAFKA-5222: -- Yes, I can see Kafka running on my br

[jira] [Commented] (KAFKA-5221) Kafka Consumer Attached to partition but not consuming messages

[ https://issues.apache.org/jira/browse/KAFKA-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007783#comment-16007783 ] Abhimanyu Nagrath commented on KAFKA-5221: -- [~huxi_2b] that consumer instance is

[GitHub] kafka pull request #3025: KAFKA-4881: add internal.leave.group.config to con...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/3025 --- 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 enable

[GitHub] kafka pull request #3024: KAFKA-4317: Checkpoint state stores on commit inte...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/3024 --- 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 enable

[jira] [Commented] (KAFKA-4317) RocksDB checkpoint files lost on kill -9

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

[jira] [Commented] (KAFKA-4881) Add internal leave.group.on.close config to consumer

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

[GitHub] kafka pull request #3031: MINOR: Fix bug in `waitUntilLeaderIsElectedOrChang...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3031 MINOR: Fix bug in `waitUntilLeaderIsElectedOrChanged` and simplify result type Also disable a couple of tests that were passing incorrectly until KAFKA-3096 is fixed. The bug was for the fol

[jira] [Commented] (KAFKA-3096) Leader is not set to -1 when it is shutdown if followers are down

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

[jira] [Commented] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007893#comment-16007893 ] Edoardo Comar commented on KAFKA-5200: -- [~huxi_2b] if we could restart the broker tha

[jira] [Created] (KAFKA-5223) Add Python support to Kafka Streams

holdenk created KAFKA-5223: -- Summary: Add Python support to Kafka Streams Key: KAFKA-5223 URL: https://issues.apache.org/jira/browse/KAFKA-5223 Project: Kafka Issue Type: Improvement Compo

[jira] [Created] (KAFKA-5224) Support for super basic map-only kafka streams

holdenk created KAFKA-5224: -- Summary: Support for super basic map-only kafka streams Key: KAFKA-5224 URL: https://issues.apache.org/jira/browse/KAFKA-5224 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request #3032: KAFKA-4965: set internal.leave.group.on.close to f...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3032 KAFKA-4965: set internal.leave.group.on.close to false in StreamsConfig Backport from trunk You can merge this pull request into a Git repository by running: $ git pull https://github.com/dguy/ka

[jira] [Commented] (KAFKA-4965) set internal.leave.group.on.close to false in KafkaStreams

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

[jira] [Updated] (KAFKA-5194) KIP-153: Include only client traffic in BytesOutPerSec metric

[ https://issues.apache.org/jira/browse/KAFKA-5194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5194: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 3003

[GitHub] kafka pull request #3003: KAFKA-5194: KIP-153: Include only client traffic i...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3003 --- 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-5194) KIP-153: Include only client traffic in BytesOutPerSec metric

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

[jira] [Commented] (KAFKA-3995) Add a new configuration "enable.compression.ratio.estimation" to the producer config

[ https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008023#comment-16008023 ] Ismael Juma commented on KAFKA-3995: Can we update the title of the JIRA, please? > A

[jira] [Updated] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4982: --- Status: Patch Available (was: Open) > Add listener tag to socket-server-metrics.connection-... metric

[GitHub] kafka pull request #2847: MINOR: update num.x.threads server.properties comm...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2847 --- 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-4982) Add listener tag to socket-server-metrics.connection-... metrics (KIP-136)

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4982: --- Summary: Add listener tag to socket-server-metrics.connection-... metrics (KIP-136) (was: Add listene

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

See Changes: [ismael] KAFKA-5194; Include only client traffic in BytesOutPerSec metric -- [...truncated 847.12 KB...] kafka.server.ReplicaFetcherThreadTest > shouldMovePa

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

See Changes: [ismael] KAFKA-5194; Include only client traffic in BytesOutPerSec metric -- [...truncated 846.17 KB...] kafka.api.SslConsumerTest > testSimpleConsumption PAS

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

See Changes: [ismael] MINOR: Improve doc for num.x.threads configs -- [...truncated 846.62 KB...] kafka.server.ReplicaFetcherThreadTest > shouldMovePartitionsOutOfTruncat

[jira] [Commented] (KAFKA-4195) support throttling on request rate

[ https://issues.apache.org/jira/browse/KAFKA-4195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008136#comment-16008136 ] Rajini Sivaram commented on KAFKA-4195: --- [~junrao] I will submit PRs for both by Mon

Jenkins build is back to normal : kafka-trunk-jdk7 #2174

See

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008147#comment-16008147 ] Joseph Aliase commented on KAFKA-5007: -- [~junrao] Any thoughts on the files related t

[jira] [Comment Edited] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008147#comment-16008147 ] Joseph Aliase edited comment on KAFKA-5007 at 5/12/17 1:51 PM: -

[GitHub] kafka pull request #3033: MINOR: Set min isr to avoid race condition in Repl...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3033 MINOR: Set min isr to avoid race condition in ReplicationBytesIn initialisation You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka fix-

[GitHub] kafka pull request #3034: MINOR: Fixed testBrokerTopicMetricsBytesInOut fail...

GitHub user mimaison opened a pull request: https://github.com/apache/kafka/pull/3034 MINOR: Fixed testBrokerTopicMetricsBytesInOut failures We've had to tweak the other tests to make them pass. `testBrokerTopicMetricsUnregisteredAfterDeletingTopic` seemed completely broke

[jira] [Created] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties

Dustin Cote created KAFKA-5225: -- Summary: StreamsResetter doesn't allow custom Consumer properties Key: KAFKA-5225 URL: https://issues.apache.org/jira/browse/KAFKA-5225 Project: Kafka Issue Type

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

[ https://issues.apache.org/jira/browse/KAFKA-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Daga reassigned KAFKA-4479: Assignee: (was: Amit Daga) > Streams tests should pass without hardcoded Time.SYSTEM in GroupCo

[GitHub] kafka pull request #3033: MINOR: Set min isr to avoid race condition in Repl...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3033 --- 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

synchronous request response using kafka

Can someone please share some thoughts whether we can do synchronous call (request response) using kafka similar to JMS Thanks Sanjay 913-221-9164

Re: [VOTE] KIP-155 Add range scan for windowed state stores

Thanks for the note Michael, I think it makes sense. And thinking about it more, I also agree that even for single-key fetch on ReadOnlyWindow/SessionStore it's better to return the Iterator, V> even when the windowed key's key field would always be the same, as it is more consistent with the adde

[jira] [Resolved] (KAFKA-5220) Application Reset Tool does not work with SASL

[ https://issues.apache.org/jira/browse/KAFKA-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5220. Resolution: Duplicate > Application Reset Tool does not work with SASL > ---

[jira] [Assigned] (KAFKA-5220) Application Reset Tool does not work with SASL

[ https://issues.apache.org/jira/browse/KAFKA-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham reassigned KAFKA-5220: - Assignee: Bharat Viswanadham > Application Reset Tool does not work with SASL > -

[jira] [Assigned] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties

[ https://issues.apache.org/jira/browse/KAFKA-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham reassigned KAFKA-5225: - Assignee: Bharat Viswanadham > StreamsResetter doesn't allow custom Consumer prop

[jira] [Commented] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties

[ https://issues.apache.org/jira/browse/KAFKA-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008338#comment-16008338 ] Bharat Viswanadham commented on KAFKA-5225: --- Matthias will contribute to this Ji

[jira] [Updated] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ian Springer updated KAFKA-5226: Description: I saw the following NPE in our Kafka Streams app, which has 3 nodes running on 3 separ

[jira] [Created] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

Ian Springer created KAFKA-5226: --- Summary: NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize Key: KAFKA-5226 URL: https://issues.apache.org/jira/browse/KAFKA-5226 Project: Kafka

[jira] [Assigned] (KAFKA-5220) Application Reset Tool does not work with SASL

[ https://issues.apache.org/jira/browse/KAFKA-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham reassigned KAFKA-5220: - Assignee: (was: Bharat Viswanadham) > Application Reset Tool does not work wi

[GitHub] kafka pull request #3035: DOC: clarifications on message committed to the lo...

GitHub user edoardocomar opened a pull request: https://github.com/apache/kafka/pull/3035 DOC: clarifications on message committed to the log based on conversations with @vahidhashemian @rajinisivaram @apurvam The docs didn't make clear that what gets committed and what get

[jira] [Comment Edited] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties

[ https://issues.apache.org/jira/browse/KAFKA-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008338#comment-16008338 ] Bharat Viswanadham edited comment on KAFKA-5225 at 5/12/17 4:39 PM:

[jira] [Updated] (KAFKA-3995) Split the ProducerBatch and resend when received RecordTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3995: Summary: Split the ProducerBatch and resend when received RecordTooLargeException (was: Add a new c

[jira] [Commented] (KAFKA-5204) Connect needs to validate Connector type during instantiation

[ https://issues.apache.org/jira/browse/KAFKA-5204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008389#comment-16008389 ] Ewen Cheslack-Postava commented on KAFKA-5204: -- Note that if we enforce this

[jira] [Updated] (KAFKA-5211) KafkaConsumer should not skip a corrupted record after throwing an exception.

[ https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-5211: Fix Version/s: 0.11.0.0 > KafkaConsumer should not skip a corrupted record after throwing an excepti

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

See Changes: [ismael] MINOR: Set min isr to avoid race condition in ReplicationBytesIn -- [...truncated 1.79 MB...] org.apache.kafka.connect.runtime.WorkerConnectorTest >

[jira] [Commented] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008427#comment-16008427 ] Matthias J. Sax commented on KAFKA-5226: [~ian.springer] Thanks for reporting this

[jira] [Updated] (KAFKA-5132) Abort long running transactions

[ https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5132: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch Available

[jira] [Commented] (KAFKA-5132) Abort long running transactions

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

[GitHub] kafka pull request #2957: KAFKA-5132: abort long running transactions

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2957 --- 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

[GitHub] kafka pull request #2937: MINOR: Fix consumer and producer to actually suppo...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2937 --- 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-3514) Stream timestamp computation needs some further thoughts

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008459#comment-16008459 ] Matthias J. Sax commented on KAFKA-3514: This JIRA also relates to this user quest

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

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3514: --- Description: Our current stream task's timestamp is used for punctuate function as well as se

[GitHub] kafka pull request #3036: KAFKA-3356: Remove ConsumerOffsetChecker

GitHub user mimaison opened a pull request: https://github.com/apache/kafka/pull/3036 KAFKA-3356: Remove ConsumerOffsetChecker You can merge this pull request into a Git repository by running: $ git pull https://github.com/mimaison/kafka KAFKA-3356 Alternatively you can revie

[jira] [Commented] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11

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

[jira] [Assigned] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11

[ https://issues.apache.org/jira/browse/KAFKA-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-3356: - Assignee: Mickael Maison (was: Ashish Singh) > Remove ConsumerOffsetChecker, deprecated

[jira] [Work started] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11

[ https://issues.apache.org/jira/browse/KAFKA-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3356 started by Mickael Maison. - > Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11 > --

[GitHub] kafka pull request #2236: KAFKA-4517: Remove deprecated shell script

Github user jeffwidman closed the pull request at: https://github.com/apache/kafka/pull/2236 --- 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

[jira] [Commented] (KAFKA-4517) Remove kafka-consumer-offset-checker.sh script since already deprecated in Kafka 9

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

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

See

[jira] [Commented] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics (KIP-136)

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008499#comment-16008499 ] Edoardo Comar commented on KAFKA-4982: -- Thanks [~ijuma] following the discussion in t

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

See Changes: [wangguoz] KAFKA-5132: abort long running transactions -- [...truncated 850.79 KB...] kafka.controller.ControllerIntegrationTest > testPartitionReassignment

[jira] [Commented] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics (KIP-136)

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008535#comment-16008535 ] Ismael Juma commented on KAFKA-4982: Thanks! Can you please send an update to the KIP

[jira] [Commented] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008543#comment-16008543 ] Ian Springer commented on KAFKA-5226: - The key data type is a String (UUID), and the v

[jira] [Resolved] (KAFKA-5196) LogCleaner should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-5196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5196. Resolution: Fixed Issue resolved by pull request 3008 [https://github.com/apache/kafka/pull/

[GitHub] kafka pull request #3008: KAFKA-5196: Make LogCleaner transaction-aware

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3008 --- 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-5196) LogCleaner should be transaction-aware

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

[jira] [Created] (KAFKA-5227) SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

Xavier Léauté created KAFKA-5227: Summary: SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe Key: KAFKA-5227 URL: https://issues.apache.org/jira/browse/KAFKA-5227 Proje

KafkaStreams reports RUNNING even though all StreamThreads has crashed

Hi All, We recently implemented a health check for a Kafka Streams based application. The health check is simply checking the state of Kafka Streams by calling KafkaStreams.state(). It reports healthy if it’s not in PENDING_SHUTDOWN or NOT_RUNNING states. We truly appreciate having the possib

Jenkins build is back to normal : kafka-trunk-jdk7 #2177

See

[jira] [Commented] (KAFKA-3995) Split the ProducerBatch and resend when received RecordTooLargeException

[ https://issues.apache.org/jira/browse/KAFKA-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008634#comment-16008634 ] Jiangjie Qin commented on KAFKA-3995: - [~ijuma] done. > Split the ProducerBatch and r

[jira] [Work started] (KAFKA-5211) KafkaConsumer should not skip a corrupted record after throwing an exception.

[ https://issues.apache.org/jira/browse/KAFKA-5211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5211 started by Jiangjie Qin. --- > KafkaConsumer should not skip a corrupted record after throwing an exception. > -

[jira] [Commented] (KAFKA-5227) SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

[ https://issues.apache.org/jira/browse/KAFKA-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008635#comment-16008635 ] Rajini Sivaram commented on KAFKA-5227: --- [~xvrl] Was this failure on a PR that was a

[jira] [Work started] (KAFKA-5186) Avoid expensive initialization of producer state when upgrading

[ https://issues.apache.org/jira/browse/KAFKA-5186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5186 started by Jason Gustafson. -- > Avoid expensive initialization of producer state when upgrading > -

[jira] [Commented] (KAFKA-5227) SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

[ https://issues.apache.org/jira/browse/KAFKA-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008641#comment-16008641 ] Xavier Léauté commented on KAFKA-5227: -- [~rsivaram] this happened here https://build

Re: synchronous request response using kafka

Hi Sanjay, Can you be a little clearer what you are trying to achieve? If you want to build an RPC system where one entity makes a remote procedure call to another, you might consider using something like CORBA, Apache Thrift, gRPC, etc. best, Colin On Fri, May 12, 2017, at 07:55, Banerjee, Sa

[jira] [Created] (KAFKA-5228) Revisit Streams DSL JavaDocs

Matthias J. Sax created KAFKA-5228: -- Summary: Revisit Streams DSL JavaDocs Key: KAFKA-5228 URL: https://issues.apache.org/jira/browse/KAFKA-5228 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008699#comment-16008699 ] Colin P. McCabe commented on KAFKA-5007: {code} java 24739 cyclone 1216u unix 0xf

[jira] [Commented] (KAFKA-5226) NullPointerException (NPE) in SourceNodeRecordDeserializer.deserialize

[ https://issues.apache.org/jira/browse/KAFKA-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008704#comment-16008704 ] Matthias J. Sax commented on KAFKA-5226: Thanks for sharing. The loc raising the e

[jira] [Resolved] (KAFKA-5130) Change InterBrokerSendThread to use a Queue per broker

[ https://issues.apache.org/jira/browse/KAFKA-5130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5130. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2964 [https://gi

[GitHub] kafka pull request #2964: KAFKA-5130: Refactor TC In-memory Cache

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2964 --- 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] [Assigned] (KAFKA-5130) Change InterBrokerSendThread to use a Queue per broker

[ https://issues.apache.org/jira/browse/KAFKA-5130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5130: Assignee: Guozhang Wang > Change InterBrokerSendThread to use a Queue per broker >

[jira] [Commented] (KAFKA-5130) Change InterBrokerSendThread to use a Queue per broker

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

[jira] [Created] (KAFKA-5229) Reflections logs excessive warnings when scanning classpaths

Ewen Cheslack-Postava created KAFKA-5229: Summary: Reflections logs excessive warnings when scanning classpaths Key: KAFKA-5229 URL: https://issues.apache.org/jira/browse/KAFKA-5229 Project: K

[jira] [Work started] (KAFKA-5214) KafkaAdminClient#apiVersions should return a public class

[ https://issues.apache.org/jira/browse/KAFKA-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5214 started by Colin P. McCabe. -- > KafkaAdminClient#apiVersions should return a public class > ---

  1   2   >