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:

[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=16009155#comment-16009155 ] Guozhang Wang commented on KAFKA-5167: -- Merged https://github.com/apache/kafka/pull/3001 to 0.10.2

[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

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 >

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

[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

[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

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

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

[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

[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

[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

[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=16009056#comment-16009056 ] Joseph Aliase commented on KAFKA-5007: -- [~cuiyang] I have replicated this issue in all version except

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

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

[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

[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

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

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

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

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

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

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

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

[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

[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

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 >

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 >

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

[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

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

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

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

[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

[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=16008940#comment-16008940 ] ASF GitHub Bot commented on KAFKA-5180: --- GitHub user onurkaraman opened a pull request:

[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

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

[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

[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

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

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

[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=16008850#comment-16008850 ] ASF GitHub Bot commented on KAFKA-5227: --- GitHub user rajinisivaram opened a 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 >

[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

[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

[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

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

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

[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

[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

[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=16008704#comment-16008704 ] Matthias J. Sax commented on KAFKA-5226: Thanks for sharing. The loc raising the exception is as

[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=16008699#comment-16008699 ] Colin P. McCabe commented on KAFKA-5007: {code} java 24739 cyclone 1216u unix 0x880035b35000

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

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

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

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

[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=16008634#comment-16008634 ] Jiangjie Qin commented on KAFKA-3995: - [~ijuma] done. > Split the ProducerBatch and resend when

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

[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

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

[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

[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

[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=16008543#comment-16008543 ] Ian Springer commented on KAFKA-5226: - The key data type is a String (UUID), and the value data type

[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=16008535#comment-16008535 ] Ismael Juma commented on KAFKA-4982: Thanks! Can you please send an update to the KIP thread as well?

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

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

See

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

[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=16008459#comment-16008459 ] Matthias J. Sax commented on KAFKA-3514: This JIRA also relates to this user question:

[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

[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

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

[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

[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=16008427#comment-16008427 ] Matthias J. Sax commented on KAFKA-5226: [~ian.springer] Thanks for reporting this. It's hard to

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

[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=16008389#comment-16008389 ] Ewen Cheslack-Postava commented on KAFKA-5204: -- Note that if we enforce this check more

[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

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

[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

[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

[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=16008338#comment-16008338 ] Bharat Viswanadham commented on KAFKA-5225: --- Matthias will contribute to this Jira. >

[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

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

  1   2   >