[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380730#comment-17380730 ] Ewen Cheslack-Postava commented on KAFKA-3539: -- [~moses.nakamura] I spent a

[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343043#comment-17343043 ] Ewen Cheslack-Postava commented on KAFKA-3539: -- [~mjsax] They aren't really

[jira] [Commented] (KAFKA-6009) Fix formatting of autogenerated docs tables

[ https://issues.apache.org/jira/browse/KAFKA-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305855#comment-17305855 ] Ewen Cheslack-Postava commented on KAFKA-6009: -- [~zacky] yes, of course. I'v

[jira] [Assigned] (KAFKA-6009) Fix formatting of autogenerated docs tables

[ https://issues.apache.org/jira/browse/KAFKA-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6009: Assignee: Takeshi Yamasaki > Fix formatting of autogenerated docs tables >

[jira] [Commented] (KAFKA-3988) KafkaConfigBackingStore assumes configs will be stored as schemaless maps

[ https://issues.apache.org/jira/browse/KAFKA-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294009#comment-17294009 ] Ewen Cheslack-Postava commented on KAFKA-3988: -- [~pachima...@gmail.com] It's

[jira] [Commented] (KAFKA-10380) Make dist flatten rocksdbjni

[ https://issues.apache.org/jira/browse/KAFKA-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181366#comment-17181366 ] Ewen Cheslack-Postava commented on KAFKA-10380: --- Probably the best solutio

[jira] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted

[ https://issues.apache.org/jira/browse/KAFKA-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177973#comment-17177973 ] Ewen Cheslack-Postava commented on KAFKA-5896: -- [~yazgoo] It looks like this

[jira] [Commented] (KAFKA-9774) Create official Docker image for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070633#comment-17070633 ] Ewen Cheslack-Postava commented on KAFKA-9774: -- My first reaction to this wa

[jira] [Commented] (KAFKA-9468) config.storage.topic partition count issue is hard to debug

[ https://issues.apache.org/jira/browse/KAFKA-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022513#comment-17022513 ] Ewen Cheslack-Postava commented on KAFKA-9468: -- [~rhauch] Allowing things to

[jira] [Closed] (KAFKA-5635) KIP-181 Kafka-Connect integrate with kafka ReST Proxy

[ https://issues.apache.org/jira/browse/KAFKA-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava closed KAFKA-5635. > KIP-181 Kafka-Connect integrate with kafka ReST Proxy > -

[jira] [Commented] (KAFKA-8586) Source task producers silently fail to send records

[ https://issues.apache.org/jira/browse/KAFKA-8586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870869#comment-16870869 ] Ewen Cheslack-Postava commented on KAFKA-8586: -- `recordSent` call could prob

[jira] [Closed] (KAFKA-4048) Connect does not support RetriableException consistently for sinks

[ https://issues.apache.org/jira/browse/KAFKA-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava closed KAFKA-4048. > Connect does not support RetriableException consistently for sinks >

[jira] [Commented] (KAFKA-8423) Update ducktape to not use deprecated APIs

[ https://issues.apache.org/jira/browse/KAFKA-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849908#comment-16849908 ] Ewen Cheslack-Postava commented on KAFKA-8423: -- [~htewari] The warning is ac

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794652#comment-16794652 ] Ewen Cheslack-Postava commented on KAFKA-2480: -- [~olkuznsmith] I see, you pr

[jira] [Resolved] (KAFKA-7813) JmxTool throws NPE when --object-name is omitted

[ https://issues.apache.org/jira/browse/KAFKA-7813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7813. -- Resolution: Fixed Fix Version/s: 2.3.0 Issue resolved by pull request 61

[jira] [Assigned] (KAFKA-7197) Release a milestone build for Scala 2.13.0 M3

[ https://issues.apache.org/jira/browse/KAFKA-7197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-7197: Assignee: Dejan Stojadinović > Release a milestone build for Scala 2.13.0

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794612#comment-16794612 ] Ewen Cheslack-Postava commented on KAFKA-2480: -- [~olkuznsmith] This doesn't

[jira] [Updated] (KAFKA-7834) Extend collected logs in system test services to include heap dumps

[ https://issues.apache.org/jira/browse/KAFKA-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-7834: - Fix Version/s: 2.1.2 > Extend collected logs in system test services to include h

[jira] [Resolved] (KAFKA-7834) Extend collected logs in system test services to include heap dumps

[ https://issues.apache.org/jira/browse/KAFKA-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7834. -- Resolution: Fixed Fix Version/s: (was: 1.1.2)

[jira] [Updated] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5117: - Fix Version/s: 2.0.2 2.1.1 2.2.0 > Kafka Co

[jira] [Resolved] (KAFKA-7461) Connect Values converter should have coverage of logical types

[ https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7461. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 60

[jira] [Resolved] (KAFKA-7503) Integration Test Framework for Connect

[ https://issues.apache.org/jira/browse/KAFKA-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7503. -- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1

[jira] [Resolved] (KAFKA-7551) Refactor to create both producer & consumer in Worker

[ https://issues.apache.org/jira/browse/KAFKA-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7551. -- Resolution: Fixed Merged [https://github.com/apache/kafka/pull/5842,] my bad fo

[jira] [Resolved] (KAFKA-7620) ConfigProvider is broken for KafkaConnect when TTL is not null

[ https://issues.apache.org/jira/browse/KAFKA-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7620. -- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1

[jira] [Resolved] (KAFKA-7560) PushHttpMetricsReporter should not convert metric value to double

[ https://issues.apache.org/jira/browse/KAFKA-7560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7560. -- Resolution: Fixed Fix Version/s: 2.1.0 2.2.0 Issue re

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16663144#comment-16663144 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~lindong] I think anything

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16662460#comment-16662460 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~lindong] we might just wan

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16659935#comment-16659935 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~ijuma] As it stands today,

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658580#comment-16658580 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~ijuma] Arguably your sugge

[jira] [Resolved] (KAFKA-6490) JSON SerializationException Stops Connect

[ https://issues.apache.org/jira/browse/KAFKA-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6490. -- Resolution: Fixed Fix Version/s: 2.0.0 Closing as this is effectively fi

[jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16655830#comment-16655830 ] Ewen Cheslack-Postava commented on KAFKA-7510: -- [~mjsax] We should be consis

[jira] [Resolved] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5117. -- Resolution: Duplicate Assignee: Ewen Cheslack-Postava Fix Versio

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16640116#comment-16640116 ] Ewen Cheslack-Postava commented on KAFKA-5117: -- Going to close this since  [

[jira] [Commented] (KAFKA-7461) Connect Values converter should have coverage of logical types

[ https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16640101#comment-16640101 ] Ewen Cheslack-Postava commented on KAFKA-7461: -- [~ritabrata1808] I didn't lo

[jira] [Resolved] (KAFKA-7476) SchemaProjector is not properly handling Date-based logical types

[ https://issues.apache.org/jira/browse/KAFKA-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7476. -- Resolution: Fixed Fix Version/s: 2.1.0 0.10.2.3

[jira] [Resolved] (KAFKA-7460) Connect Values converter uses incorrect date format string

[ https://issues.apache.org/jira/browse/KAFKA-7460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7460. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1

[jira] [Created] (KAFKA-7461) Connect Values converter should have coverage of logical types

Ewen Cheslack-Postava created KAFKA-7461: Summary: Connect Values converter should have coverage of logical types Key: KAFKA-7461 URL: https://issues.apache.org/jira/browse/KAFKA-7461 Project:

[jira] [Created] (KAFKA-7460) Connect Values converter uses incorrect date format string

Ewen Cheslack-Postava created KAFKA-7460: Summary: Connect Values converter uses incorrect date format string Key: KAFKA-7460 URL: https://issues.apache.org/jira/browse/KAFKA-7460 Project: Kafk

[jira] [Resolved] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7434. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 Issue re

[jira] [Commented] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608631#comment-16608631 ] Ewen Cheslack-Postava commented on KAFKA-6684: -- [~amitsela] fyi, "not ready

[jira] [Commented] (KAFKA-4932) Add UUID Serde

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608605#comment-16608605 ] Ewen Cheslack-Postava commented on KAFKA-4932: -- [~brandon.kirchner] We inclu

[jira] [Resolved] (KAFKA-4932) Add UUID Serde

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4932. -- Resolution: Fixed Issue resolved by pull request 4438 [https://github.com/apach

[jira] [Resolved] (KAFKA-7353) Connect logs 'this' for anonymous inner classes

[ https://issues.apache.org/jira/browse/KAFKA-7353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7353. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16595907#comment-16595907 ] Ewen Cheslack-Postava commented on KAFKA-2260: -- I think it is worth pointing

[jira] [Resolved] (KAFKA-7242) Externalized secrets are revealed in task configuration

[ https://issues.apache.org/jira/browse/KAFKA-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7242. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 Issue re

[jira] [Resolved] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7225. -- Resolution: Fixed > Kafka Connect ConfigProvider not invoked before validation

[jira] [Updated] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-7225: - Fix Version/s: 2.1.0 2.0.1 > Kafka Connect ConfigProvider not

[jira] [Updated] (KAFKA-5071) ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-128] Failed to commit StreamTask 0_304 state: org.apache.kafka.streams.errors.ProcessorStateExcepti

[ https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5071: - Summary: ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-12

[jira] [Resolved] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7228. -- Resolution: Fixed > DeadLetterQueue throws a NullPointerException > ---

[jira] [Commented] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517504#comment-16517504 ] Ewen Cheslack-Postava commented on KAFKA-6889: -- Globs might be nice, but it

[jira] [Resolved] (KAFKA-7068) ConfigTransformer doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7068. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request 52

[jira] [Assigned] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-7058: Resolution: Fixed Assignee: Ewen Cheslack-Postava Revi

[jira] [Resolved] (KAFKA-7047) Connect isolation whitelist does not include SimpleHeaderConverter

[ https://issues.apache.org/jira/browse/KAFKA-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7047. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava Fix Version/s:

[jira] [Resolved] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned

[ https://issues.apache.org/jira/browse/KAFKA-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7039. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request 51

[jira] [Resolved] (KAFKA-7056) Connect's new numeric converters should be in a different package

[ https://issues.apache.org/jira/browse/KAFKA-7056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7056. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request 52

[jira] [Resolved] (KAFKA-7009) Mute logger for reflections.org at the warn level in system tests

[ https://issues.apache.org/jira/browse/KAFKA-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7009. -- Resolution: Fixed Fix Version/s: 2.1.0 0.11.0.3

[jira] [Resolved] (KAFKA-7031) Kafka Connect API module depends on Jersey

[ https://issues.apache.org/jira/browse/KAFKA-7031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7031. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request 51

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510622#comment-16510622 ] Ewen Cheslack-Postava commented on KAFKA-6161: -- [~chia7712] Really up to [~e

[jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510619#comment-16510619 ] Ewen Cheslack-Postava commented on KAFKA-6914: -- [~sriramks85] Spring Boot is

[jira] [Updated] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6914: - Fix Version/s: (was: 1.1.1) > Kafka Connect - Plugins class should have a con

[jira] [Resolved] (KAFKA-7043) Connect isolation whitelist does not include new primitive converters (KIP-305)

[ https://issues.apache.org/jira/browse/KAFKA-7043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7043. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request 51

[jira] [Resolved] (KAFKA-7003) Add headers with error context in messages written to the Connect DeadLetterQueue topic

[ https://issues.apache.org/jira/browse/KAFKA-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7003. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.0 Issue re

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504252#comment-16504252 ] Ewen Cheslack-Postava commented on KAFKA-6161: -- lol, thanks for the offer [~

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504243#comment-16504243 ] Ewen Cheslack-Postava commented on KAFKA-6161: -- I think it is now a compatib

[jira] [Updated] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6161: - Labels: needs-kip (was: ) > Introduce new serdes interfaces with empty configure

[jira] [Updated] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3992: - Fix Version/s: (was: 2.1.0) > InstanceAlreadyExistsException Error for Consum

[jira] [Resolved] (KAFKA-6997) Kafka run class doesn't exclude test-sources jar

[ https://issues.apache.org/jira/browse/KAFKA-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6997. -- Resolution: Fixed Issue resolved by pull request 5139 [https://github.com/apach

[jira] [Resolved] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters

[ https://issues.apache.org/jira/browse/KAFKA-6981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6981. -- Resolution: Fixed Issue resolved by pull request 5125 [https://github.com/apach

[jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16486603#comment-16486603 ] Ewen Cheslack-Postava commented on KAFKA-6914: -- [~sriramks85] Not sure I unde

[jira] [Resolved] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef

[ https://issues.apache.org/jira/browse/KAFKA-5807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5807. -- Resolution: Fixed Fix Version/s: 2.0.0 Issue resolved by pull request 376

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480973#comment-16480973 ] Ewen Cheslack-Postava commented on KAFKA-6566: -- [~rayokota] Merged back throu

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6566: - Fix Version/s: 0.10.2.2 > SourceTask#stop() not called after exception raised in p

[jira] [Resolved] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6566. -- Resolution: Fixed > SourceTask#stop() not called after exception raised in poll(

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6566: - Reviewer: Ewen Cheslack-Postava > SourceTask#stop() not called after exception rai

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6566: - Fix Version/s: 1.1.1 1.0.2 0.11.0.3 > Source

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469767#comment-16469767 ] Ewen Cheslack-Postava commented on KAFKA-6891: -- [~olkuznsmith] Yeah, agreed.

[jira] [Resolved] (KAFKA-5141) WorkerTest.testCleanupTasksOnStop transient failure due to NPE

[ https://issues.apache.org/jira/browse/KAFKA-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5141. -- Resolution: Fixed Assignee: Ewen Cheslack-Postava Not sure of the fix, but

[jira] [Commented] (KAFKA-4882) Remove internal converter configuration from example property files

[ https://issues.apache.org/jira/browse/KAFKA-4882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16458284#comment-16458284 ] Ewen Cheslack-Postava commented on KAFKA-4882: -- KAFKA-5540 is a generalizatio

[jira] [Commented] (KAFKA-5635) KIP-181 Kafka-Connect integrate with kafka ReST Proxy

[ https://issues.apache.org/jira/browse/KAFKA-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16458273#comment-16458273 ] Ewen Cheslack-Postava commented on KAFKA-5635: -- [~dhananjaydp] I'm inclined t

[jira] [Commented] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16458262#comment-16458262 ] Ewen Cheslack-Postava commented on KAFKA-6684: -- The idea here seems quite sim

[jira] [Assigned] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

[ https://issues.apache.org/jira/browse/KAFKA-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6735: Assignee: Ewen Cheslack-Postava > Document how to skip findbugs / checkstyl

[jira] [Commented] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

[ https://issues.apache.org/jira/browse/KAFKA-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16431672#comment-16431672 ] Ewen Cheslack-Postava commented on KAFKA-6735: -- Why should we document outs f

[jira] [Assigned] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6728: Assignee: Randall Hauch > Kafka Connect Header Null Pointer Exception > ---

[jira] [Resolved] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6728. -- Resolution: Fixed Fix Version/s: 1.1.1 1.2.0 Issue res

[jira] [Assigned] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6725: Assignee: Matt Farmer > Indicate "isClosing" in the SinkTaskContext > -

[jira] [Commented] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances

[ https://issues.apache.org/jira/browse/KAFKA-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16418435#comment-16418435 ] Ewen Cheslack-Postava commented on KAFKA-6717: -- Are both assigned the partiti

[jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407352#comment-16407352 ] Ewen Cheslack-Postava commented on KAFKA-3821: -- So a couple of points -- * T

[jira] [Created] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM

Ewen Cheslack-Postava created KAFKA-6676: Summary: System tests do not handle ZK chroot properly with SCRAM Key: KAFKA-6676 URL: https://issues.apache.org/jira/browse/KAFKA-6676 Project: Kafka

[jira] [Commented] (KAFKA-6651) SchemaBuilder should not allow Arrays or Maps to be created by type()

[ https://issues.apache.org/jira/browse/KAFKA-6651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401270#comment-16401270 ] Ewen Cheslack-Postava commented on KAFKA-6651: -- Could go either way. Based on

[jira] [Commented] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401255#comment-16401255 ] Ewen Cheslack-Postava commented on KAFKA-6661: -- Oh, also, I marked it as 1.1.

[jira] [Commented] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401254#comment-16401254 ] Ewen Cheslack-Postava commented on KAFKA-6661: -- [~rhauch] Got this cherry-pic

[jira] [Updated] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6661: - Fix Version/s: 1.1.1 1.0.2 0.11.0.3

[jira] [Commented] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16393217#comment-16393217 ] Ewen Cheslack-Postava commented on KAFKA-6626: -- It cannot be a regular map, s

[jira] [Commented] (KAFKA-5939) Add a dryrun option to release.py

[ https://issues.apache.org/jira/browse/KAFKA-5939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390528#comment-16390528 ] Ewen Cheslack-Postava commented on KAFKA-5939: -- I think dry run is fine if we

[jira] [Commented] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389095#comment-16389095 ] Ewen Cheslack-Postava commented on KAFKA-6127: -- Isn't a basic `poll()` also a

[jira] [Resolved] (KAFKA-5999) Offset Fetch Request

[ https://issues.apache.org/jira/browse/KAFKA-5999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5999. -- Resolution: Invalid Assignee: Ewen Cheslack-Postava Closing as Invalid unt

[jira] [Commented] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme

[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389064#comment-16389064 ] Ewen Cheslack-Postava commented on KAFKA-5799: -- Is there an actual Kafka issu

[jira] [Commented] (KAFKA-5626) Producer should be able to negotiate ProduceRequest version with broker

[ https://issues.apache.org/jira/browse/KAFKA-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387319#comment-16387319 ] Ewen Cheslack-Postava commented on KAFKA-5626: -- [~lindong] Given KIP-97, is t

[jira] [Resolved] (KAFKA-5471) Original Kafka paper link broken

[ https://issues.apache.org/jira/browse/KAFKA-5471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5471. -- Resolution: Fixed Assignee: Ewen Cheslack-Postava Updated the link to what

[jira] [Commented] (KAFKA-5306) Official init.d scripts

[ https://issues.apache.org/jira/browse/KAFKA-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16387300#comment-16387300 ] Ewen Cheslack-Postava commented on KAFKA-5306: -- I think the challenge here is

  1   2   3   >