[
https://issues.apache.org/jira/browse/KAFKA-521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13505148#comment-13505148
]
Swapnil Ghike commented on KAFKA-521:
-
Log.deleteOldSegments:
Just a nitpick, I person
[
https://issues.apache.org/jira/browse/KAFKA-622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-622:
Attachment: kafka-622-v3.patch
1. I see your point, that's good to know. Now using a case class with
[
https://issues.apache.org/jira/browse/KAFKA-521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13504871#comment-13504871
]
Swapnil Ghike commented on KAFKA-521:
-
1. I see, thanks for the clarification. If there
[
https://issues.apache.org/jira/browse/KAFKA-521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13504392#comment-13504392
]
Swapnil Ghike commented on KAFKA-521:
-
Overall, a lot of things have become much more r
[
https://issues.apache.org/jira/browse/KAFKA-622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-622:
Attachment: kafka-622-v2.patch
1.2, 2.1, 3.2, 5.3, 9.2: Renamed *Stat to *Stats and get*Stat to get
[
https://issues.apache.org/jira/browse/KAFKA-622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-622:
Attachment: kafka-622-v1.patch
The major change in this patch is to convert a bunch of *Stat objects
Swapnil Ghike created KAFKA-622:
---
Summary: Create mbeans per client
Key: KAFKA-622
URL: https://issues.apache.org/jira/browse/KAFKA-622
Project: Kafka
Issue Type: Bug
Components: cor
[
https://issues.apache.org/jira/browse/KAFKA-622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-622:
Labels: bugs improvement (was: improvement)
> Create mbeans per client
> -
[
https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13493749#comment-13493749
]
Swapnil Ghike commented on KAFKA-513:
-
Have finished writing down all functionality. Th
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-546:
Attachment: kafka-546-v5.patch
A small addition to the unit test to make sure that the iterator does
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-546:
Attachment: kafka-546-v4.patch
30. Fixed.
31. The test in v3 patch would've worked too, but changed
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-546:
Attachment: kafka-546-v3.patch
Thanks for the comments. The fixes are as follows:
20. Changed Consu
[
https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-513:
---
Assignee: Swapnil Ghike
> Add state change log to Kafka brokers
>
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-596:
Attachment: kafka-596-v3.patch
After a discussion with Jun, reverted the conditions in maybeRoll() t
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-596:
Attachment: kafka-596-v2.patch
Yes, I see your point. Attached a new patch.
> LogSe
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-546:
Attachment: kafka-546-v2.patch
Rebased.
> Fix commit() in zk consumer for compresse
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489286#comment-13489286
]
Swapnil Ghike commented on KAFKA-596:
-
Actually the modification in maybeRoll() in the
[
https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489201#comment-13489201
]
Swapnil Ghike commented on KAFKA-513:
-
Hi Prashanth,
How far along are you in this ji
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489191#comment-13489191
]
Swapnil Ghike edited comment on KAFKA-546 at 11/2/12 1:34 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-546:
Attachment: kafka-546-v1.patch
1. ConsumerIterator skips messages that have already been fetched.
2
[
https://issues.apache.org/jira/browse/KAFKA-546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-546:
---
Assignee: Swapnil Ghike
> Fix commit() in zk consumer for compressed messages
> --
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-596:
---
Assignee: Swapnil Ghike
> LogSegment.firstAppendTime not reset after truncate to
> ---
[
https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-596:
Attachment: kafka-596.patch
Yes, that's a pretty sharp observation. The current time based roll poli
[
https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-575:
Attachment: kafka-575-v3-correct.patch
Sorry, please ignore the last patch. This one is the correct
[
https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-575:
Attachment: kafka-575-v3.patch
Minor change + passed sanity test.
> Partition.makeF
[
https://issues.apache.org/jira/browse/KAFKA-592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-592:
Attachment: kafka-592-v1.patch
Change made to register AllTopicsProduceFailurePerSec,
AllTopicsFetc
Swapnil Ghike created KAFKA-592:
---
Summary: Register metrics beans at kafka server startup
Key: KAFKA-592
URL: https://issues.apache.org/jira/browse/KAFKA-592
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13486378#comment-13486378
]
Swapnil Ghike commented on KAFKA-589:
-
Hi Jason,
Are you using the KafkaServer.startu
[
https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-589:
---
Assignee: Swapnil Ghike
> Clean shutdown after startup connection failure
> --
[
https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-575:
Attachment: kafka-575-v2.patch
Made the change.
> Partition.makeFollower() reads br
[
https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-575:
Attachment: kafka-575-v1.patch
1. Live broker info included in LeaderIsrRequest.
ControllerBrokerR
[
https://issues.apache.org/jira/browse/KAFKA-579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-579:
Attachment: kafka-579-v1.patch
1. Modified syncProducer.connect() to not backoff and directly return
[
https://issues.apache.org/jira/browse/KAFKA-556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-556:
Attachment: kafka-556-v1.patch
Changed return/parameter/data types from Long to Int in the foll:
1.
[
https://issues.apache.org/jira/browse/KAFKA-579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-579:
---
Assignee: Swapnil Ghike
> remove connection timeout in SyncProducer
>
[
https://issues.apache.org/jira/browse/KAFKA-578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-578:
Assignee: (was: Swapnil Ghike)
> Leader finder thread in ConsumerFetcherManager needs to han
[
https://issues.apache.org/jira/browse/KAFKA-556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-556:
Labels: bugs (was: bugs newbie)
> Change MessageSet.sizeInBytes to Int
> --
[
https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-575:
---
Assignee: Swapnil Ghike
> Partition.makeFollower() reads broker info from ZK
> ---
[
https://issues.apache.org/jira/browse/KAFKA-556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-556:
---
Assignee: Swapnil Ghike (was: Jay Kreps)
> Change MessageSet.sizeInBytes to Int
> ---
[
https://issues.apache.org/jira/browse/KAFKA-578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-578:
---
Assignee: Swapnil Ghike
> Leader finder thread in ConsumerFetcherManager needs to handle e
[
https://issues.apache.org/jira/browse/KAFKA-567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13475327#comment-13475327
]
Swapnil Ghike commented on KAFKA-567:
-
Thanks for kafka-567.patch! I was also hitting t
[
https://issues.apache.org/jira/browse/KAFKA-567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-567:
Comment: was deleted
(was: Thanks for kafka-567.patch! I was also hitting this bug with the
contain
Swapnil Ghike created KAFKA-570:
---
Summary: Kafka should not need snappy jar at runtime
Key: KAFKA-570
URL: https://issues.apache.org/jira/browse/KAFKA-570
Project: Kafka
Issue Type: Bug
Aff
Swapnil Ghike created KAFKA-563:
---
Summary: KafkaScheduler shutdown in ZookeeperConsumerConnector
should check for config.autocommit
Key: KAFKA-563
URL: https://issues.apache.org/jira/browse/KAFKA-563
Pr
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Attachment: kafka-v0.8-v4.patch
Uploading kafka-v0.8-v4.patch.
This patch allows only ASCII alphan
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13463303#comment-13463303
]
Swapnil Ghike commented on KAFKA-495:
-
After a bit of discussion, decided to ALLOW only
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13463259#comment-13463259
]
Swapnil Ghike commented on KAFKA-495:
-
Reopening this issue because of additional const
[
https://issues.apache.org/jira/browse/KAFKA-509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13461964#comment-13461964
]
Swapnil Ghike commented on KAFKA-509:
-
The string "\0" is a valid topic name, I was jus
[
https://issues.apache.org/jira/browse/KAFKA-505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike closed KAFKA-505.
---
> Remove errorcode from TopicMetaDataResponse
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike resolved KAFKA-505.
-
Resolution: Fixed
> Remove errorcode from TopicMetaDataResponse
>
[
https://issues.apache.org/jira/browse/KAFKA-500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-500:
Attachment: kafka-500-v5.patch
1. Yes, {SyncProducer, SimpleConsumer}.send() now returns
TopicMetad
[
https://issues.apache.org/jira/browse/KAFKA-500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13458543#comment-13458543
]
Swapnil Ghike edited comment on KAFKA-500 at 9/19/12 9:13 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13458546#comment-13458546
]
Swapnil Ghike commented on KAFKA-505:
-
See KAFKA-500.
> Remove errorco
[
https://issues.apache.org/jira/browse/KAFKA-500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-500:
Attachment: kafka-500-v4.patch
1. Removed writeTo() from javaapi.{PartitionMetadata, TopicMetadata}.
[
https://issues.apache.org/jira/browse/KAFKA-473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-473:
---
Assignee: Yang Ye
> Use getMetadata Api in ZookeeperConsumerConnector
> --
[
https://issues.apache.org/jira/browse/KAFKA-500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-500:
Attachment: kafka-500-v3.patch
1. Probably svn generated a wrong diff due to a simultaneous rename a
[
https://issues.apache.org/jira/browse/KAFKA-500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-500:
Attachment: kafka-500-v2.patch
1. Rebased. javaapi/SyncProducer is gone.
2. Removed the two step cr
[
https://issues.apache.org/jira/browse/KAFKA-500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-500:
Attachment: kafka-500-v1.patch
1. Created java apis for TopicMetadataRequest and TopicMetadataRespon
[
https://issues.apache.org/jira/browse/KAFKA-500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-500:
---
Assignee: Swapnil Ghike
> javaapi support for getTopoicMetaData
>
[
https://issues.apache.org/jira/browse/KAFKA-463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-463:
Attachment: kafka-463-v3.patch
20.1. Letting the constructor be as it is as discussed.
20.2. Made t
Swapnil Ghike created KAFKA-515:
---
Summary: Log cleanup can close a file channel opnened by Log.read
before the transfer completes
Key: KAFKA-515
URL: https://issues.apache.org/jira/browse/KAFKA-515
Proj
[
https://issues.apache.org/jira/browse/KAFKA-463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-463:
Attachment: kafka-463-v2.patch
1. Made the changes 1.1, 1.3, 1.5, 2 as recommended.
2. Made an app
[
https://issues.apache.org/jira/browse/KAFKA-325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-325:
Attachment: kafka-325-v3.patch
Rebased and made the change.
> revisit broker config
[
https://issues.apache.org/jira/browse/KAFKA-325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13455079#comment-13455079
]
Swapnil Ghike commented on KAFKA-325:
-
monitoringPeriodSecs seems to be used in SocketS
Swapnil Ghike created KAFKA-509:
---
Summary: server should shut down on encountering invalid
highwatermark file
Key: KAFKA-509
URL: https://issues.apache.org/jira/browse/KAFKA-509
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-325:
Attachment: kafka-325-v2.patch
Rebased.
> revisit broker config in 0.8
> --
[
https://issues.apache.org/jira/browse/KAFKA-463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-463:
Attachment: kafka-463-v1.patch
Truncates all existing log segments if targetOffset is smaller than t
[
https://issues.apache.org/jira/browse/KAFKA-463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-463:
---
Assignee: Swapnil Ghike
> log.truncateTo needs to handle targetOffset smaller than the low
[
https://issues.apache.org/jira/browse/KAFKA-325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-325:
Attachment: kafka-300-v1.patch
This patch will conflict with the last patch in KAFKA-495.
- Removed
[
https://issues.apache.org/jira/browse/KAFKA-325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-325 started by Swapnil Ghike.
> revisit broker config in 0.8
>
>
> Key: KAFKA-325
> URL: https:/
[
https://issues.apache.org/jira/browse/KAFKA-325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-325:
---
Assignee: Swapnil Ghike
> revisit broker config in 0.8
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Attachment: kafka-495-v0.8-v3.patch
1. Done.
2. Thanks, should have thought of that. :\
3. Oh, tha
[
https://issues.apache.org/jira/browse/KAFKA-505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-505:
Issue Type: Improvement (was: Bug)
> Remove errorcode from TopicMetaDataResponse
>
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Attachment: kafka-495-v0.8-v2.patch
- After discussing with Jun, inserted topic validation in create
Swapnil Ghike created KAFKA-505:
---
Summary: Remove errorcode from TopicMetaDataResponse
Key: KAFKA-505
URL: https://issues.apache.org/jira/browse/KAFKA-505
Project: Kafka
Issue Type: Bug
Aff
[
https://issues.apache.org/jira/browse/KAFKA-458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-458:
Attachment: kafka-458-v4.patch
Modified the patch.
> remove errorcode from ByteBuff
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Attachment: kafka-495-v0.8.patch
Attached the 0.8 patch. It was taken with git --no-prefix, hope it
[
https://issues.apache.org/jira/browse/KAFKA-458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-458:
Attachment: kafka-458-v3.patch
2.1 As discussed with Jun, since any use of javaapi/ByteBufferMessage
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Attachment: kafka-495-v4.patch
Changed the property string in KafkaConfig for maxTopicNameLength.
[
https://issues.apache.org/jira/browse/KAFKA-490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-490:
Attachment: kafka-490-v2.patch
attached the modified patch. I dont know if it will need a rebase, sv
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Attachment: kafka-495-v3.patch
Thanks, made the changes.
> Handle topic names with
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Attachment: kafka-495-v2.patch
1. Actually the zookeeper code does not implement all the checks that
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13448374#comment-13448374
]
Swapnil Ghike edited comment on KAFKA-495 at 9/5/12 12:21 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13448374#comment-13448374
]
Swapnil Ghike commented on KAFKA-495:
-
So I am planning to insert the following regex c
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13448150#comment-13448150
]
Swapnil Ghike edited comment on KAFKA-495 at 9/5/12 12:14 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13448150#comment-13448150
]
Swapnil Ghike commented on KAFKA-495:
-
Some relevant discussion is at KAFKA-195.
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Fix Version/s: 0.7.1
0.8
Labels: bugs (was: )
Status: Patch
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-495:
Attachment: kafka-495-v1.patch
Created two server config properties -
1. Black list of characters
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-495 started by Swapnil Ghike.
> Handle topic names with "/" on Kafka server
> ---
>
> Key: KAFKA-495
[
https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-495:
---
Assignee: Swapnil Ghike
> Handle topic names with "/" on Kafka server
> --
[
https://issues.apache.org/jira/browse/KAFKA-458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-458:
Attachment: kafka-458-v2.patch
Changes from last patch:
1. Removed errorcode from message/ByteBuffe
[
https://issues.apache.org/jira/browse/KAFKA-490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-490:
Status: Patch Available (was: In Progress)
> Check max message size on server instead of produc
[
https://issues.apache.org/jira/browse/KAFKA-490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-490:
Attachment: kafka-490-v1.patch
1. The changes in Log are mostly similar to those in Kafka-469.
2.
[
https://issues.apache.org/jira/browse/KAFKA-490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-490 started by Swapnil Ghike.
> Check max message size on server instead of producer
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-469:
Attachment: kafka-469-v3.patch
Reopening this issue to remove the stack trace logged in case of rece
Swapnil Ghike created KAFKA-490:
---
Summary: Check max message size on server instead of producer
Key: KAFKA-490
URL: https://issues.apache.org/jira/browse/KAFKA-490
Project: Kafka
Issue Type: Bu
[
https://issues.apache.org/jira/browse/KAFKA-469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-469:
Attachment: kafka-469-v2.patch
Yes. Attached the change.
> Message size is not chec
[
https://issues.apache.org/jira/browse/KAFKA-475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-475:
Attachment: kafka-475-v4.patch
1. Topic level log roll size and retention size limits added.
2. Rem
Swapnil Ghike created KAFKA-481:
---
Summary: Require values in Utils.getTopic* methods to be positive
Key: KAFKA-481
URL: https://issues.apache.org/jira/browse/KAFKA-481
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13440519#comment-13440519
]
Swapnil Ghike commented on KAFKA-475:
-
1. Similarly, should we also add topic level log
[
https://issues.apache.org/jira/browse/KAFKA-469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-469:
Status: Patch Available (was: In Progress)
> Message size is not checked at the server
> --
1 - 100 of 133 matches
Mail list logo
