Jenkins build is back to normal : kafka-0.10.2-jdk7 #158

See

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

See

[jira] [Updated] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5167: - Resolution: Fixed Fix Version/s: 0.11.0.0 0.10.2.2 Status: Res

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009155#comment-16009155 ] Guozhang Wang commented on KAFKA-5167: -- Merged https://github.com/apache/kafka/pull/3

[GitHub] kafka pull request #3040: MINOR: Some minor improvements to TxnOffsetCommit ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3040 MINOR: Some minor improvements to TxnOffsetCommit handling You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka txn-offset-commit-c

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

See Changes: [jason] MINOR: Rename InitPidRequest/InitPidResponse to -- [...truncated 1.66 MB...] org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > s

[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=16009132#comment-16009132 ] ASF GitHub Bot commented on KAFKA-4144: --- Github user asfgit closed the pull request

[GitHub] kafka pull request #2466: KAFKA-4144: Allow per stream/table timestamp extra...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2466 --- 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-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4144: - Status: Resolved (was: Patch Available) Issue resolved by pull request 2466 [https://github.com/a

[jira] [Created] (KAFKA-5231) TransactinoCoordinator does not bump epoch when aborting open transactions

Apurva Mehta created KAFKA-5231: --- Summary: TransactinoCoordinator does not bump epoch when aborting open transactions Key: KAFKA-5231 URL: https://issues.apache.org/jira/browse/KAFKA-5231 Project: Kafka

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

See

[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=16009080#comment-16009080 ] Matthias J. Sax commented on KAFKA-5226: I see your point, however, it's unclear t

[GitHub] kafka pull request #2997: MINOR: Rename InitPidRequest/InitPidResponse to In...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2997 --- 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-5166) Add option "dry run" to Streams application reset tool

[ https://issues.apache.org/jira/browse/KAFKA-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham updated KAFKA-5166: -- Status: Patch Available (was: In Progress) > Add option "dry run" to Streams applicatio

[GitHub] kafka pull request #3038: KAFKA-5180: fix transient failure in ControllerInt...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3038 --- 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-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=16009056#comment-16009056 ] Joseph Aliase commented on KAFKA-5007: -- [~cuiyang] I have replicated this issue in al

[jira] [Updated] (KAFKA-5180) Transient failure: ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch

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

[jira] [Commented] (KAFKA-5180) Transient failure: ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch

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

[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: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 3004

[GitHub] kafka pull request #3039: MINOR: Close ZooKeeper clients in tests

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3039 MINOR: Close ZooKeeper clients in tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka MINOR-close-zkclient Alternat

[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=16009052#comment-16009052 ] Joseph Aliase commented on KAFKA-5007: -- [~cuiyang] you are referring to open file des

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

See Changes: [wangguoz] KAFKA-4965: set internal.leave.group.on.close to false in StreamsConfig [wangguoz] KAFKA-5198: Synchronize on RocksDbStore#openIterators since it is

[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=16009040#comment-16009040 ] cuiyang commented on KAFKA-5007: @Joseph Aliase Could you give the command which you used

[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=16009039#comment-16009039 ] cuiyang commented on KAFKA-5007: [~joseph.alias...@gmail.com] [~junrao] we also encounter

[GitHub] kafka pull request #3004: KAFKA-4982: add listener tags to socket-server-met...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3004 --- 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-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=16009035#comment-16009035 ] ASF GitHub Bot commented on KAFKA-4982: --- Github user asfgit closed the pull request

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

See

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

See Changes: [wangguoz] KAFKA-5216: Fix peekNextKey in cached window/session store iterators [jason] KAFKA-5160; KIP-98 Broker side support for TxnOffsetCommitRequest [wangguoz] KAFKA-5198: Synchronize on Rocks

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

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

[GitHub] kafka pull request #3037: KAFKA-5227: Remove unsafe assertion, make jaas con...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3037 --- 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] [Resolved] (KAFKA-5227) SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe

[ https://issues.apache.org/jira/browse/KAFKA-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5227. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 3037 [https://github

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

See Changes: [wangguoz] KAFKA-5216: Fix peekNextKey in cached window/session store iterators -- [...truncated 158.85 KB...] kafka.server.KafkaConfigTest > testUncleanLeade

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

See Changes: [jason] KAFKA-5160; KIP-98 Broker side support for TxnOffsetCommitRequest -- [...truncated 858.84 KB...] kafka.log.BrokerCompressionTest > testBrokerSideComp

[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=16008959#comment-16008959 ] Joseph Aliase commented on KAFKA-5007: -- [~cmccabe] PID: 24739 is Kafka process. Let

[jira] [Resolved] (KAFKA-5198) RocksDbStore#openIterators should be synchronized, since it is accessed from multiple threads

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

[jira] [Commented] (KAFKA-5198) RocksDbStore#openIterators should be synchronized, since it is accessed from multiple threads

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

[jira] [Updated] (KAFKA-5180) Transient failure: ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch

[ https://issues.apache.org/jira/browse/KAFKA-5180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5180: Status: Patch Available (was: In Progress) > Transient failure: > ControllerIntegrationTest.testCo

[jira] [Work started] (KAFKA-5180) Transient failure: ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch

[ https://issues.apache.org/jira/browse/KAFKA-5180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5180 started by Onur Karaman. --- > Transient failure: > ControllerIntegrationTest.testControllerMoveIncrementsContr

[GitHub] kafka pull request #3000: KAFKA-5198. RocksDbStore#openIterators should be s...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3000 --- 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-5180) Transient failure: ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch

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

[GitHub] kafka pull request #3038: KAFKA-5180: fix transient failure in ControllerInt...

GitHub user onurkaraman opened a pull request: https://github.com/apache/kafka/pull/3038 KAFKA-5180: fix transient failure in ControllerIntegrationTest.testControllerMoveIncrementsControllerEpoch The tests previously ignored the fact that the controller does not atomically create t

[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=16008930#comment-16008930 ] Colin P. McCabe commented on KAFKA-5007: I tried running a kafka instance that cou

[GitHub] kafka pull request #2970: Kafka-5160; KIP-98 Broker side support for TxnOffs...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2970 --- 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] [Resolved] (KAFKA-5160) KIP-98 : broker side handling for the TxnOffsetCommitRequest

[ https://issues.apache.org/jira/browse/KAFKA-5160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5160. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2970 [https:

[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=16008885#comment-16008885 ] Ian Springer commented on KAFKA-5226: - That's not how I read the stack trace. If my co

Re: [DISCUSS] KIP-136: Add Listener name and Security Protocol name to SelectorMetrics tags

Thanks Ismael, following the discussion in the PR thread, I've updated the implementation to only use the listener tag and I've updated the KIP to match the implementation and describe the compatibility choice of not tagging the yammer metric. -- E

[jira] [Created] (KAFKA-5230) Recommended values for Connect transformations contain the wrong class name

Ewen Cheslack-Postava created KAFKA-5230: Summary: Recommended values for Connect transformations contain the wrong class name Key: KAFKA-5230 URL: https://issues.apache.org/jira/browse/KAFKA-5230

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

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

[GitHub] kafka pull request #3037: KAFKA-5227: Remove unsafe assertion, make jaas con...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3037 KAFKA-5227: Remove unsafe assertion, make jaas config safer You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka KAFKA-5227

[jira] [Commented] (KAFKA-5216) Cached Session/Window store may return error on iterator.peekNextKey()

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-5227: - Assignee: Rajini Sivaram > SaslScramSslEndToEndAuthorizationTest.testNoConsumeWithoutDesc

[GitHub] kafka pull request #3016: KAFKA-5216 fix error on peekNextKey in cached wind...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3016 --- 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-5216) Cached Session/Window store may return error on iterator.peekNextKey()

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

[jira] [Work started] (KAFKA-5215) Small JavaDoc fix for AdminClient#describeTopics

[ https://issues.apache.org/jira/browse/KAFKA-5215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5215 started by Colin P. McCabe. -- > Small JavaDoc fix for AdminClient#describeTopics >

[jira] [Work started] (KAFKA-5198) RocksDbStore#openIterators should be synchronized, since it is accessed from multiple threads

[ https://issues.apache.org/jira/browse/KAFKA-5198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5198 started by Colin P. McCabe. -- > RocksDbStore#openIterators should be synchronized, since it is accessed fro

[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 > ---

[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] [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] [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 >

[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] [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

[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] [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] [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

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] [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

[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=16008635#comment-16008635 ] Rajini Sivaram commented on KAFKA-5227: --- [~xvrl] Was this failure on a PR that was a

[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-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

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

See

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

[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

[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

[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] [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/

[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] [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

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=16008499#comment-16008499 ] Edoardo Comar commented on KAFKA-4982: -- Thanks [~ijuma] following the discussion in t

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

See

[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

[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] [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 > --

[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] [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:

[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] [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

[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

[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

[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

[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

[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-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

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] [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

[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-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] [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:

[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

  1   2   >